概述
消息中间件（Message Middleware）是物联网平台的数据中枢，负责设备上报数据的接收、存储、分发。在车联网、工业互联网、能源监控等高频数据场景中，海量设备每秒产生数十万甚至百万条消息，消息中间件提供高吞吐、低延迟、持久化能力，支撑实时分析、离线存储、规则引擎、告警服务等多类消费者。与点对点RPC不同，消息中间件采用发布-订阅模式，生产者与消费者解耦，新增消费者无需改动生产者，系统扩展性更强。
物联网消息中间件通常分为两层：①设备接入层：MQTT Broker（如EMQX、Mosquitto）负责设备连接与消息收发，采用Topic机制；②数据流层：Kafka、RocketMQ等负责消息持久化、多消费者分发、回溯。两者通过桥接或规则引擎连接，形成"设备→MQTT→Kafka→多消费者"的管道。
核心功能
发布订阅与Topic
Topic机制：设备发布到iot/device/{deviceId}/data，规则引擎、数据服务订阅iot/device/+/data。支持通配符（+、#）。灵活的路由满足不同消费者的订阅需求。MQTT、Kafka均采用类似模型。
消息持久化与回溯
消息落盘，保留期可配置。支持按offset/时间回溯消费，便于新消费者追历史、故障重放、审计分析。物联网数据具有时效性与可回溯性双重需求。
水平扩展与多协议
分区、副本、消费组机制支持水平扩展。MQTT、AMQP、Kafka Protocol等协议适配，满足设备、应用、系统间不同通信需求。物联网场景常用EMQX（设备接入）+Kafka（数据流）组合。
典型产品与选型
MQTT Broker：EMQX、Mosquitto、HiveMQ。负责设备接入，轻量、支持QoS。
大数据流：Kafka、RocketMQ、Pulsar。高吞吐、持久化、多消费者。
企业消息：RabbitMQ。功能丰富、路由灵活，适合复杂业务逻辑。
物联网场景推荐EMQX+Kafka：EMQX接收设备消息，规则引擎桥接至Kafka，下游数据服务、实时分析、告警等消费Kafka。详见分布式消息队列、消息队列技术。