SpringWebSocket是否支持订阅id？

Question

STOMP规范规定订阅必须有id头。

https://stomp.github.io/stomp-specification-1.2.html#SUBSCRIBE_id_Header

订阅id标头

由于单个连接可以与服务器有多个打开的订阅，因此必须在框架中包含id标头以唯一标识订阅。id标头允许客户端和服务器将后续消息或取消订阅帧与原始订阅关联。在同一连接中，不同的订阅必须使用不同的订阅标识符。

然而，在spring的例子中https://spring.io/guides/gs/messaging-stomp-websocket/，它在订阅目标时不指定id。

function connect() {
    var socket = new SockJS('/gs-guide-websocket');
    stompClient = Stomp.over(socket);
    stompClient.connect({}, function (frame) {
        setConnected(true);
        console.log('Connected: ' + frame);
        stompClient.subscribe('/topic/greetings', function (greeting) {
            showGreeting(JSON.parse(greeting.body).content);
        });
    });
}

在Spring的API中，SimpMessageSendingOperations.convertAndSendToUser不明确支持id标头。

我的问题是如何在向客户端发送消息时指定id头？

Answer 1

我认为您不能使用订阅ID向特定客户端发送消息。Stomp定义了这个ID，Spring的实现在内部使用它为订阅目标地址的每个客户端创建消息。因此，订阅ID在跺脚通信中是透明的...您可以在客户端指定它，或者让Stomp JS（STOMP over WebSocket）创建一个唯一的。

如果您订阅前缀为/user/的目标，并使用org.springframework.messaging.simp.SimpMessagingTemboard#transtAndSendToUser或org. springframework. mail. simp.注解。SendToUser向单个客户端发送消息，Spring所做的是注册并基于原始目的地创建对基于自定义会话的目的地的订阅。换句话说，来自Spring的Javadoc：

当用户尝试订阅时，例如订阅“/user/queue/position updates”，将删除“/user”前缀，并根据会话id添加一个唯一的后缀，例如“/queue/position-updates-useri9oqdfzo”，以确保不同用户可以订阅相同的逻辑目标而不会发生冲突。

发送给用户时，例如“/user/{username}/queue/position updates”，删除“/user/{username}”前缀，并添加基于活动会话id的后缀，例如“/queue/position-updates-useri9oqdfzo”。

看http://docs.spring.io/spring/docs/current/javadoc-api/org/springframework/messaging/simp/user/DefaultUserDestinationResolver.html

看见https://docs.spring.io/spring/docs/current/spring-framework-reference/html/websocket.html#websocket-跺脚用户目的地

编辑：

您不能使用订阅ID直接向其订阅的客户端发送消息，但可以使用客户端的会话ID。根据此处，您可以使用用户名向其发送消息。但是，您需要一个具有主体的经过身份验证的会话。或者，您可以在消息头中强制目标的会话ID，避免内部步骤来发现它，如下所示。

private void sendMessageToUser(String destinationSessionId, String message) {
    SimpMessageHeaderAccessor headerAccessor = SimpMessageHeaderAccessor.create(SimpMessageType.MESSAGE);
    headerAccessor.setSessionId(destinationSessionId);
    headerAccessor.setLeaveMutable(true);
    messagingTemplate.convertAndSendToUser(destinationSessionId, "/subscribe/private", message, headerAccessor.getMessageHeaders());
}

这样做，如果会话中没有主体，我就无法使用@SendToUser注释。