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 内置的 Sink 和 Source 来实现将 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