如何从另一个套接字访问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'); 
     }); 
    } 

    }); 
})