在 Amazon Beanstalk 上处理 Spring Boot 集群 Websocket

Question

我有一个使用 Spring Framework/Spring Boot/Spring Messaging/Websockets 的应用程序，并将将其部署到 Elastic Beanstalk。您可以将应用程序视为聊天应用程序（它实际上确实具有聊天功能）

场景

这是一个示例场景：

Client A <-> Server A
Client B <-> Server B
Client C <-> Server B

现在，如果 Client A 使用 spring 消息传递一条消息，如果我将该消息发送到所有连接的客户端，则只有 Client A 会看到它，因为只有 Client A 连接到 Server A，同样如果 @ 987654327@ 会看到，只有Clients B and C 会看到，Client A 不会看到。

所以这给我留下了一个问题，我有哪些选择。

可能的解决方案

如果可能，我想使用亚马逊服务，因为我已经在他们的云平台上。

我考虑过使用 Amazon SQS，让每台服务器订阅同一个队列，然后通过它发送所有通知，但我相信所有使用 SQS 的请求都是活动的，所以我必须进行轮询，并且会创建一个显着的延迟。

有谁知道解决这个问题的好方法吗？我可以设置一个服务器来处理所有网络套接字，但这不是最佳的。

提前致谢！

Answer 1

我正在成功地完成你所描述的几乎完全一样的事情。

虽然我没有使用 spring boot，但是当通过弹性 beanstalk 在集群中运行时，我使用 spring 和 web 套接字向浏览器客户端发送推送消息。

我处理集群的方式是构建一个子系统，通过它我可以向其他节点发送消息。

因此，当我想从节点 AI 发送 Web 套接字消息时，从该节点发送 Web 套接字消息（它将发送给所有已注册的客户端），然后将消息发送给其他节点，让他们发送给他们的所有节点客户。

“集群内”消息传递是通过 SNS + SQS 完成的。在启动时，每个节点都会创建一个队列（由它的 instanceid 标识），在一个主题上注册该队列（所有节点都使用相同的主题），然后为该队列上的新消息启动一个侦听器。此侦听器使用长轮询。亚马逊不久前在其队列中增加了对“长轮询”的支持，起初它不可用。这意味着客户端最多可以阻塞 20 秒以等待消息，一旦收到消息，就会处理该消息 - 因此您的延迟非常低。当我想向主题发送消息时，消息会被路由到在该主题上注册的所有队列。然后，我还在侦听器中构建了过滤功能，以允许消息仅发送给“其他”客户端（即不要将其发送给我自己选项）。

我看到你确实提到了 RabbitMQ...我的方法的缺点是它不支持如果你使用支持 STOMP 消息协议的消息代理可能实现的丰富性。这样做意味着您根本不必担心集群，您只需发送到代理，它就会处理繁重的工作。如果我需要更丰富的解决方案，我想这将是我的下一步。

如果有人可以构建一个由 SQS 支持的 STOMP 客户端，那将是在 AWS 中在 Spring 上执行 Web 套接字消息的福音。