在骆驼 websocket 连接/断开连接上连接/断开 ActiveMQ 主题

Question

我有以下骆驼路由，它侦听 ActiveMQ 主题上的消息并立即将它们发送到所有连接的 Web 套接字客户端。这工作正常，但是一旦初始化路由构建器，就会建立与主题的连接。

from("activemq:topic:mytopic").routeId("routeid").to("websocket://test?sendToAll=true");

我需要的是仅在一个或多个客户端连接到 Web 套接字时才连接到主题。一旦没有更多的连接，我想停止听这个话题。这可能吗？

Answer 1

据我所知，没有正确的方法可以做到这一点。实现这一点的唯一方法是覆盖 Jetty WebSocket 代码。覆盖 Jetty Websocket 代码后，您可以灵活地在打开和关闭 Websocket 中编写自己的自定义代码。

• 为打开的 websocket 中的所有 websocket 客户端维护一个列表。检查关闭 websocket 并将其从列表中删除以了解有多少已连接或已断开连接。或者在打开和关闭 websocket 时设置一个计数器。
• 一旦所有 websocket 客户端关闭，就暂停路由，以便您的消息保留在主题或队列中。
• 如果有任何客户端连接到 websocket，请恢复路由，以便消息到达连接的特定客户端。