mqtt 是一个比较常用的iot 协议,5.0 支持共享订阅,共享订阅是一个特别方便的功能,可以实现业务的高可用,以及提升消息的处理
参考格式
- 共享订阅格式
$share/{Share Name}/{Topic Filter}
Share Name 是一个共享名称,可以实现业务组的能力,Topic Filter} 可以对于订阅消息的过滤处理
参考玩法
简单说明: 消息发布者通过broker 发布消息,对于消息的消费者通过订阅一个包含特定格式的topic 可以实现业务组消息处理的高可用以及负载均衡
说明
mqtt 3.1.1 支持$queue/{Topic File}
格式的共享订阅,共享订阅的消息处理是在broker 中处理的,还是比较方便的,emqx 有专门的介绍可以看看
参考资料
https://www.emqx.com/zh/blog/introduction-to-mqtt5-protocol-shared-subscription
https://www.emqx.com/zh/blog/introduction-to-mqtt-5