共享订阅是否可以达到 那个客户端发的消息，回复到发送消息的客户端

EMQX
1

比如我A客户端订阅了 $queue/topic/s/#,B客户端订阅了 $queue/topic/s/#，我A客户端向 /topic/v/1发送了一条消息，消息接受者向 /topic/s/1返回消息，如何客户端A一直收到消息，我目前共享订阅策略是 hash_clientid，达不到这样的效果

总结：怎么可以达到 谁发送的消息谁接收返回消息的效果

2

不行，用上共享订阅，就无法达到这种效果了。

3

那不用，怎么可以达到这样的效果 除了全都订阅通配符主题广播形式

4

1. 使用请求-响应模式 (Request-Response Pattern)

  • 发送消息时在payload中包含reply_to字段，指定响应主题
  • 例如：A客户端发送到/topic/v/1时，payload包含reply_to: /topic/reply/clientA
  • A客户端同时订阅/topic/reply/clientA
  • 响应方向/topic/reply/clientA发送响应

2. 基于ClientID的动态主题

  • 发送方使用包含自己ClientID的主题发送消息
  • 例如：/topic/v/{clientid}/request
  • 响应主题：/topic/s/{clientid}/response
  • 每个客户端只订阅自己的响应主题

3. 使用MQTT 5.0的Response Topic属性

发送消息时设置：
- Response Topic: /response/{clientid}
- Correlation Data: 唯一标识符

客户端订阅: /response/{clientid}

完整流程

  1. A客户端发送消息到/topic/v/1，设置：
  • responseTopic: /response/clientA
  • correlationData: req-001
  1. B客户端（处理者）收到消息，从消息属性中获取响应主题
  2. B客户端处理完成后，向/response/clientA发送响应
  3. A客户端从自己的响应主题/response/clientA收到响应

4. 消息ID关联方案

  • 在消息中包含唯一的消息ID和发送方标识
  • 所有客户端都订阅响应主题，但根据消息ID过滤
  • 只处理与自己发送的消息ID匹配的响应
    不是很推荐，毕竟要客户端订阅所有消息，然后自己过滤。

我觉得方案 3 最好。