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

我计划用七天的时间， 基于开源物联网平台， 打造一款物联网案例的闭环。

为了增加感观体验，欢迎大家与我保持亲密的沟通。 我们来看一段代码：

@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 的消息发送接口。

欢迎三连，或者有需要进一步交流的欢迎留言，评论区见。