Skip to content

EMQX 企业版概览

EMQX 企业版是一款「无限连接,任意集成,随处运行」的大规模分布式物联网接入平台,同时作为一个高性能、可扩展的 MQTT 消息服务器,它可以为物联网(IoT)应用提供可靠的实时消息传输和设备连接解决方案。通过强大的内置规则引擎和数据集成功能,EMQX 企业版可以对海量 IoT 数据进行实时数据处理、数据转换和路由,还可以将 IoT 数据无缝集成到各种后端数据库和分析工具中,助力企业快速构建关键业务的 IoT 平台与应用。

EMQX-enterprise

产品优势

  • 海量连接:单节点支持 500 万 MQTT 设备连接,集群可水平扩展至支持 1 亿并发的 MQTT 连接。

  • 高可靠:弹性伸缩,无单点故障。内置 RocksDB 可靠地持久化 MQTT 消息,确保无数据损失。

  • 数据安全:端到端数据加密(支持国密),细粒度访问控制,保障数据安全,满足企业合规需求。

  • 多协议:支持 MQTT、HTTP、QUIC、WebSocket、LwM2M/CoAP 或专有协议连接任何设备。

  • 高性能:单节点支持每秒实时接收、处理与分发数百万条的 MQTT 消息。毫秒级消息交付时延。

  • 易运维:图形化配置、操作与管理,实时监测运行状态。支持 MQTT 跟踪进行端到端问题分析。

核心组件

EMQX 企业版由多个组件组成,这些组件共同构建了一个功能强大、可扩展的 MQTT 消息服务器和物联网平台。以下是 EMQX 企业版核心组成部分:

设备连接

EMQX 企业版 100% 兼容 MQTT 5.0 和 3.x 规范,出色的扩展性使其能够轻松处理海量的 MQTT 设备客户端连接。与此同时它还提供了包括 HTTP、QUIC 以及 LwM2M/CoAP 在内的其他开放标准协议接入,从而实现更多物联网设备与场景接入。EMQX 企业版还扩展实现了文件传输、延迟发布等功能,丰富使用场景。

MQTT over QUIC

EMQX 企业版开创性地引入了 MQTT over QUIC 协议,允许物联网客户端通过 QUIC 与 EMQX 建立连接并进行通信。采用 QUIC 的设备可以提高连接与消息吞吐性能并减少消息延迟。特别是对于弱网、链路频繁变化、不稳定网络环境很常见的车联网场景,MQTT over QUIC 能够满足消息传输的实时性和高效性的要求。

多协议网关

多协议网关使 EMQX 企业版能够支持除使用 MQTT 协议以外的不同通信协议的设备连接到 EMQX 服务器。多协议网关会监听设备的连接请求并识别设备使用的通信协议,随后根据相应的协议规范解析设备发送的消息、命令和数据,并将其转换为 MQTT 消息格式进行消息处理。

消息路由

EMQX 企业版通过支持发布/订阅模式提供了高度可靠的消息传输机制,确保消息能够可靠地传递到目标设备或应用程序。借助 QoS 机制和保留会话能力,即便在不稳定的网络环境下,也能确保数据快速和可靠地传递,从而保障业务的连续性和稳定性。

分布式集群

EMQX 企业版提供原生的集群能力,能够实现无缝弹性伸缩,避免单点故障。通过极致的优化,单节点每秒能够低时延地实时接收、处理与分发数百万条 MQTT 消息,并通过集群水平扩展支持 1 亿并发的 MQTT 连接,这对于大规模 IoT 部署至关重要,如车联网、工业自动化和智能家居等领域。

访问控制和数据安全

通过 TLS/SSL 加密认证授权机制,EMQX 企业版能够保障设备数据传输的机密性和完整性。

EMQX 企业版内置了多重客户端认证机制,包括用户名密码、JWT、增强认证以及 PSK、X.509 证书,提供了基于 ACL 的发布订阅授权机制。认证与授权数据支持通过 LDAP、HTTP 服务、SQL 和 NoSQL 数据库等外部企业安全系统进行集成管理,实现灵活多样的客户端安全保护方案。

