11

クラスターで動作するサーバーがあり、それを socke.IO で動作させるために、スティッキーセッションを使用していますが、部屋に問題があります (私が行った方法が最良の選択肢であるかどうかはわかりません): クラスタープロセスをインスタンス化しており、各プロセスには特定の数の部屋があります。

  • サーバ
    • 工程1
      • ルーム1
      • ルーム2
      • ルームN
    • 工程2
      • ルーム1
      • ルーム2
      • ルームN

一部のユーザーを部屋に接続するために行った方法 (1 つのプロセスのみ) は、ユーザーがページにアクセスし、Socket.io との接続を試みたときに、URL を確認し、その情報を挿入するルートを使用することです。部屋で彼。

私の問題は、このサーバーをクラスターで実装することです。特定のプロセスにのみ存在する部屋がいくつかあり、スティッキーセッションが彼を別のプロセスに置くため、特定の部屋にユーザーを挿入できません。別のプロセスにあるルームにユーザーを入れるにはどうすればよいですか? また、彼がサーバーにいるプロセスのルートを確認するためだけに使用でき、ページ内のすべての部屋を表示したいと思います。

Redis-Adapter については既に読んだことがありますが、Socket.io + Cluster(Sticky-session + redis-adapter) + rooms を使用して github で解決策が見つかりませんでした。

私のコードに従って、私が行ったことを共有してください。

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

3 に答える 3

1

これは、参加する部屋に基づいて機能するサンプルコードです。

http://www.html5gamedevs.com/topic/12321-create-a-cluster-server-with-nodejs-and-socketio/

この投稿で質問がある場合はお知らせください。

于 2016-10-25T06:09:58.857 に答える