@[toc]

主题（消息路由），子主题，分组订阅(共享订阅)

（1） 常见的主题形式以及定义

mqtt 常见的topic 形式举例

chat/room/1

sensor/10/temperature

sensor/+/temperature

$SYS/broker/metrics/packets/received

$SYS/broker/metrics/#

$queue/t/1

$share/abc/t/1

定义形式： 可以理解问文件式的分层结构： chat/root/1，主题是以 ”/“ 分割的

（2）子主题（解释下 ”+“ ， ”#“ 通配符的使用）

通配符 ”+“ 的使用

'+': 表示通配一个层级，例如a/+，匹配a/x, a/y
    
'#': 表示通配多个层级，例如a/#，匹配a/x, a/b/c/d

'+' 表示 一个的占位 ， client 订阅 a/+ 相当有订阅月 a/ ... 等主题, 可以如：

sensor/+/temperature 形式来订阅 sensor/未知主题/temperature 下的消息

通配符 ”#“ 的使用

'#' 表示 多个占位 ，client 订阅 a/# 相当于a 文件夹的子文件夹，以及子文件夹的子文件夹都会被订阅

（3） 分组订阅 (共享订阅)

定义：适用于消息让一个集群中只有一台机器消费的场景歌（基于mqtt 服务 EMQ 的，其他的中间件原理查不多）

示例	前缀	真实主题名
$queue/t/1	$queue/	t/1
$share/abc/t/1	$share/abc	t/1

群组订阅

以 $share/<group-name> 为前缀的共享订阅是带群组的共享订阅

group-name 可以为任意字符串，属于同一个群组内部的订阅者将以负载均衡接收消息，但 EMQ X 会向不同群组广播消息。

例如，假设订阅者 s1，s2，s3 属于群组 g1，订阅者 s4，s5 属于群组 g2。那么当 EMQ X 向这个主题发布消息 msg1 的时候：

EMQ X 会向两个群组 g1 和 g2 同时发送 msg1

s1，s2，s3 中只有一个会收到 msg1

s4，s5 中只有一个会收到 msg1

                                       [s1]
           msg1                      /
[emqx]  ------>  "$share/g1/topic"    - [s2] got msg1
         |                           \
         |                             [s3]
         | msg1
          ---->  "$share/g2/topic"   --  [s4]
                                     \
                                      [s5] got msg1

不带群组订阅

以 share 订阅的一种特例，相当与所有订阅者都在一个订阅组里面

                                       [s1] got msg1
        msg1,msg2,msg3               /
[emqx]  --------------->  "$queue/topic" - [s2] got msg2
                                     \
                                       [s3] got msg3

如图相当于消息只会被 一个机器节点 s1 | s2 | s3 消费而不会每个机器都给消息消费一次

EMQ 负载均衡配置与派发Ack 配置

# etc/emqx.conf

# 均衡策略
broker.shared_subscription_strategy = random

# 适用于 QoS1 QoS2 消息，启用时在其中一个组离线时，将派发给另一个组
broker.shared_dispatch_ack_enabled = false

更多EMQ 使用参照 EMQ官方文档

更多的mqtt 问题，欢迎查看专题下的其他文章查看 ，也欢迎留言，也可以加我微信 Yangting199306 备注 简书 一起讨论技术，也可以一起写文章

一起学Java ，跟强哥得永生,点赞关注 ！！！