一尘不染

socket.io如何在多个服务器之间发送消息?

redis

Socket.io API具有发送消息的能力 所有 的客户。

通过一台服务器和所有套接字在内存中,我知道该服务器如何向其所有客户端发送消息,这是显而易见的。但是,使用Redis来存储套接字的多台服务器呢?

如果我的客户端 a 连接到服务器 y ,客户端 b 连接到服务器 z
(以及商店的Redis框),并且我socket.broadcast.emit在一个服务器上运行,则另一台服务器上的客户端将收到此消息。怎么样?

实际连接 到另一台服务器的客户端如何获得该消息?

  • 一台服务器是否 告诉另一台服务器 向其连接的客户端发送消息?
  • 服务器是否在建立与客户端的连接以发送该消息?

阅读 449

收藏
2020-06-20

共1个答案

一尘不染

Socket.io默认情况下使用MemoryStore,因此所有连接的客户端都将存储在内存中,这使得(连接到另一个socket.io服务器的)客户端发送和接收事件成为不可能(嗯,不是安静的,稍后再说)。

使所有socket.io服务器接收所有事件的一种方法是,所有服务器都使用redis的pub-
sub。因此,代替使用socket.emit可以发布到Redis。

redis_client = require('redis').createClient();
redis_client.publish('channelName', data);

并且所有套接字服务器都通过Redis订阅该通道,并在收到消息后将其发送给与其连接的客户端。

redis_sub = require('redis').createClient();
redis_sub.subscribe('channelName', 'moreChannels');

redis_sub.on("message", function (channel, message) {        
    socket.emit(channel, message);
});

复杂的东西!但是,等等,事实证明您实际上并不需要这种代码来实现目标。Socket.io具有RedisStore,它本质上以一种更好的方式完成了上面的代码应该做的事情,因此您可以像编写单个服务器一样编写Socket.io代码,并且仍然可以通过以下方式传播到其他socket.io服务器Redis。

总结一下,socket.io通过使用redis作为通道而不是内存在多个服务器之间发送消息。

2020-06-20