# mqtt **Repository Path**: y2000_1/mqtt ## Basic Information - **Project Name**: mqtt - **Description**: No description available - **Primary Language**: Unknown - **License**: Not specified - **Default Branch**: master - **Homepage**: None - **GVP Project**: No ## Statistics - **Stars**: 0 - **Forks**: 0 - **Created**: 2025-07-14 - **Last Updated**: 2026-01-28 ## Categories & Tags **Categories**: Uncategorized **Tags**: None ## README # 发布者 消息通过消息网关发送出去,由 MessageChannel 的实例 DirectChannel 处理发送的细节。 DirectChannel 收到消息后,内部通过 MessageHandler 的实例 MqttPahoMessageHandler 发送到指定的 Topic。 # 订阅者 通过注入 MessageProducerSupport 的实例 MqttPahoMessageDrivenChannelAdapter,实现订阅 Topic 和绑定消息消费的 MessageChannel。 同样由 MessageChannel 的实例 DirectChannel 处理消费细节。Channel 收到消息后会发送给自定义的 MqttInboundMessageHandler 实例进行消费。