Spring websocket отправляет сообщение из нескольких потоков

Добавив volatile ключевое слово за моим WebsocketSession в том месте, где я сохраняю свои сеансы, я решил проблему. Я был бы рад узнать, если это тоже плохая практика. Но моя идея заключается в том, что при записи в сеанс веб-сокета из нескольких потоков эти потоки теряют состояние веб-сокета, потому что он еще не обновлен, и поэтому возникает это исключение.

Добавляя volatile, мы гарантируем, что состояние веб-сокета было обновлено до того, как его использует другой поток, поэтому запись в веб-сокет работает синхронизированно, как и ожидалось.

Я создал класс с именем SessionData, который содержит websocketSession и все другие данные, которые мне нужны о сеансе.

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

и я использовал SessionData как значение карты, где идентификаторы сеанса являются ключами

затем при получении websocketSession из SessionData и записи в него из разных потоков volatile помог мне получить обновленный websocketSession.

Обновление (2020)

Одно ключевое замечание здесь заключается в том, что вы должны использовать sessionData.getWebsocketSession.sendMessage(...) каждый раз, когда хотите отправить сообщение в сеанс. Никогда не следует использовать сеанс напрямую, что означает, что использование кода типа this является плохой практикой:

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

Вы никогда не узнаете, какие изменения были применены к сеансу websocket между этими двумя строками кода (в вашем случае их может быть больше 2).

Также никогда не публикуйте напрямую в сеансах, которые передаются вам внутри Spring websocket MessageHandlers. В противном случае вы, вероятно, снова получите эту ошибку.

Вот почему рекомендуется отображать sessionId из WebSocketSession в SessionData при открытии соединения. Вы можете использовать этот репозиторий для получения volatile session с использованием идентификатора сеанса вместо прямого использования сеанса.