Socket.io - 푸시 스트림에서 클라이언트로 데이터 보내기

Question

pusher-client-node을 통해 소비되는 데이터 스트림을 Socket.IO를 사용하여 클라이언트로 보내려고합니다.

이 같은 Node.js를 내 데이터를 수신하고 있습니다 : 지속적으로 제공

var API_KEY = 'cb65d0a7a72cd94adf1f'; 
var pusher = new Pusher(API_KEY, { 
    encrypted: true 
}); 
var channel = pusher.subscribe("ticker.160"); 
channel.bind("message", function (data) { 
    //console.log(data); 
}); 

내 데이터는 그 다음과 같습니다

내 Socket.IO 코드는 다음과 같습니다

{ channel: 'ticker.160', 
    trade: 
    { timestamp: 1420031543, 
    datetime: '2014-12-31 08:12:23 EST', 
    marketid: '160', 
    topsell: { price: '0.00007650', quantity: '106.26697381' }} 

:

/** 
* Socket.io 
*/ 
var io = require("socket.io").listen(server, {log: true}); 
var users = []; 

var stream = channel.bind("message", function (data) { 
    console.log(data); 
}); 

io.on("connection", function (socket) { 
    // The user it's added to the array if it doesn't exist 
    if(users.indexOf(socket.id) === -1) { 
     users.push(socket.id); 
    } 

    // Log 
    logConnectedUsers(); 

    socket.emit('someevent', { attr: 'value' }) 

    stream.on("newdata", function(data) { 
     // only broadcast when users are online 
     if(users.length > 0) { 
      // This emits the signal to the user that started 
      // the stream 
      socket.emit('someevent', { attr: 'value' }) 

     } 
     else { 
      // If there are no users connected we destroy the stream. 
      // Why would we keep it running for nobody? 
      stream.destroy(); 
      stream = null; 
     } 
    }); 

    // This handles when a user is disconnected 
    socket.on("disconnect", function(o) { 
     // find the user in the array 
     var index = users.indexOf(socket.id); 
     if(index != -1) { 
      // Eliminates the user from the array 
      users.splice(index, 1); 
     } 
     logConnectedUsers(); 
    }); 
}); 

// A log function for debugging purposes 
function logConnectedUsers() { 
    console.log("============= CONNECTED USERS =============="); 
    console.log("== :: " + users.length); 
    console.log("============================================"); 
} 

나는 Node.JS. 내 푸셔 스트림을 사용하기 Node.js를하고 Socket.IO와 투쟁에 아주 새로운 오전 따라서 내 질문 : 어떻게 내 Pusher 코드 내 Socket.IO 코드를 연결하려면? 당신은 socket/io rooms를 사용할 필요가

Answer 1

...

서버 :

var channel = pusher.subscribe("ticker.160"); //subscribe to pusher 

//pass messages from pusher to the matching room in socket.io 
channel.bind("message", function (data) { 
    io.to('ticker.160').emit('room-message', {room:'ticker.160', data:data}); 
}); 

... 

io.on("connection", function (socket) { 
    ... 
    socket.on('join', function(room){ 
    socket.join(room); 
    }); 
    socket.on('leave', function(room){ 
    socket.leave(room); 
    }); 
}); 

클라이언트 :

io.emit('join','ticker.160'); 
io.on('room-message', function(message){ 
    switch(message.room) { 
    case 'ticker.160': return doSomething(message.data); 
    ... 
    } 
});