同时,EMQX 企业版还提供了审计日志、角色与权限管理以及单点登录,以满足 SOC 2 合规性要求和 GDPR 数据隐私保护。全面的安全功能,帮助企业构建符合行业安全标准的可信赖的物联网应用。

规则引擎与数据集成

EMQX 企业版包含一个强大的规则引擎,您可以根据您的需求在 EMQX 中配置规则 ,对传入的数据进行处理和路由。您还可以使用 EMQX 的数据桥接功能来实现将 EMQX 企业版与云端服务或数据库集成,以便将 IoT 数据传输到云端进行存储和分析。

即时数据处理

内置基于 SQL 的规则引擎、Schema Registry、消息编解码器和 Flow 设计器,能够轻松编排设备事件与消息处理流程,实时地提取、验证、过滤和转换物联网数据。

企业数据集成

通过开箱即用的 Webhook 与数据桥接,将物联网数据与 40 多个云服务和企业系统进行完美整合,包括 Kafka、AWS RDS、MongoDB、Oracle、SAP 以及时序数据库等。助力企业有效地管理、分析和利用来自物联网设备的数据,从而支持各种应用和业务需求。

管理与监控仪表板

EMQX 企业版提供图形化的管理系统 Dashboard,能够实时监控关键指标与运行状态,轻松管理客户端连接与功能配置。它还允许对客户端和集群异常行为进行诊断与调试,在线进行 MQTT 设备端到端的问题分析,大大缩短故障排查的时间。除此之外,还支持将可观测性指标集成到外部 Prometheus,Datadog 以及支持 OpenTelemetry 的服务中,实现更完善的运维监控能力。

典型用例

EMQX 企业版是一个全面的物联网消息平台,它在物联网接入与数据传输的不同阶段发挥着关键作用,为各类业务需求提供了多种强大功能和灵活性。

基于发布-订阅的消息传递模型,EMQX 企业版能够实现数百万主题、不同模式的灵活消息通信,满足各类场景下的实时消息传递。通过内置的规则引擎和数据桥接,EMQX 企业版允许您将消息发送到云端各类服务中,实现设备数据与企业系统之间的无缝集成,能够轻松实现数据处理、存储、分析以及业务指令下发等用例。以下是常见的用例:

双向通信

EMQX 企业版支持各类设备与应用端连接,为设备及应用程序提供双向通信。例如智能家居场景下,手机 App 能够获取各类设备传感器数据,并在需要时将控制指令下发到设备。此模式允许设备与设备、设备与应用进行灵活的一对一或一对多通信。

use_case_1

遥测数据上传

EMQX 企业版支持设备数据上云,并对来自指定主题的数据进行处理和云端存储。例如工业生产场景下,EMQX 能够实时处理来自工厂车间的各种工业设备数据,并将其存储到数据库中,以实现产品质量追溯,生产分析等业务。此模式能够通过可视化的方式进行配置,使用丰富的数据处理能力实现快速开发。

use_case_2

大文件数据上传

EMQX 企业版提供了 MQTT 协议文件传输能力,允许设备上传大文件数据并将其存储到本地磁盘或 S3 存储中。例如车联网场景下,机器学习日志文件、打包后的 CAN Bus 数据可以传输到云端存储,以驱动智能驾驶算法模型更新。此模式将结构化数据与文件类型数据结合,通过统一的数据通道,降低应用的复杂性和维护成本。

use_case_3

云端控制指令下发

EMQX 企业版允许通过 MQTT 消息、REST API 以及 Kafka 等数据桥接进行消息下发,推送数据或远程控制设备。例如金融交易场景下,云端服务可以根据用户关注列表,进行分组实时数据推送。此模式提供了主题映射、下发数据处理以及数据触达统计,能够实现灵活且可靠的数据下发。

use_case_4