我有一个与集群一起工作的服务器，并与 socke.IO 一起工作正在实例化进程，每个进程都有特定数量的房间。
- 服务器
- 过程 1
- 房间1
- 房间2
- N号房间
- 过程 2
- 房间1
- 房间2
- N号房间
- 过程 1
我将一些用户连接到房间（只有一个进程）的方式是使用路由，用户访问页面以及当他尝试与 Socket.io 建立连接时，我检查 URL 并使用我插入的信息他在一个房间里。
我的问题是用集群实现此服务器我无法将用户插入特定房间，因为有些房间只存在于特定进程中，并且粘性会话将他置于另一个进程中。如何将用户放在另一个进程中的房间中？此外，使用只能查看他在服务器中的进程的路线，我想显示页面中的每个房间。
我已经阅读了有关 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();
});
}