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

Question

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

我的web应用程序有弹簧安全设置并使用websocket。我遇到了棘手的问题，试图从服务器发送消息到特定用户只有。

我从阅读理解the manual从服务器我们可以做

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，登录使用任一摆锤/试验或吉姆/测试

3）点击“请求用户特定的信息”。预期：仅显示此用户的“收到的邮件给我”旁边显示“hello {用户名}”消息，实际：没有收到任何邮件

Answer 1

啊我发现我的问题是什么。首先，我没有发送时的简单代理注册/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,...) 

Answer 2

哦，client side no need to known about current user，服务器会为你做的。

在服务器端，使用下面的方法来发送消息到用户：

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

注意：使用queue，不topic，春天总是使用queue与sendToUser

在客户端

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

Exp lain

当任何websocket连接打开时，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，并且它将带有2个目的地的消息发送到您的消息代理。

消息代理接收消息并将其提供回服务器实例，该实例拥有与每个会话相对应的会话（WebSocket会话可由一个或多个服务器保存）。 Spring会将消息翻译为destination（例如：user/queue/reply）和session id（例如：wsxedc123）。然后，将消息发送到相应的Websocket session

Answer 3

我的，基于清阮文的最好解释的解决方案，但除了我已经配置MessageBrokerRegistry：

@Configuration 
@EnableWebSocketMessageBroker 
public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer { 

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

Answer 4

我使用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(); 
} 

}

它的作品是否“/用户”被包括在config.enableSimpleBroker（...

Answer 5

正是我做同样的，它是不使用用户

@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"); 
    } 
}