分答网站,wordpress 4.8.1下载,东莞市建网站制作方案,莆田网站建设创意我计划用七天的时间#xff0c; 基于开源物联网平台#xff0c; 打造一款物联网案例的闭环。
为了增加感观体验#xff0c;欢迎大家与我保持亲密的沟通。 我们来看一段代码#xff1a;
Slf4j
Component
public class MqttSendManager {Resourceprivate MqttSendHandler m…我计划用七天的时间 基于开源物联网平台 打造一款物联网案例的闭环。
为了增加感观体验欢迎大家与我保持亲密的沟通。 我们来看一段代码
Slf4j
Component
public class MqttSendManager {Resourceprivate MqttSendHandler mqttSendHandler;public void sendToMqtt(String topic, String data) {mqttSendHandler.sendToMqtt(topic, data);}public void sendToMqtt(String topic, Integer qos, String data) {log.debug(下发网关的qos {}, qos);log.info(下发网关的消息 {}, topic: topic ; data);mqttSendHandler.sendToMqtt(topic, qos, data);}
}以上消息发送管理类可以实现向 mqtt 发送消息 主要是借用了 MqttSendHandler 的能力MqttSendHandler 是一个接口 托管给了 spring 容器实例化我们看看它的代码
MessagingGateway(defaultRequestChannel mqttOutputChannel)
public interface MqttSendHandler {/*** 使用 自定义 Topic Default Qos 发送数据** param topic 自定义 Topic* param data string*/void sendToMqtt(Header(MqttHeaders.TOPIC) String topic, String data);/*** 使用 自定义 Topic 自定义 Qos 发送数据** param topic 自定义 Topic* param qos 自定义 Qos* param data string*/void sendToMqtt(Header(MqttHeaders.TOPIC) String topic, Header(MqttHeaders.QOS) Integer qos, String data);
}
这样两个类就封装了与 mqtt 的消息发送接口。
欢迎三连或者有需要进一步交流的欢迎留言评论区见。
