1. MQTT 客户端订阅主题时,所在节点订阅成功后广播通知其他节点:某个主题(Topic)被本节点订阅。

    EMQ X 消息服务器同一集群的所有节点,都会复制一份主题(Topic) -> 节点(Node)映射的路由表,例如:

    EMQ X 消息服务器每个集群节点,都保存一份主题树(Topic Trie)和路由表。

    最终会生成如下主题树(Topic Trie)和路由表(Route Table):

    订阅(Subscription)与消息派发

    例如 client1 向主题’t/a’发布消息,消息在节点间的路由与派发流程:

    1. node1 --> node3: Route[t/a]

    image