博客
萬(wàn)物互聯(lián)-物聯(lián)網(wǎng)之MQTT
||
MQTT是物聯(lián)網(wǎng)系統中使用最廣泛的通訊協(xié)議， 已被所有的物聯(lián)云所支持， 鈦極OS(TiJOS) 提供了MQTT相關(guān)Java類(lèi)，可直接支持設備連接至各大物聯(lián)云平臺。
下面以百度云為例，在使用前請先在百度云下的物接入IoT Hub中進(jìn)行相關(guān)配置，具體請參考
https://cloud.baidu.com/product/iot.html
網(wǎng)絡(luò )配置在進(jìn)行網(wǎng)絡(luò )應用開(kāi)發(fā)之前，請先通過(guò)Ti-Device Manager對TiKit 進(jìn)行網(wǎng)絡(luò )設置
在百度云Iot Hub進(jìn)行設置后獲得如下類(lèi)似信息:
| |||||||||||||||||
|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
以上配置為例程中所用的配置， 可根據實(shí)際應用進(jìn)行對應修改。
新建 TiJOS Application 應用工程在Ti-Dev Studio中新建MQTTClientDemo工程及相應的類(lèi)
啟動(dòng)網(wǎng)絡(luò )連接在應用中使用網(wǎng)絡(luò )之前， 首先需要啟動(dòng)網(wǎng)絡(luò )連接
//啟動(dòng)WLAN及DNS
TiWLAN.getInstance().startup(10);
TiDNS.getInstance().startup();
}
catch(IOException ex)
{
ex.printStackTrace();
return ;
}
final String broker = "tcp://tijos.mqtt.iot.gz.baidubce.com:1883";
final String username = "tijos/dev1";
final String password = "tWnuCZdmdgqn6uT6oaVjE1NwC9atipvOTxBA0Xn2QFQ=";
//ClientID
final String clientId = "mqtt_test_java_tijos";
//MQTT連接設置
MqttConnectOptions connOpts = new MqttConnectOptions();
connOpts.setUserName(username);
connOpts.setPassword(password);
//允許自動(dòng)重新連接
connOpts.setAutomaticReconnect(true);
MQTT通過(guò)事件回調的方式提供服務(wù)，需要創(chuàng )建一個(gè)MqttClientListner的實(shí)現類(lèi)用于接收事件回調
設置回調參數
//連接MQTT服務(wù)器
mqttClient.connect(connOpts, mqttClient);
訂閱指定主題，當收到訂閱主題的數據發(fā)布時(shí)， MqttClientListener的messageArrived事件將被調用
int qos = 1;
String topic = "topic2";
int msgId = mqttClient.subscribe(topic, qos);
publish用于將數據發(fā)布到指定主題
msgId = mqttClient.publish(topic, content.getBytes(), qos, false);
應用結束前或不再使用MQTT時(shí)，請關(guān)閉MQTT 連接
結果輸出可在Ti-Device Manager中將日志配置為顯示全部以查看輸出結果，編譯下載后在TiKit上運行如下圖所示：
相關(guān)源碼請參考MqttClientDemo.java
結論鈦極OS(TiJOS) MQTT編程與目前廣泛流行開(kāi)源Paho MQTT編程方式相似，可以方便將現有的MQTT 應用移植到鈦極OS(TiJOS)中運行， 與各大物聯(lián)云集成非常方便。
