node.js – 在socket.io中使用RedisStore的示例

不同之处在于，当使用默认MemoryStore时，您在工作程序中发出的任何消息只会发送到连接到同一个工作程序的客户端，因为工作程序之间没有IPC。使用RedisStore，您的消息将发布到redis服务器，您的所有工作者都在订阅该服务器。因此，消息将被所有工人和所有连接的客户端拾取和广播。

我不是非常熟悉RedisStore，所以我不知道所有的差异。但是自己做这是一个完全有效的做法。在这种情况下，您可以将所有消息发布到redis服务器，并监听套接字处理程序中的消息。这可能会为你更多的工作，但你也将有更多的控制你如何设置它。我自己做了类似的事情：

// Publishing a message somewhere
var pub = redis.createClient();
pub.publish("messages",JSON.stringify({type: "foo",content: "bar"}));

// Socket handler
io.sockets.on("connection",function(socket) {
  var sub = redis.createClient();
  sub.subscribe("messages");
  sub.on("message",function(channel,message) {
    socket.send(message);
  });

  socket.on("disconnect",function() {
    sub.unsubscribe("messages");
    sub.quit();
  });
});

这也意味着您必须自己处理更高级的消息路由，例如通过发布/订阅不同的频道。使用RedisStore，您可以使用socket.io通道(io.sockets.of(“channel”)。emit(…))免费获得该功能。

一个潜在的大缺点是，socket.io会话不是工人之间共享。如果使用任何长轮询传输，这可能意味着问题。