小编典典

Redis客户端广播问题(在Socket.IO上下文中)

redis

因此,我读了一些有关扩展Socket.IO的文章。由于种种原因,我不想使用内置的Socket.IO缩放机制(大多数情况似乎效率低下,因为从我的角度来看,它向Redis发布了很多东西)。

所以我想出了一个简单的想法:

每个Socket.IO服务器都创建Redis发布/订阅/存储客户端,连接到Redis并订阅频道。现在,当我要广播数据时,我只是将其发布到Redis,所有其他Socket.IO服务器都将其发布并将其推送给用户。

但是有一个问题(我认为这也是Socket.IO内置机制的问题)。假设我想知道所有已连接用户的数量。至少有两种方法可以做到这一点:

  1. 服务器A发布give_me_clients到Redis。然后,每个Socket.IO服务器都会计算连接数并发布number_of_clients。服务器A抓取该数据,将其组合并发送给客户端。

  2. number_of_clients_for::ID_HERE每当用户连接到服务器或从服务器断开连接时,每个服务器都会在Redis中更新。然后,服务器A仅获取数据并将其合并。可能会更有效率。

这些解决方案仍然存在问题:

  1. 服务器A不知道其他服务器。因此他不知道什么时候该停止听number_of_clients。可以通过使服务器A知道其他服务器来解决此问题:每当服务器连接到Redis时,他都会发布new_server(服务器A抓取数据并将其存储在内存中)。但是,当Redis-Socket.IO连接断开时该怎么办?Redis是否可以通知客户端其中一个客户端已断开连接?

  2. 其实和上面一样。当Socket.IO服务器崩溃时,如何清除number_of_clients数据?

因此,真正的问题是:Redis可以通知(发布到chanel)客户端与其中一个客户端的连接刚刚结束吗?


阅读 748

收藏
2020-06-20

共1个答案

小编典典

经过大量测试,Redis似乎没有这种功能。我还发现,扩展Socket.IO确实很痛苦。

因此,我已经从Socket.IO切换到WS(请参阅此链接)。它是低级的(但是很适合我使用),并且仅支持WebSockets(在所有主要版本中)。但是话又说回来,我只想支持WebSockets和FlashSocket(我必须手动对其进行实现,但这很好)。

优点是我可以轻松地使用此类服务​​器创建集群。HAProxy几乎可以立即使用此类服务​​器(有些小的调整)。服务器可以轻松地在本地网络上进行通信(如果群集很大,则可以使用UDP或中央TCP服务器)。

缺点是必须手动实现一些很酷的功能,例如心跳,广播,房间等。另外,您还希望进行长轮询回退,但这对我来说很好。缩放更重要,恕我直言。

2020-06-20