物联网：七天构建一个闭环的物联网DEMO

我计划用七天的时间， 基于开源物联网平台， 打造一款物联网案例的闭环。
为了增加感观体验，欢迎大家与我保持亲密的沟通。 我们来看一段代码：

1. @Slf4j
2. @Component
3. public class MqttSendManager {
5.     @Resource
6.     private MqttSendHandler mqttSendHandler;
8.     public void sendToMqtt(String topic, String data) {
9.         mqttSendHandler.sendToMqtt(topic, data);
10.     }
12.     public void sendToMqtt(String topic, Integer qos, String data) {
13.         log.debug("下发网关的qos： {}", qos);
14.         log.info("下发网关的消息： {}", "topic: " + topic  + "; "+ data);
15.         mqttSendHandler.sendToMqtt(topic, qos, data);
16.     }
17. }

复制代码

以上消息发送管理类可以实现向 mqtt 发送消息， 主要是借用了 MqttSendHandler 的本领，MqttSendHandler 是一个接口， 托管给了 spring 容器实例化，我们看看它的代码：

1. @MessagingGateway(defaultRequestChannel = "mqttOutputChannel")
2. public interface MqttSendHandler {
4.     /**
5.      * 使用 自定义 Topic & Default Qos 发送数据
6.      *
7.      * @param topic 自定义 Topic
8.      * @param data  string
9.      */
10.     void sendToMqtt(@Header(MqttHeaders.TOPIC) String topic, String data);
12.     /**
13.      * 使用 自定义 Topic & 自定义 Qos 发送数据
14.      *
15.      * @param topic 自定义 Topic
16.      * @param qos   自定义 Qos
17.      * @param data  string
18.      */
19.     void sendToMqtt(@Header(MqttHeaders.TOPIC) String topic, @Header(MqttHeaders.QOS) Integer qos, String data);
20. }

复制代码

这样两个类就封装了与 mqtt 的消息发送接口。
欢迎三连，或者有必要进一步交流的欢迎留言，评论区见。


免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。