如何发送消息到一个特定的订阅通过Spring webSocket STOMP？

Question

我用的是带Spring靴的网靴。是否有可能向特定订阅发送消息？根据STOMP文档，我使用包含id字段的STOMP头订阅STOMPendpoint，我希望使用此id确定应该接收消息的客户端，但是spring似乎没有使用这个id。我不能只使用sendToUser，因为两个客户端可以具有相同的用户id，例如，如果一个用户有两个打开的浏览器窗口。只有一个特定窗口应接收该消息。

在下面的示例中，我有两个连接的客户端，它们使用相同的用户，但在STOMP标头中使用不同的id。

客户ID:a32d66bf-03c7-47a4-aea0-e464c0727842

客户2 ID:b3673d33-1bf2-461e-8df3-35b7af07371b

在spring中，我执行了以下Kotlin代码：

val subscriptions =  userRegistry.findSubscriptions {
            it.destination == "/user/topic/operations/$operationId/runs"
        }
        subscriptions.forEach{
            println("subscription id: ${it.id}");
            println("session id: ${it.session.id}");
            println("user id ${it.session.user.name}");
        }

输出：

subscription id: sub-7
session id: mcjpgn2i
user id 4a27ef88-25eb-4175-a872-f46e7b9d0564
subscription id: sub-7
session id: 0dxuvjgp
user id 4a27ef88-25eb-4175-a872-f46e7b9d0564

没有迹象表明我已经传递给跺脚头的id。

是否可以将消息发送到一个特定的订阅，该订阅由我通过标头的id确定？

Answer 1

我让它工作了。

首先，我的客户端设置有问题。我在连接头中设置了订阅id，如下所示：

this.stompClient.webSocketFactory = (): WebSocket => new SockJS("/ws");
this.stompClient.connectHeaders = { id: subscriptionId };
this.stompClient.activate();

但必须在订阅标头中设置订阅标头：

this.stompClient.subscribe(this.commonEndpoint,
        this.onMessageReceived.bind(this),
        { id: subScriptionId });

如果我这样做，spring将正确地使用这个id作为订阅id，而不是使用一些默认的sub-7。

根据该线程，我可以向特定会话而不是用户发送消息。

通过以下代码，我可以向特定订阅发送消息：

val subscriptions = userRegistry.findSubscriptions {
            it.destination == "/user/topic/operations/$operationId/runs"
        }
subscriptions.forEach {
    if(it.id === mySubscriptionId){
        val headerAccessor = 
        SimpMessageHeaderAccessor.create(SimpMessageType.MESSAGE)
        headerAccessor.sessionId = it.session.id
        headerAccessor.setLeaveMutable(true)

        simpMessagingTemplate.convertAndSendToUser(it.session.id,  
            "/topic/operations/runs", messageResponseEntity,
            headerAccessor.getMessageHeaders())

     }
}