如何将消息广播到所有套接字？

Question

我有一个消息应用程序，我正在使用spring的stomp-websocket。

我向套接字发送消息，如下所示：

messageBean.convertAndSend( "/topic/message.${USER_ID}",  ${Message_Object} )

但是，在某些情况下，我希望将消息发送给活跃使用套接字的所有用户。

我的意思是，我想发送这样的信息：

messageBean.convertAndSend( "/topic/message",  ${Message_Object} )

我的意思是我不想为这个消息创建新的套接字。使用这个套接字的前端应用程序，比如sockJs.subscribe("/topic/message.${userId}")，我不想破坏这个逻辑。

我如何像我说的那样发送信息，或者我如何实现这个逻辑？

谢谢你的帮助。

Answer 1

我不确定这是否回答了您的问题，但是使用@SendTo和@MessageMapping注释的方法将自动向所有订阅者广播返回值。

如果它可能对你有所帮助，这里是我写的一个Kalah game的实现，它使用Spring WebSocket来实时地向活跃的玩家广播游戏状态。