我有一个 Spring Websocket 服务器,非常简单:
@Configuration
@EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {
@Override
public void registerWebSocketHandlers(WebSocketHandlerRegistry webSocketHandlerRegistry) {
webSocketHandlerRegistry.addHandler(new WebsocketHandler(), "/socket").setAllowedOrigins("*");
}
@Bean
public ServletServerContainerFactoryBean createWebSocketContainer() {
ServletServerContainerFactoryBean container = new ServletServerContainerFactoryBean();
container.setMaxBinaryMessageBufferSize(1024000);
container.setMaxTextMessageBufferSize(1024000);
return container;
}
}
和
public class WebsocketHandler extends AbstractWebSocketHandler {
@Override
protected void handleTextMessage(WebSocketSession session, TextMessage message) throws IOException {
System.out.println(message.getPayload()+"\n");
session.sendMessage(message);
}
@Override
protected void handleBinaryMessage(WebSocketSession session, BinaryMessage message) throws IOException {
System.out.println("New Binary Message Received");
session.sendMessage(message);
}
}
当我打开客户端(只是带有 SockJS 库的简单 HTML)时,客户端可以从服务器发送接收消息,但如果我使用类似的客户端打开新选项卡,则它无法接收其他客户端发布的消息客户。
这是因为session.sendMessage(message);
吗?当一个客户端发布消息时,所有其他客户端都能够接收到它,应该进行怎样的配置?
最佳答案
如果你想将数据发送给其他客户端,你需要跟踪 session 。正如您在 LINK 的文档中看到的那样该处理程序还有两个函数,用于连接打开后和连接关闭后。那么这对你有什么帮助呢?
您可以保持同步集合,例如 CopyOnWriteList<T>
或使用Collections.Synchronized
,当客户端连接 ( afterConnectionEstablished(WebSocketSession session)
) 时,将此客户端添加到此集合中,或者当客户端断开连接 ( afterConnectionClosed(WebSocketSession session, CloseStatus closeStatus)
) 时,您可以从集合中删除 session 。当您想要向每个客户端发送消息时,请循环此集合并使用 session 发送对象。如果您仍然觉得这很困惑,我可以提供一个代码示例。
关于java - Spring Websocket 处理程序未向所有客户端发布消息,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/61072137/