Spring WebSocket如何向特定用户发送消息？

Question

我正在阅读《Spring in Action4》一书，以使用WebSocket上的STOMP消息传递。

假设用户目标前缀设置为“/user”，如下所示：

registry.setUserDestinationPrefix("/user");

然后客户端使用以下JavaScript代码订阅目标：

stomp.subscribe("/user/queue/notifications", handleNotifications);

/queue/notifications-user6hr83v6t  --- (1)

messaging.convertAndSendToUser( username, "/queue/notifications",
                           new Notification("You just got mentioned!"));

则该消息将发送到目的地,如下所示：

/user/<username>/queue/notifications  ---(2)

那么，两个目的地(1)和(2)看起来是不同的，消息怎么可能到达客户端呢？

Answer 1

小路

/user/<username>/queue/notifications 

似乎是文档中使用的“逻辑”路径。它最初也是用convertAndSendToUser方法创建的。然后将其转换为技术格式，在本行的UserDestinationMessageHandler类中完成

UserDestinationResult result = this.destinationResolver.resolveDestination(message);

例如

stompClient.subscribe('/user/queue/reply', function (greeting) { ...

stompClient.send("/app/personal", ...

@MessageMapping("/personal")
public void personalMessage(SimpMessageHeaderAccessor headerAccessor, PoCRequestMessage message) {

    SimpMessageHeaderAccessor ha = SimpMessageHeaderAccessor
            .create(SimpMessageType.MESSAGE);
    ha.setSessionId(headerAccessor.getSessionId());
    ha.setLeaveMutable(true);
    PoCReplyMessage reply = new PoCReplyMessage("Personal Message" + message.getName());
    simpMessagingTemplate.convertAndSendToUser(headerAccessor.getSessionId(), "/queue/reply", reply, ha.getMessageHeaders());
}

目标将按以下方式解析:

source destination: /user/zojdn53y/queue/reply
target destination: /queue/reply-userzojdn53y

这就是最终目标名称的解析方式。目标目的地是所创建队列的真实名称（至少在使用外部消息代理的情况下是这样的-没有检查是否有简单的内存中代理，但我假设这是一样的）。

需要注意的一件重要事情是，当您希望使用未经身份验证的用户时（在使用WebSocket进行实验时，最常见的情况是），您需要另外将消息头放在convertAndSendToUser方法中-这在Spring WebSocket@SendToSession：send message to specific session中有很好的描述