概述
EMQX是由EMQ公司开发的云原生MQTT消息服务器,采用Erlang/OTP构建,以高并发、低延迟、高可用著称。EMQX支持百万级单节点并发连接,集群模式下可线性扩展至千万级,是物联网设备接入的首选开源MQTT Broker之一。除MQTT外,EMQX还支持MQTT-SN、CoAP、LwM2M、WebSocket等协议,内置规则引擎可将消息桥接到Kafka、MySQL、HTTP等后端,实现设备数据与业务系统的无缝对接。适用于车联网、工业互联网、能源监控、智慧城市等大规模物联网场景。提供开源版(Apache 2.0)与企业版(含运维工具、技术支持)。
EMQX与Eclipse Mosquitto的定位不同:Mosquitto轻量、适合小规模;EMQX面向大规模、企业级场景,支持集群、规则引擎、多协议。达希物联在物联网平台实践中,EMQX常作为设备接入层核心,与Kafka、时序数据库、ThingsBoard等配合,构建完整的物联网数据管道。
核心特性
高并发与集群
单节点支持百万级连接,得益于Erlang的轻量级进程与Actor模型。集群采用RLOG复制,支持水平扩展。设备连接可跨节点分布,单节点故障时会话迁移,业务无感知。
规则引擎
基于SQL的规则配置,支持消息过滤、转换、转发。可将指定Topic的消息桥接到Kafka、HTTP、数据库等。支持数据脱敏、格式转换。无需编码即可实现设备数据与下游系统的对接。
多协议与认证
MQTT 3.1.1/5.0、MQTT-SN、CoAP、LwM2M、WebSocket。内置认证(内置数据库、MySQL、Redis、HTTP、LDAP、JWT)、ACL权限控制。支持与外部认证系统集成。
云原生
支持Kubernetes部署、Helm Chart。支持水平扩缩容、健康检查。适合云上物联网平台的建设。
物联网典型应用
车联网:T-Box、车载终端通过MQTT连接EMQX,数据经规则引擎转发至Kafka或车联网平台。
工业采集:边缘网关、PLC、传感器通过MQTT上报,EMQX集群支撑高并发接入。
能源监控:电表、水表、光伏逆变器数据汇聚,规则引擎写入时序库或业务系统。
智慧城市:路灯、停车、环境监测等设备统一接入,支撑城市物联网平台。
生态与集成
与Kafka、RabbitMQ、MySQL、InfluxDB、TimescaleDB、ThingsBoard等有官方或社区桥接方案。支持Dashboard管理、监控指标导出(Prometheus)。企业版提供更丰富的运维与安全能力。