javascript - 如何使用集群处理 Socket.IO 房间？

Question

我有一个与集群一起工作的服务器，并与 socke.IO 一起工作:集群正在实例化进程，每个进程都有特定数量的房间。

• 服务器
  • 流程 1
    • 一室
    • 房间 2
    • N号房间
  • 流程 2
    • 一室
    • 房间 2
    • N号房间

我将一些用户连接到房间(只有一个进程)的方式是使用路由，用户在该路由中访问页面，当他尝试与 Socket.io 建立连接时，我会检查 URL 并使用它信息我将他插入一个房间。

我的问题是用集群实现此服务器我无法将用户插入特定房间，因为有些房间只存在于特定进程中，并且粘性 session 将他置于另一个进程中。如何将用户放在另一个进程中的房间中？另外用户只能看到他在服务器中的进程的路线，我想显示页面中的每个房间。

我已经阅读了 Redis-Adapter，但我没有在 github 上找到使用 Socket.io + Cluster(Sticky-session + redis-adapter) + rooms 的解决方案。

按照我的代码分享我所做的事情:

//Cluster.Master with simplified Code
if (cluster.isMaster) {

   var workers = [];
   // Spawn workers.
   for (var i = 0; i < num_processes; i++) {
      spawn(i);
   }

   // Create the outside facing server listening on our port.
   var server = net.createServer({
        pauseOnConnect: true
   }, function(connection) {
        // We received a connection and need to pass it to the appropriate
        // worker. Get the worker for this connection's source IP and pass
       // it the connection.
       var worker = workers[worker_index(connection.remoteAddress, num_processes)];
       worker.send('sticky-session:connection', connection);
   }).listen(process.env.PORT);
} else {
     console.log('I am worker #' + cluster.worker.id);
     var app = new express();

     //view engine
     app.set('views', './views');
     app.set('view engine', 'pug');
     //statics
     app.use(express.static(path.join(__dirname, 'public')));
     //rooms
     app.use('/', rooms);
     var server = app.listen(0, 'localhost'),
         io = sio(server);
     io.adapter(sio_redis({ host: 'localhost', port: 6379 }));

    //This File has the socket events (socket.on('messageX', function(){}))
    // And there I am 
    var realtime = require('./realtime/socketIOEvents.js')(io);

    // Listen to messages sent from the master. Ignore everything else.
    process.on('message', function(message, connection) {
    if (message !== 'sticky-session:connection') {
        return;
    }
   // Emulate a connection event on the server by emitting the
   // event with the connection the master sent us.
   server.emit('connection', connection);
   connection.resume();
});
}

Answer 1

socketio-redis 是正确的做法。每个 sserver/进程都会监听 redis 队列中的一个主题。简而言之，socketio-redis 只是将事件发布到集群中的每个其他服务器/进程。因此，就房间而言，它们只是一组对房间中的消息感兴趣的套接字的抽象。

即使套接字分布到不同的服务器/进程，它们也可以是同一个房间的一部分。当每条消息进来时，每个服务器都知道它并将其传递给所需的套接字。

就正确性而言，您的架构是正确的也是正确的，因为您的代理也决定选择性地转发消息，但它增加了消息生命周期中的跃点。你真的不需要这个代理来处理套接字路由。