EMQX 集群节点数据转发

EMQX 分布式集群设计

emqx 分布式集群解决的问题是将客户端连接分到不同的节点上，从而获得最大的连接数和并发量，但是也带来了新的问题：订阅者和发布者可能不在同一个节点上，发布者的消息需要进行中转才能到达订阅者。

于是 emqx 设计了一套数据路由中转机制，其中主要使用了订阅表、路由表、主题树。三者搭配实现了数据的路由。

订阅表

说明： 即 topic 和 订阅客户端 的对应关系。该订阅表记录只存在于订阅者所在的 EMQX 节点上。

目的：便于根据 topic 获取到 到订阅者，从而向订阅者发送消息。

路由表

说明：维护了节点和 topic 的对应关系。同一集群中的所有节点将都维护了主题到节点的映射表。

目的：当消息到达某个节点时，可以根据 topic 查找到订阅对应 topic 的客户端连接在那个节点上，从而将消息路由到该节点。

主题树

说明：EMQX 会维护 主题树。

目的：用于匹配多个主题。当发布者发布主题时，从主题树上获取到匹配的主题