共享订阅

共享订阅是在多个订阅者之间实现负载均衡的订阅方式：

  1.                                                    [subscriber1] got msg1
  2.              msg1, msg2, msg3                    /
  3. [publisher]  ---------------->  "$share/g/topic"  -- [subscriber2] got msg2
  4.                                                  \
  5.                                                    [subscriber3] got msg3

上图中，共享 3 个 subscriber 用共享订阅的方式订阅了同一个主题 $share/g/topic，其中topic 是它们订阅的真实主题名，而 $share/g/ 是共享订阅前缀。EMQ X 支持两种格式的共享订阅前缀：

示例前缀真实主题名
$queue/t/1$queue/t/1
$share/abc/t/1$share/abct/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

  1.                                        [s1]
  2.            msg1                      /
  3. [emqx]  ------>  "$share/g1/topic"    - [s2] got msg1
  4.          |                           \
  5.          |                             [s3]
  6.          | msg1
  7.           ---->  "$share/g2/topic"   --  [s4]
  8.                                      \
  9.                                       [s5] got msg1

不带群组的共享订阅

以 $queue/ 为前缀的共享订阅是不带群组的共享订阅。它是 $share 订阅的一种特例，相当与所有订阅者都在一个订阅组里面：

  1.                                        [s1] got msg1
  2.         msg1,msg2,msg3               /
  3. [emqx]  --------------->  "$queue/topic" - [s2] got msg2
  4.                                      \
  5.                                        [s3] got msg3

均衡策略与派发 Ack 配置

EMQ X 的共享订阅支持均衡策略与派发 Ack 配置：

  1. # etc/emqx.conf
  3. # 均衡策略
  4. broker.shared_subscription_strategy = random
  6. # 适用于 QoS1 QoS2 消息，启用时在其中一个组离线时，将派发给另一个组
  7. broker.shared_dispatch_ack_enabled = false
均衡策略描述
random在所有订阅者中随机选择
round_robin按照订阅顺序
sticky一直发往上次选取的订阅者
hash按照发布者 ClientID 的哈希值

无论是单客户端订阅还是共享订阅都要注意客户端性能与消息接收速率，否则会引发消息堆积、客户端崩溃等错误。