socket.io“握手”失败，群集和粘滞会话

Question

var cluster = require('cluster');
var sticky = require('sticky-session');
var http   = require('http');

if (cluster.isMaster) {
  for (var i = 0; i < 4; i++) {
    cluster.fork();
  }

  Object.keys(cluster.workers).forEach(function(id) {
    console.log("Worker running with ID : " + 
      cluster.workers[id].process.pid);
  });
}

if (cluster.isWorker) {
  var anotherServer = http.createServer(function(req, res) {
    res.end('hello world!');
  });
  anotherServer.listen(3000);
  console.log('http server on 3000');
}

sticky(function() {
  var io = require('socket.io')();

  var server = http.createServer(function(req, res) {
    res.end('socket.io');
  });

  io.listen(server);

  io.on('connection', function onConnect(socket) {
    console.log('someone connected.');

    socket.on('sync', sync);
    socket.on('send', send);

    function sync(id) {
      socket.join(id);
      console.log('someone joined ' + id);
    }

    function send(id, msg) {
      io.sockets.in(id).emit(msg);
      console.log('someone sent ' + msg + ' to ' + id);
    }
  });

  return server;
}).listen(3001, function() {
  console.log('socket.io server on 3001')
});

var socket = require('socket.io-client')('http://localhost:3001');

socket.on('connect', function() { 
  console.log('connected')
  socket.emit('sync', 'secret') 
});

Answer 1

@jordyyy:我在谷歌之后也面临着同样的问题，我有一个很好的答案。IO握手任务在多个请求中完成，当您将在粘滞会话上运行时，这意味着您根据核心使用了多个进程。

因此，握手请求会分布在不同的进程上，它们之间不能通话（不是IPC）（它们是子进程），大多数情况下连接会失败/丢失（连接断开事件频繁发生）

那么什么是解决方案呢？解决方案是socketio-sticky-session

有关更多信息https://github.com/elad/node-cluster-socket.io（如果服务器支持IPv6，则需要worker_index方法的修补程序）

只是知识字节。*）：）

还有一件事，你不需要分叉过程。它将通过粘性会议来完成。