如何在会话中向特定订阅发送 websocket 消息？

问题描述

我已经使用 Spring WebSocket 和 STOMP 实现了一个 WebSocket 服务器。单个会话中有多个订阅，我只想向特定订阅发送消息。

重现步骤：

1. 客户端通过调用注册的 STOMP 端点连接到服务器。

   

2. 客户端通过连接进行 2 次订阅。

SUBSCRIBE
country:germany
id:sub-0
destination:/user/queue/countryUpdates

SUBSCRIBE
country:france
id:sub-1
destination:/user/queue/countryUpdates

3. 在 SimpuserRegistry 中有 1 个用户和 1 个会话，其中 2 个订阅。

   

4. 问题是，如果我向一个订阅发送消息，它也会发送给其他订阅。

   

5. 在发送消息时，我正在本机标头中添加订阅 ID，但它不起作用。

SimpMessageHeaderAccessor accessor = SimpMessageHeaderAccessor.create(SimpMessageType.MESSAGE);
accessor.setNativeHeader("id",subscriptionId);
accessor.setNativeHeader("subscription",subscriptionId);
accessor.setSubscriptionId(subscriptionId);
accessor.setLeaveMutable(true);
messagingTemplate.convertAndSendToUser(simpuserId,REPLY_DESTINATION,message,accessor.getMessageHeaders());

我尝试过的：如果我将国家/地区添加到目的地，则每个订阅都有唯一的目的地，而不会有重复的消息。

我想使用 id/subscriptionId 来确定订阅并向该特定订阅发送消息。

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）