系统架构 概念模型 设计原则 系统分层 系统架构 概念模型 EMQ X 消息服务器概念上更像一台网络路由器(Router)或交换机(Switch)，而不是传统的企业级消息服务器(MQ)。相比网络路由器按 IP 地址或 MPLS 标签路由报文，EMQ X 按主题树(Topic Trie)发布订阅模式在集群节点间路由 MQTT 消息: ...

数据存储设计 一对一消息存储 一对多消息存储 客户端在线状态存储 客户端代理订阅 存储插件列表 数据存储设计 一对一消息存储 Publish 端发布一条消息； Backend 将消息记录数据库中； Subscribe 端订阅主题； Backend 从数据库中获取该主题的消息； 发送消息给 Subscribe 端； Subscrib...

MQTT Erlang 客户端库 emqtt 使用示例 emqtt MQTT 5.0 支持 MQTT Erlang 客户端库 emqtt 是开源 MQTT Broker EMQ X 官方提供的客户端库，适用于 Erlang 语言。 Erlang 生态有多个 MQTT Broker 实现，如通过插件支持 MQTT 的 RabbitMQ ，Ver...

日志与追踪 控制日志输出 日志级别 日志文件和日志滚动 针对日志级别输出日志文件 日志格式 日志消息举例 1： 日志消息举例 2： 日志级别和 log handlers 运行时修改日志级别 修改全局日志级别： 修改主日志级别： 修改某个 log handler 的日志级别： 日志追踪 日志追踪的原理 日志与追踪 ...

分布式集群 Erlang/OTP 分布式编程 节点(Node) EMQ X 分布集群设计 主题树(Topic Trie)与路由表(Route Table) 订阅(Subscription)与消息派发 节点发现与自动集群 手动(manual) 方式管理集群介绍 配置 emqx@s1.emqx.io 节点 配置 emqx@s2.emqx.io 节点 ...

emqx-sn mqtt.sn.port 说明 mqtt.sn.advertise_duration 说明 mqtt.sn.gateway_id 说明 mqtt.sn.enable_stats 说明 mqtt.sn.enable_qos3 说明 mqtt.sn.idle_timeout 说明 mqtt.sn.predefined.t...

RPC 桥接 配置 RPC 桥接的 Broker 地址 配置 MQTT 桥接转发和订阅主题 MQTT 桥接转发和订阅主题说明 桥接 CLI 命令 RPC 桥接 EMQ X 桥接转发 MQTT 消息到远程 EMQ X: rpc bridge 桥接插件配置文件: etc/plugins/emqx_bridge_mqtt.conf 配置...

emqx-sn mqtt.sn.port 说明 mqtt.sn.advertise_duration 说明 mqtt.sn.gateway_id 说明 mqtt.sn.enable_stats 说明 mqtt.sn.enable_qos3 说明 mqtt.sn.idle_timeout 说明 mqtt.sn.predefined.t...

RPC 桥接 配置 RPC 桥接的 Broker 地址 配置 MQTT 桥接转发和订阅主题 MQTT 桥接转发和订阅主题说明 桥接 CLI 命令 RPC 桥接 EMQ X 桥接转发 MQTT 消息到远程 EMQ X: rpc bridge 桥接插件配置文件: etc/plugins/emqx_bridge_mqtt.conf 配置...

RPC 桥接 配置 RPC 桥接的 Broker 地址 配置 MQTT 桥接转发和订阅主题 MQTT 桥接转发和订阅主题说明 桥接 CLI 命令 RPC 桥接 EMQ X 桥接转发 MQTT 消息到远程 EMQ X: rpc bridge 桥接插件配置文件: etc/plugins/emqx_bridge_mqtt.conf 配置...