Отправка сообщения конкретному пользователю в Spring Websocket

О, client side no need to known about current user, сервер сделает это за вас.

На стороне сервера, используя следующий способ отправки сообщения пользователю:

simpMessagingTemplate.convertAndSendToUser(username, "/queue/reply", message);

Примечание. Используя queue, а не topic, Spring всегда использует queue с sendToUser

На стороне клиента

stompClient.subscribe("/user/queue/reply", handler);

Объясните

Когда открыто какое-либо соединение с веб-сокетом, Spring присваивает ему session id (не HttpSession, назначается для каждого соединения). И когда ваш клиент подписывается на канал, начинающийся с /user/, например: /user/queue/reply, ваш экземпляр сервера подпишется на очередь с именем queue/reply-user[session id]

При использовании отправки сообщения пользователю, например: имя пользователя admin Вы должны написать simpMessagingTemplate.convertAndSendToUser("admin", "/queue/reply", message);

Spring определит, какой session id сопоставлен с пользователем admin. Например: обнаружено два сеанса wsxedc123 и thnujm456, Spring переведет их в 2 пункта назначения queue/reply-userwsxedc123 и queue/reply-userthnujm456 и отправит ваше сообщение с двумя адресатами вашему брокеру сообщений.

Брокер сообщений получает сообщения и возвращает их экземпляру вашего сервера, который поддерживает сеанс, соответствующий каждому сеансу (сеансы WebSocket могут удерживаться одним или несколькими серверами). Spring переведет сообщение в destination (например: user/queue/reply) и session id (например: wsxedc123). Затем он отправляет сообщение соответствующему Websocket session

Ах, я нашел, в чем была моя проблема. Сначала не прописал префикс /user на простом брокере

<websocket:simple-broker prefix="/topic,/user" />

Тогда мне не нужен лишний префикс /user при отправке:

convertAndSendToUser(principal.getName(), "/reply", reply);

Spring автоматически добавит "/user/" + principal.getName() к месту назначения, поэтому он преобразуется в "/ user / bob / reply".

Это также означает, что в javascript мне приходилось подписываться на разные адреса для каждого пользователя.

stompClient.subscribe('/user/' + userName + '/reply,...) 

Я также создал образец проекта веб-сокета, используя STOMP. Я замечаю, что

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer {

@Override
public void configureMessageBroker(MessageBrokerRegistry config) {
    config.enableSimpleBroker("/topic", "/queue");// including /user also works
    config.setApplicationDestinationPrefixes("/app");
}

@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
    registry.addEndpoint("/getfeeds").withSockJS();
}

}

он работает независимо от того, включен ли "/ user" в config.enableSimpleBroker (...

Мое решение этого вопроса основано на лучшем объяснении Тхань Нгуен Вана, но, кроме того, я настроил MessageBrokerRegistry:

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer {

    @Override
    public void configureMessageBroker(MessageBrokerRegistry config) {
        config.enableSimpleBroker("/queue/", "/topic/");
        ...
    }
    ...
}

Точно я сделал то же самое, и он работает без использования пользователя

@Configuration
@EnableWebSocketMessageBroker  
public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer {

    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
       registry.addEndpoint("/gs-guide-websocket").withSockJS();
    }

    @Override
    public void configureMessageBroker(MessageBrokerRegistry config) {
        config.enableSimpleBroker("/topic" , "/queue");
        config.setApplicationDestinationPrefixes("/app");
    }
}