在Spring Websocket上向特定用户发送消息

Question

如何仅将websocket消息从服务器发送给特定用户？

我的webapp具有Spring Security设置，并使用websocket。我在尝试只从服务器向特定用户发送消息时遇到了一个棘手的问题。

从阅读手册中我的理解是从服务器上我们可以做到的

simpMessagingTemplate.convertAndSend("/user/{username}/reply", reply);

在客户端：

stompClient.subscribe('/user/reply', handler);

但是我永远无法调用订阅回调。我尝试了许多不同的道路，但没有运气。

如果我将它发送到/topic/reply，它会工作，但所有其他连接的用户也会收到它。

为了说明这个问题，我在github上创建了这个小项目：https://github.com/gerrytan/wsproblem

复制步骤：

1）克隆并构建项目（确保您使用的是jdk 1.7和maven 3.1）

$ git clone https://github.com/gerrytan/wsproblem.git
$ cd wsproblem
$ mvn jetty:run

2） 导航到http://localhost:8080，使用bob/test或jim/test登录

3） 单击“请求用户特定消息”。预期：仅此用户的“Received message to Me Only”旁边显示消息“hello{username}”，实际：未收到任何消息

Answer 1

我还使用STOMP创建了一个示例websocket项目。我注意到的是

@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”，它都有效。enableSimpleBroker（。。。

Answer 2

啊我发现了我的问题所在。首先，我没有在简单代理上注册/user前缀

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

发送时，我不需要额外的/user前缀：

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

Spring将自动在“/user/”主体前面加上前缀。getName（）到目标，因此它解析为“/user/bob/reply”。

这也意味着在javascript中，我必须为每个用户订阅不同的地址

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

Answer 3

哦，客户端不需要知道当前用户的情况，服务器会为您这样做。

在服务器端，使用以下方式向用户发送消息：

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

注意：使用队列，而不是主题，Spring总是将队列与发送程序

在客户端

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

解释

当任何websocket连接打开时，Spring将为其分配一个会话id（不是HttpSession，为每个连接分配）。当您的客户端订阅以/user/开头的频道时，例如：/user/queue/reply，您的服务器实例将订阅名为queue/reply user[session id]

当使用send message to user时，例如：username是admin，您将编写SimpMessageTemplate。convertAndSendToUser（“管理”，“队列/回复”，消息）

Spring将确定哪个会话id映射到用户admin。例如：它找到了两个会话wsxedc123和thnumjm456，Spring将把它翻译成两个目的地queue/reply-userwsxedc123和queue/reply-userthnumjm456，并将您的消息发送到您的消息代理。

消息代理接收消息并将其提供回与每个会话相对应的保持会话的服务器实例（WebSocket会话可以由一个或多个服务器保持）。Spring将消息翻译为目的地（例如：user/队列/回复）和会话id（例如：wsxedc123）。然后，它将消息发送到相应的WebSocket会话