因此,我读了一些有关扩展Socket.IO的文章。由于种种原因,我不想使用内置的Socket.IO缩放机制(大多数情况似乎效率低下,因为从我的角度来看,它向Redis发布了很多东西)。
所以我想出了一个简单的想法:
每个Socket.IO服务器都创建Redis发布/订阅/存储客户端,连接到Redis并订阅频道。现在,当我要广播数据时,我只是将其发布到Redis,所有其他Socket.IO服务器都将其发布并将其推送给用户。
但是有一个问题(我认为这也是Socket.IO内置机制的问题)。假设我想知道所有已连接用户的数量。至少有两种方法可以做到这一点:
服务器A发布give_me_clients到Redis。然后,每个Socket.IO服务器都会计算连接数并发布number_of_clients。服务器A抓取该数据,将其组合并发送给客户端。
give_me_clients
number_of_clients
number_of_clients_for::ID_HERE每当用户连接到服务器或从服务器断开连接时,每个服务器都会在Redis中更新。然后,服务器A仅获取数据并将其合并。可能会更有效率。
number_of_clients_for::ID_HERE
这些解决方案仍然存在问题:
服务器A不知道其他服务器。因此他不知道什么时候该停止听number_of_clients。可以通过使服务器A知道其他服务器来解决此问题:每当服务器连接到Redis时,他都会发布new_server(服务器A抓取数据并将其存储在内存中)。但是,当Redis-Socket.IO连接断开时该怎么办?Redis是否可以通知客户端其中一个客户端已断开连接?
new_server
其实和上面一样。当Socket.IO服务器崩溃时,如何清除number_of_clients数据?
因此,真正的问题是:Redis可以通知(发布到chanel)客户端与其中一个客户端的连接刚刚结束吗?
经过大量测试,Redis似乎没有这种功能。我还发现,扩展Socket.IO确实很痛苦。
因此,我已经从Socket.IO切换到WS(请参阅此链接)。它是低级的(但是很适合我使用),并且仅支持WebSockets(在所有主要版本中)。但是话又说回来,我只想支持WebSockets和FlashSocket(我必须手动对其进行实现,但这很好)。
优点是我可以轻松地使用此类服务器创建集群。HAProxy几乎可以立即使用此类服务器(有些小的调整)。服务器可以轻松地在本地网络上进行通信(如果群集很大,则可以使用UDP或中央TCP服务器)。
缺点是必须手动实现一些很酷的功能,例如心跳,广播,房间等。另外,您还希望进行长轮询回退,但这对我来说很好。缩放更重要,恕我直言。