在SockJS + Spring Websocket中，convertAndSendToUser中的“用户”来自哪里？

Question

我想了解convertAndSendToUser如何在Spring SockJS + Websocket框架中工作。

在客户端，我们将连接为

stompClient.connect(login, password, callback())

这将导致使用登录名和密码的“ Stomp凭据”进行连接请求，例如，如果我们处理SessionConnectEvent
http://www.sergialmar.com/2014/03/detect-websocket-connects-and-disconnects-
in
，就会看到该请求-spring-4
/

但是我仍然不清楚这是否是服务器端发送到队列的“用户”：

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

我能得到的最接近的是在SpringWebsocket上阅读此线程正在向特定用户发送消息，作者是Thanh Nguyen Van，但仍不清楚。

基本上，我需要做的是使一些客户端订阅同一主题，但是在服务器上，向他们发送不同的数据。客户可以提供用户标识符。

Answer 1

我们知道我们可以使用他订阅的主题前缀从单足服务器向客户端发送消息/topic/hello。我们也知道我们可以将消息发送给特定的用户，因为spring提供了convertAndSendToUser(username, destination, message)API。它接受一个字符串用户名，这意味着如果我们为每个连接都拥有唯一的用户名，则我们应该能够向订阅主题的特定用户发送消息。

鲜为人知的是，该用户名来自何处？

该用户名是java.security.Principal界面的一部分。每个StompHeaderAccessor或WebSocketSession对象有此主体的情况下，你可以从它那里得到的用户名。但是，根据我的实验，它不是自动生成的。
它必须由服务器为每个会话手动生成。

要首先使用此接口，您需要实现它。

class StompPrincipal implements Principal {
    String name

    StompPrincipal(String name) {
        this.name = name
    }

    @Override
    String getName() {
        return name
    }
}

然后，可以StompPrincipal通过覆盖DefaultHandshakeHandler为每个连接生成唯一的。您可以使用任何逻辑来生成用户名。这是一种使用UUID的潜在逻辑：

class CustomHandshakeHandler extends DefaultHandshakeHandler {
    // Custom class for storing principal
    @Override
    protected Principal determineUser(
        ServerHttpRequest request,
        WebSocketHandler wsHandler,
        Map<String, Object> attributes
    ) {
        // Generate principal with UUID as name
        return new StompPrincipal(UUID.randomUUID().toString())
    }
}

最后，您需要配置websocket以使用自定义的握手处理程序。

@Override
void registerStompEndpoints(StompEndpointRegistry stompEndpointRegistry) {
    stompEndpointRegistry
         .addEndpoint("/stomp") // Set websocket endpoint to connect to
         .setHandshakeHandler(new CustomHandshakeHandler()) // Set custom handshake handler
         .withSockJS() // Add Sock JS support
}

而已。现在，您的服务器已配置为为每个连接生成唯一的主体名称。它将把该主体作为StompHeaderAccessor您可以通过连接事件侦听器，MessageMapping函数等访问的对象的一部分进行传递。

来自事件监听器：

@EventListener
void handleSessionConnectedEvent(SessionConnectedEvent event) {
    // Get Accessor
    StompHeaderAccessor sha = StompHeaderAccessor.wrap(event.getMessage())
}

从消息映射的API

@MessageMapping('/hello')
protected void hello(SimpMessageHeaderAccessor sha, Map message) {
    // sha available in params
}

关于使用的最后一点说明convertAndSendToUser(...)。向用户发送消息时，您将使用类似这样的内容

convertAndSendToUser(sha.session.principal.name, '/topic/hello', message)

但是，要订阅客户端，您将使用

client.subscribe('/user/topic/hello', callback)

如果您订阅客户端，/topic/hello您将只收到广播的消息。