平台能力

EMQX 功能完整参考。从设备连接到 AI 处理，探索平台提供的所有功能。

项功能: 136
个分类: 10

连接

全面的协议支持，任意规模的设备接入

MQTT 3.1.1/5.0

全球最受信赖的 MQTT 消息服务器，完整支持 MQTT 3.1.1 和 5.0 标准。以业界领先的性能、可靠性和可扩展性连接数百万设备。

MQTT over QUIC

基于 QUIC 的下一代 MQTT 传输，显著降低弱网环境下的连接延迟

MQTT over WebSocket

基于 WebSocket 的 MQTT，支持浏览器直接连接

更多功能

MQTT-SN 网关

面向资源受限设备的传感器网络协议网关

CoAP 网关

支持 UDP/DTLS 的受限应用协议网关

LwM2M 网关

用于物联网设备管理的轻量级 M2M 协议

STOMP 网关

流文本导向消息协议支持

OCPP 网关

用于电动汽车充电站的开放充电点协议

GB/T 32960 网关

中国新能源汽车远程监控数据交换协议

JT/T 808 网关

中国道路运输车辆定位协议

NATS 网关

NATS 消息系统协议网关

消息

面向实时数据流的高级 MQTT 消息功能

发布/订阅

MQTT 消息通信的基石。发布者与订阅者解耦，轻松支撑数百万设备间灵活、可扩展的实时通信。

MQTT Streams

Kafka 风格的消息流，支持持久化历史记录和回放，适用于物联网数据

消息队列

持久化消息队列，支持 TTL、容量限制和保证投递

更多功能

保留消息

服务器为每个主题保存最后一条消息

遗嘱消息

客户端异常断开时自动投递消息

主题通配符

使用 + 和 # 通配符订阅多个主题

排他订阅

确保单一订阅者的排他主题订阅

延迟发布

定时延迟消息投递

自动订阅

客户端连接时自动订阅主题

主题重写

动态消息主题重写

共享订阅

跨多个订阅者的负载均衡消息消费

文件传输

通过 MQTT 进行大文件分块传输

客户端属性

动态客户端自定义属性，灵活处理业务数据

安全

企业级安全与访问控制

用户名/密码认证

支持多种后端存储的密码认证

JWT 认证

基于 JSON Web Token 的认证

X.509 证书认证

TLS 客户端证书认证

LDAP 认证

LDAP/Active Directory 认证集成

SCRAM 认证

加盐挑战响应认证机制

Kerberos 认证

企业级 Kerberos 认证

HTTP 认证服务

通过 HTTP API 进行外部认证

数据库认证

MySQL/PostgreSQL/MongoDB/Redis 认证后端

ACL 授权

基于文件和数据库的访问控制列表

TLS/SSL 加密

端到端 TLS 加密传输

CRL/OCSP

证书吊销列表和在线证书状态

PSK 认证

预共享密钥认证

黑名单

客户端/IP/用户黑名单管理

连接抖动检测

检测连接抖动以防止资源耗尽

数据集成

规则引擎、Flow 设计器和 50 多个连接器，无缝集成数据处理流程

规则引擎

基于 SQL 的强大规则引擎，每秒处理数百万条消息。以亚毫秒级延迟完成物联网数据的实时过滤、转换、补充和路由。

Flow 设计器

可视化拖放界面，无需编写代码即可构建复杂数据管道

Schema Registry

Avro/Protobuf 模式管理与验证

消息转换

消息格式转换与编解码

Schema 验证

消息模式验证以确保数据质量

更多功能

Sparkplug B

工业物联网 Sparkplug B 标准支持

连接器

消息流 (10)

HTTP / Webhook (1)

HTTP Server

数据库 (20)

数据分析 (7)

对象存储 (4)

其他 (2)

Agentic AI

将 AI 能力直接集成到物联网数据流中

MCP over MQTT

基于 MQTT 构建的全新 AI Agent 通信协议。标准化上下文共享与工具调用，让 AI 模型与物联网设备无缝协作。

实时 AI

基于火山引擎 RTC / GPT-Realtime 的实时音视频 AI，支持语音和视频交互

更多功能

OpenAI 集成

使用 GPT 模型分析、转换和丰富数据

Anthropic 集成

使用 Claude 模型分析、转换和丰富数据

Gemini 集成

使用 Google Gemini 分析、转换和丰富数据

集群

分布式集群与高可用

集群部署

多节点高可用集群部署

集群发现

手动和自动集群，支持 DNS、etcd、K8s 发现

会话持久化

基于 RocksDB 的会话持久化

集群链接

跨地域分布式多集群链接

节点疏散

用于滚动升级的节点迁移

负载均衡

Nginx/HAProxy 负载均衡器配置

管理

全面的管理与运维工具

Dashboard

现代化 Web 管理控制台，集监控、配置、运维于一体。集群状态、客户端连接、实时指标一目了然。

EMQX Operator

用于自动化部署和运维的 Kubernetes Operator

REST API

完整的管理 REST API，便于自动化与系统集成

CLI 工具

命令行管理工具，便于脚本编写与自动化运维

更多功能

热配置

运行时热配置更新

多租户

基于命名空间的多租户隔离

速率限制

连接和消息速率限制

许可证管理

商业许可证管理

备份与恢复

数据备份和恢复

审计日志

操作审计日志

单点登录

LDAP/SAML/OIDC 单点登录

多因素认证

多因素身份认证

热升级

运行时代码热升级，业务零中断

可观测性

实时监控与诊断

指标与统计

实时性能指标和统计数据

Prometheus

Prometheus 指标导出

Datadog

Datadog APM 集成

OpenTelemetry

分布式追踪、指标和日志导出

告警

CPU/内存/规则引擎告警

日志管理

结构化日志收集和配置

主题指标

按主题的消息统计

慢订阅者

慢订阅者检测和统计

日志追踪

用于调试的动态日志追踪

系统主题

$SYS 系统主题监控

扩展

可扩展性与插件开发

钩子

消息和连接生命周期钩子

ExHook (gRPC)

多语言 gRPC 扩展钩子

插件开发

Erlang 插件开发框架

SDK

多语言客户端 SDK，助力快速开发

MQTT 客户端 SDK (5)

C SDK

C 语言 MQTT 客户端库（Paho）

Java SDK

Java MQTT 客户端库（Paho）

Python SDK

Python MQTT 客户端库（Paho）

Go SDK

Go 语言 MQTT 客户端库（Paho）

JavaScript SDK

JavaScript/Node.js MQTT 客户端库（MQTT.js）

MCP over MQTT SDK (6)

MCP Python SDK

Python MCP over MQTT 客户端库

MCP TypeScript SDK

TypeScript MCP over MQTT 客户端库

MCP Kotlin SDK

Kotlin MCP over MQTT 客户端库

MCP Erlang SDK

Erlang MCP over MQTT 客户端库

MCP C SDK

C 语言 MCP over MQTT 客户端库

MCP ESP32 SDK

ESP32 嵌入式 MCP 客户端库

即刻体验 EMQX

选择全托管云服务快速上手，或下载自托管企业版部署。

下载 EMQX 企业版