Spring websocket从多线程发送消息

Question

我是如何临时修复它的：考虑我已经实现了下面的方法

void sendMessageToSession(WebsocketSession session,String message);

它向websocket会话发送一个TextMessage。我无法使整个方法同步，因为多个线程可以为不同的websocketSessions和消息调用它。我也不能将会话放在同步块中（尝试了但没有工作）

虽然，我这样解决了我的问题

synchronized(session.getId()){ 
    //sending message;
}

session = new ConcurrentWebSocketSessionDecorator(session, (int) StaticConfig.MAXIMUM_WS_ASYNC_SEND_TIMEOUT, StaticConfig.MAXIMUM_WS_BINARY_BUFFER_SIZE * 2);

Answer 1

通过在我的WebSocketSession后面添加volatile关键字，我解决了这个问题。我很高兴知道这是否也是一个坏的做法。但我的想法是，当从多个线程写入websocket会话时，这些线程会释放websocket的状态，因为它还没有更新，这就是抛出这个异常的原因。

通过添加volatile,我们可以确保websocket状态在另一个线程使用它之前已经更新,这样写入websocket的工作就会像预期的那样同步。

我创建了一个名为SessionData的类，它保存websocketSession和我需要的关于Session的所有其他数据。

public class SessionData {
    private volatile WebSocketSession websocketSession;
    //...other 
    // getters and setters ...
}

这里的一个关键注意事项是，每次要向会话发送消息时，都应该使用sessionData.getWebSocketSession.SendMessage(...)。您不应该直接使用会话，这意味着像这样的代码是一种糟糕的做法：

WebSocketSession websocketSession = sessionData.getWebSocketSession();
websocketSession.sendMessage(...);

您永远不会知道在这两行代码（在您的例子中可能超过2行）之间对websocket会话应用了哪些更改。

此外，永远不要直接发布到Spring websocketMessageHandler中传递给您的会话中。否则，您可能会再次出现该错误。