我需要水平可扩展的WebSocket连接服务器来实现类似聊天的系统，其中连接到不同WebSocket服务器的浏览器客户端可以在单独的聊天室中交换消息。ClientsHaProxyWebSocketserver1WebSocketserver2Redis/ZeroMQ||||clientA----=------------>o|||||clientB----=-------------|---------------->o|||||这里clientA和clientB通过HaProxy连接到两个不同的WebSocket服务器，它们交换消息通过Redis/ZeroMQ后端，如that和tha
我需要水平可扩展的WebSocket连接服务器来实现类似聊天的系统，其中连接到不同WebSocket服务器的浏览器客户端可以在单独的聊天室中交换消息。ClientsHaProxyWebSocketserver1WebSocketserver2Redis/ZeroMQ||||clientA----=------------>o|||||clientB----=-------------|---------------->o|||||这里clientA和clientB通过HaProxy连接到两个不同的WebSocket服务器，它们交换消息通过Redis/ZeroMQ后端，如that和tha
我正在创建一个传输层作为webApp的前端。用户可以通过移动应用程序和浏览器进行连接。传输层是多个应用程序的前端，包括聊天应用程序、多页面Web应用程序、通知和电子邮件服务器。规模约为4000个并发用户。少数场景不同的服务可能还需要相互交互。例如，聊天服务器可能会发送电子邮件。我正在为这个传输层寻找最佳设计。整个系统需要部署在云端，但需要独立于供应商。我的设计:1.通过NettoSphere(https://github.com/Atmosphere/nettosphere)或带有FallBacks的Netty创建套接字以进行HTTP轮询。2.将套接字层与Redis之类的Pub/Sub
我正在创建一个传输层作为webApp的前端。用户可以通过移动应用程序和浏览器进行连接。传输层是多个应用程序的前端，包括聊天应用程序、多页面Web应用程序、通知和电子邮件服务器。规模约为4000个并发用户。少数场景不同的服务可能还需要相互交互。例如，聊天服务器可能会发送电子邮件。我正在为这个传输层寻找最佳设计。整个系统需要部署在云端，但需要独立于供应商。我的设计:1.通过NettoSphere(https://github.com/Atmosphere/nettosphere)或带有FallBacks的Netty创建套接字以进行HTTP轮询。2.将套接字层与Redis之类的Pub/Sub
我正在尝试构建一个websocket服务器，每个客户端在其中建立自己的用于发布和订阅的redis连接。当redis服务器运行时，当客户端连接到websocket服务器时，我可以看到正在建立的两个新连接，我也可以向客户端发布数据，但是当客户端断开与websocket服务器的连接时，我也想要断开与Redis的连接。我该怎么做？也许我做错了，但这是我的代码。#require'redis'require'em-websocket'require'em-hiredis'require'json'CLIENTS=Hash.newclassPubSubdefinitialize(client)@so
我正在尝试构建一个websocket服务器，每个客户端在其中建立自己的用于发布和订阅的redis连接。当redis服务器运行时，当客户端连接到websocket服务器时，我可以看到正在建立的两个新连接，我也可以向客户端发布数据，但是当客户端断开与websocket服务器的连接时，我也想要断开与Redis的连接。我该怎么做？也许我做错了，但这是我的代码。#require'redis'require'em-websocket'require'em-hiredis'require'json'CLIENTS=Hash.newclassPubSubdefinitialize(client)@so
我正在处理有关新消息的通知。我想我需要为每个用户打开套接字，服务器会在收到新消息时发送通知。我想使用socket.io和redispub/sub。当用户发送消息时，它会将此事件发布到将成为订阅者的redis和nodejs服务器，并将通知客户端有关新消息的信息。但在这种情况下，消息会立即从队列中删除，当用户更新页面时，他会收到通知，所有消息都已读取，因为队列为空，但实际上并没有读取消息。如何判断这个问题？ 最佳答案 我已经为多页网络应用程序做了类似的事情，但现在它是单页的，我不再需要它了:varnotifications=[]...s
我正在处理有关新消息的通知。我想我需要为每个用户打开套接字，服务器会在收到新消息时发送通知。我想使用socket.io和redispub/sub。当用户发送消息时，它会将此事件发布到将成为订阅者的redis和nodejs服务器，并将通知客户端有关新消息的信息。但在这种情况下，消息会立即从队列中删除，当用户更新页面时，他会收到通知，所有消息都已读取，因为队列为空，但实际上并没有读取消息。如何判断这个问题？ 最佳答案 我已经为多页网络应用程序做了类似的事情，但现在它是单页的，我不再需要它了:varnotifications=[]...s
文档说明可以从消费者外部发布到channel层:https://channels.readthedocs.io/en/latest/topics/channel_layers.html#using-outside-of-consumers我需要做相反的事情。我有一个相当复杂的python脚本，它从pubnub读取实时数据，对其进行处理，然后通过channel_layer上的组将其推送给消费者。这工作正常，但我需要消费者能够向该脚本宣布他们的存在，以便它可以向他们推送数据(它目前仅在从pubnub获取新数据时才推送到channel层，这可能是每24小时一次)。我决定通过让消费者发布到连接
文档说明可以从消费者外部发布到channel层:https://channels.readthedocs.io/en/latest/topics/channel_layers.html#using-outside-of-consumers我需要做相反的事情。我有一个相当复杂的python脚本，它从pubnub读取实时数据，对其进行处理，然后通过channel_layer上的组将其推送给消费者。这工作正常，但我需要消费者能够向该脚本宣布他们的存在，以便它可以向他们推送数据(它目前仅在从pubnub获取新数据时才推送到channel层，这可能是每24小时一次)。我决定通过让消费者发布到连接
