如何從另一個套接字訪問tcp套接字？

Question

我有幾個客戶端連接，其中一個應該監聽其他數據。我怎樣才能讓他們之間的橋樑（不是數組迭代器）？

示例僞代碼：

socket.on('data', function(chunk){ 
    decodeChunk(chunk.toString('hex'), function(response){ 
    if(response.name === 'toDB'){ 
     //write smth. to DB 
    } 

    if(response.name === 'readDB'){ 
     //watch all incoming tcp sockets with 'toDB' and continiously 
     //send to client connected with this socket 
    } 

    }); 
}) 

我可以使用像RabbitMQ的，但它並不適合現階段以保持發展更加敏捷。

任何建議表示讚賞。

Answer 1

結束了這樣的服務：

var SocketMedium = { 
    sessions: {}, 
    onEvent: function (event, cb) { 
    if (!this.sessions[event]) { 
     this.sessions[event] = []; 
     this.sessions[event].push(cb); 
    } else { 
     this.sessions[event].push(cb); 
    } 

    console.log('onEvent: ', event); 
    }, 
    rTrigger: function (event, data) { 
    console.log('Started rTrigger: ', event); 
    if(this.sessions[event]){ 
     console.log('FOUND: ', event); 
     this 
     .sessions[event] 
     .forEach(function (cb) { 
      cb(data); 
     }) 
    } 
    console.log('Completed rTrigger', this.sessions); 
    }, 
    cleaner: function(sessionId){ 

    var event = 'session' + sessionId; 

    if (this.sessions[event]) { 
     delete this.sessions[event]; 
     console.log('SocketMedium cleaned: ', this.sessions[event]); 
    } 

    console.log('SocketMedium can not find: ', this.sessions[event]); 
    } 
}; 

module.exports = SocketMedium; 

Answer 2

用純粹的僞代碼解決這個問題有點棘手，但無論如何我都會給它一個鏡頭。

如果我理解正確，那麼toDB和readDB是樣本數據，並且有多個toDB。這意味着，你還會有一堆toXY與相應的readXY或一堆toPQ以及相應的readPQ。如果是這樣，那麼只要連接了toSOMETHING，就可以將該套接字存儲在readSOMETHING下。如果密鑰已經存在，那麼你只需將toSOMETHING套接字添加到它。隨着時間的推移它會是這個樣子：

var socketData = { 
    readDB: { 
     sockets: [ 
      <socket-object-toDB-1>, 
      <socket-object-toDB-2>, 
      <socket-object-toDB-3> 
     ] 
    }, 
    readXY: { 
     sockets: [ 
      <socket-object-toXY-1>, 
      <socket-object-toXY-2>, 
      <socket-object-toXY-3> 
     ] 
    } 
} 

然後你的僞代碼可能會看起來像

socket.on('data', function(chunk){ 
    decodeChunk(chunk.toString('hex'), function(response){ 
    if(response.name === 'toDB'){ 
     //write smth. to DB 
     if (socketData['readDB']) { 
     // already exists, simply append incoming socket to it's sockets array 
     socketData['readDB'].sockets.push(socket); 
     } else { 
     // does not exist, add it with a sockets array 
     socketData['readDB'] = { 
      sockets: [socket] 
     } 
    } 

    if(response.name === 'readDB'){ 
     // Write to all sockets of readDB 
     socketData['readDB'].sockets.forEach(function(sock) { 
      sock.write('Whatever message\r\n'); 
     }); 
    } 

    }); 
})