x286212455的個人空間 http://www.qingdxww.cn/space-uid-142968.html [收藏] [復制] [RSS]

博客

萬物互聯-物聯網之MQTT

已有 1431 次閱讀2018-5-17 14:45 |個人分類:物聯網| 物聯網, MQTT

MQTT是物聯網系統中使用最廣泛的通訊協議，已被所有的物聯云所支持，鈦極OS(TiJOS) 提供了MQTT相關Java類，可直接支持設備連接至各大物聯云平臺。

下面以百度云為例，在使用前請先在百度云下的物接入IoT Hub中進行相關配置，具體請參考

https://cloud.baidu.com/product/iot.html

網絡配置

在進行網絡應用開發之前，請先通過Ti-Device Manager對TiKit 進行網絡設置

network_settings

百度云Iot Hub設置

在百度云Iot Hub進行設置后獲得如下類似信息:

參數	值	說明
MQTT Server URI	tcp://tijos.mqtt.iot.gz.baidubce.com:1883	MQTT 服務器地址及端口
User Name	tijos/dev1	設備用戶名
Password	tWnuCZdmdgqn6uT6oaVjE1NwC9atipvOTxBA0Xn2QFQ=	用戶密碼
Topic	topic2	用于發布和訂閱的主題名，需要同時具有發布和訂閱權限

以上配置為例程中所用的配置，可根據實際應用進行對應修改。

新建 TiJOS Application 應用工程

在Ti-Dev Studio中新建MQTTClientDemo工程及相應的類

啟動網絡連接

在應用中使用網絡之前，首先需要啟動網絡連接

try{
//啟動WLAN及DNS
TiWLAN.getInstance().startup(10);
TiDNS.getInstance().startup();
}
catch(IOException ex)
{
ex.printStackTrace();
return ;
}

MQTT server連接參數設置

根據以上參數設置MQTT server的連接參數

//MQTT Server 地址,用戶名, 密碼
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);
//允許自動重新連接
connOpts.setAutomaticReconnect(true);

設置MQTT事件回調并連接MQTT服務器

MQTT通過事件回調的方式提供服務，需要創建一個MqttClientListner的實現類用于接收事件回調

class MqttEventLister implements MqttClientListener

設置回調參數

mqttClient.SetMqttClientListener(new MqttEventLister());
//連接MQTT服務器
mqttClient.connect(connOpts, mqttClient);

訂閱主題

訂閱指定主題，當收到訂閱主題的數據發布時， MqttClientListener的messageArrived事件將被調用

//訂閱topic
int qos = 1;
String topic = "topic2";
int msgId = mqttClient.subscribe(topic, qos);

發布數據到指定主題

publish用于將數據發布到指定主題

String content = "new data";
msgId = mqttClient.publish(topic, content.getBytes(), qos, false);

關閉并釋放資源