## 一、概述 引入集成依賴庫，作為客戶端（發布者或訂閱者）；使用MQTT主要有兩種方式： * 使用傳統的Client客戶端，這個類似數據庫連接或redis連接，比較簡單； * 使用spring-integration的消息通道，平臺采用這個方案； >[danger] artemis和mosquitto都已經在rayframework平臺測試通過了； ## 二、接受消息（作為訂閱者） ### **基礎配置** ``` ###mqtt rayframework.enabled.mqtt=true rayframework.mqtt.server-uris=tcp://mq.rayframework.org:1883 #ssl單向免證書 rayframework.mqtt.server-uris=ssl://mq.rayframework.org:1889 rayframework.mqtt.server-username=rayframework rayframework.mqtt.server-password=ENC(906117904514216015909308307209) rayframework.mqtt.subscriber.client-id=subscriber${random.value} rayframework.mqtt.subscriber.default-topic=rayframework/subscriber/default ``` 特別注意，rayframework.mqtt.subscriber.default-topic配置的時候訂閱的主題，配置的broker會將這個主題的消息推送到業務系統中來； ### **業務配置及開發** ``` rayframework.facility.mqtt-subscribed-handler-clazz=org.ray.framework.facility.mqtt.api.sample.SampleRayMqttSubscribeMessageHandler ``` 這里配置監聽到信息后的處理實現類，可以在這里面實現你的業務，監聽到哪個主題的消息，做出什么業務動作； 舉例： ``` public class SampleRayMqttSubscribeMessageHandler implements RayMqttSubscribeMessageHandler { Logger logger = LoggerFactory.getLogger(getClass()); @Override public void receiveMessage(String topic, String message) { logger.info("接受到的主題{},消息為{}", topic, message); } } ``` ### **動態訂閱開發** 到目前為止，都只能監聽配置中，預先配置的默認主題，如果需要根據業務需要，動態訂閱主題，需要通過平臺提供的api來實現，可以動態增加或者刪除訂閱的主題； ``` @Autowired private RayMqttSubscribeTopicOperator rayMqttSubscribeTopicOperator; ``` ``` String topic = "ray/change/" + DateUtil.getDateStr("mm"); rayMqttSubscribeTopicOperator.addTopic(topic); rayMqttSubscribeTopicOperator.removeTopic(topic); ``` ## 三、發送消息（作為發布者） ### **基礎配置** ``` ###mqtt rayframework.enabled.mqtt=true rayframework.mqtt.server-uris=tcp://mq.rayframework.org:1883 #ssl單向免證書 rayframework.mqtt.server-uris=ssl://mq.rayframework.org:1889 rayframework.mqtt.server-username=rayframework rayframework.mqtt.server-password=ENC(906117904514216015909308307209) rayframework.mqtt.publisher.client-id=client${random.value} rayframework.mqtt.publisher.default-topic=rayframework/publisher/default ``` ### **代碼開發** ``` @Autowired private RayMqttPublishTopicOperator rayMqttPublishTopicOperator; ``` 發布消息到某個主題的方法： ``` rayMqttPublishTopicOperator.sendToMqttWithSpecTopic("ray/test","{ID:1,name:'測試人'}"); ```