Socket.io 'Handshake' 因集群和粘性会话而失败

Question

即使是一个简单的示例，我也无法让sticky-sessions socket.io 模块正常工作。按照自述文件 (https://github.com/indutny/sticky-session) 中给出的最小示例，我只是想让这个示例正常工作：

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') 
});

工人启动良好。 http 服务器工作正常。但是当客户端连接时，控制台会记录“有人连接”，仅此而已。客户端从不触发 on connect 事件，所以我认为升级/握手失败或其他什么。如果有人能发现我做错了什么，那将有很大帮助。

谢谢！

Answer 1

@jordyyy ：我在谷歌搜索后遇到了同样的问题，我有很好的答案。 Socket.Io 握手任务在多个请求中完成，当您在粘性会话上运行时，这意味着您正在根据您的核心使用多个进程。

因此握手请求将分布在不同的不同进程上，它们无法交谈。（不是 IPC）（它们是子进程）并且大部分时间连接将失败/丢失。（连接断开事件经常发生)

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

Socketio-sticky-session，基于 IP 管理连接。因此，当您请求任何客户端时，它将维护与进程/工作人员相关的 IP 地址。因此，进一步的请求将转发给相同的进程/工作人员，并且您的连接会正确稳定。

当你将使用 redies 适配器时，你实际上可以维护套接字 连接数据 b/w 所有进程/工作人员。

更多信息 https://github.com/elad/node-cluster-socket.io （如果您的服务器支持 IPv6，则需要对 worker_index 方法进行一些补丁）

只是知识字节。 :) :)

还有一点，你不需要 fork 进程。它将通过粘性会话完成。

Answer 2

这是超级旧的，当我需要它时并没有真正回答，但我的解决方案是删除这个坏模块和任何其他超级混乱的模块，只使用带有 redis 适配器的 pub/sub。唯一的其他步骤是强制传输到 websockets，如果这让任何人感到困扰，那么请使用其他东西。就我的目的而言，我的解决方案简单易读，没有与“典型”socket.io api 混淆，最重要的是它运行得非常好。