当前位置：首页 > news >正文

MQTT-共享订阅

news 2025/11/1 21:19:53

共享订阅

在普通的订阅中，每发布一条消息，所有匹配的订阅端都会收到该消息。当某个订阅端的消费速度无法跟上消息的生产速度时，没有办法将其中一部分消息分流到其他订阅端来消费。这就使得订阅端容易成为整个消息系统的性能瓶颈。

在这里插入图片描述

解决办法

MQTT 5.0 引入了共享订阅特性，它使得 MQTT 服务端可以在使用特定订阅的客户端之间均衡地分配消息负载。这表示，当我们有两个客户端共享一个订阅时，那么发布的消息都只投递给其中一个客户端。类似：订阅者集群，负载均衡，提高消费性能

订阅分类

启用共享订阅：为一组订阅者的原始主题添加指定前缀

前缀格式	示例	前缀	真实主题名
群组格式	$share/g/test/a	$share/g	test/a
非群组格式	$queue/test/a	$queue/	test/a

群组订阅

通过在原始主题前 添加 $share/<group-name> 前缀为分组的订阅者启用共享订阅。组名可以是任意字符串。EMQX 同时将消息转发给不同的组，属于同一组的订阅者可以使用负载均衡接收消息。

案例说明

订阅者 sub_1、sub_2 和 sub_3 是组 g1 的成员，订阅者 sub_4 和 sub_5 是组 g2 的成员，而所有订阅者都订阅了原始主题 test/1。共享订阅的主题是 $share/g1/test/1 和 $share/g2/test/1。

当 EMQX 发布消息 msg1 到原始主题 test/1 时：

EMQX 将 msg1 发送给 g1 和 g2 两个组。
sub_1、sub_2、sub_3 中的一个订阅者将接收 msg1。
sub_4 和 sub_5 中的一个订阅者将接收 msg1。

在这里插入图片描述

案例演示

创建订阅者

sub_1
- 主题 $share/g1/test/1

在这里插入图片描述

sub_2
- 主题 $share/g1/test/1

在这里插入图片描述

sub_3
- 主题 $share/g1/test/1

在这里插入图片描述

sub_4
- 主题 $share/g2/test/1

在这里插入图片描述

sub_5
- 主题 $share/g2/test/1

在这里插入图片描述

发布者发布消息

publish 发布消息
- 主题 test/1

在这里插入图片描述

订阅者接收消息

g1 组中只有 sub_2 接收到

在这里插入图片描述

g2 组中只有 sub_5 接收到

在这里插入图片描述

非群组订阅

通过在原始主题前 添加 $queue/ 前缀为非群组订阅者启用共享订阅。它是 $share 订阅的一种特例，可以理解为所有订阅者都在一个订阅组。

案例说明

订阅者 sub_queue_1、sub_queue_2 和 sub_queue_3 都订阅主题 $queue/test/q。原始主题为 test/q。发布消息 msg1、msg2、msg3到原始主题 test/q 时，sub_queue_1、sub_queue_2 和 sub_queue_3 各自收到一个消息。