物联网：七天构建一个闭环的物联网DEMO
我计划用七天的时间， 基于开源物联网平台， 打造一款物联网案例的闭环。为了增加感观体验，欢迎大家与我保持亲密的沟通。 我们来看一段代码：
@Slf4j
@Component
public class MqttSendManager {
@Resource
private 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 datastring
*/
void sendToMqtt(@Header(MqttHeaders.TOPIC) String topic, String data);
/**
* 使用 自定义 Topic & 自定义 Qos 发送数据
*
* @param topic 自定义 Topic
* @param qos 自定义 Qos
* @param datastring
*/
void sendToMqtt(@Header(MqttHeaders.TOPIC) String topic, @Header(MqttHeaders.QOS) Integer qos, String data);
} 这样两个类就封装了与 mqtt 的消息发送接口。
欢迎三连，或者有必要进一步交流的欢迎留言，评论区见。
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。
页:
[1]