Как я могу обрабатывать комнаты Socket.IO с помощью кластера?

У меня есть сервер, работающий с кластером и работающий с socke.IO Я использую липкую сессию, но у меня проблемы с моими комнатами (я не знаю, лучший ли способ, который я сделал): Кластер создает экземпляры процессов, и каждый процесс имеет определенное количество комнат.

• Сервер
  • Процесс 1
    • Room1
    • Room2
    • Комната N
  • Процесс 2
    • Room1
    • Room2
    • Комната N

То, как я сделал, чтобы подключить некоторого пользователя к комнатам (только с одним процессом), использует маршрут, где пользователь обращается к странице, и когда он пытается установить соединение с Socket.io, я проверяю URL-адрес и с этим Я вставляю его в комнату.

Моя проблема заключается в реализации этого сервера с кластером. Я не могу вставить пользователя в определенные комнаты, потому что есть некоторые комнаты, которые существуют только в определенных процессах и липкий сеанс, поставил его в другой процесс. Как я могу поместить пользователя в комнату, которая находится в другом процессе? Также использование может только увидеть маршруты процесса, который он находится на сервере, и я хотел бы показать все номера на странице.

Я уже прочитал о Redis-Adapter, но я не нашел решений на github, используя Socket.io + Cluster (Sticky-session + redis-adapter) + комнаты.

Следуйте моему коду, чтобы поделиться тем, что я сделал:

//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 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();
});
}

Ответы

                      Proxy
           /            |          \
worker(5rooms)   worker(5rooms)  worker(5rooms)
           \            |          /
                      Redis