package?example;

import?java.util.concurrent.ScheduledExecutorService;??
import?org.eclipse.paho.client.mqttv3.MqttClient;??
import?org.eclipse.paho.client.mqttv3.MqttConnectOptions;??
import?org.eclipse.paho.client.mqttv3.MqttException;??
import?org.eclipse.paho.client.mqttv3.MqttTopic;??
import?org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;??
??
public?class?ClientMQTT?{??
??
????public?static?final?String?HOST?=?“tcp://localhost:1883“;??
????public?static?final?String?TOPIC?=?“topic11“;??
????private?static?final?String?clientid?=?“client11“;??
????private?MqttClient?client;??
????private?MqttConnectOptions?options;??
????private?String?userName?=?“admin“;??
????private?String?passWord?=?“password“;??
??
????private?ScheduledExecutorService?scheduler;??
??
????private?void?start（）?{??
????????try?{??
????????????//?host為主機名，clientid即連接MQTT的客戶端ID，一般以唯一標識符表示，MemoryPersistence設(shè)置clientid的保存形式，默認為以內(nèi)存保存??
????????????client?=?new?MqttClient（HOST?clientid?new?MemoryPersistence（））;??
????????????//?MQTT的連接設(shè)置??
????????????options?=?new?MqttConnectOptions（）;??
????????????//?設(shè)置是否清空session這里如果設(shè)置為false表示服務(wù)器會保留客戶端的連接記錄，這里設(shè)置為true表示每次連接到服務(wù)器都以新的身份連接??
????????????options.setCleanSession（true）;??
????????????//?設(shè)置連接的用戶名??
????????????options.setUserName（userName）;??
????????????//?設(shè)置連接的密碼??
????????????options.setPassword（passWord.toCharArray（））;??
????????????//?設(shè)置超時時間?單位為秒??
????????????options.setConnectionTimeout（10）;??
????????????//?設(shè)置會話心跳時間?單位為秒?服務(wù)器會每隔1.5*20秒的時間向客戶端發(fā)送個消息判斷客戶端是否在線，但這個方法并沒有重連的機制??
????????????options.setKeepAliveInterval（20）;??
????????????//?設(shè)置回調(diào)??
????????????client.setCallback（new?PushCallback（））;??
????????????MqttTopic?topic?=?client.getTopic（TOPIC）;??
????????????//setWill方法，如果項目中需要知道客戶端是否掉線可以調(diào)用該方法。設(shè)置最終端口的通知消息??
????????????options.setWill（topic?“close“.getBytes（）?2?true）;??
??
????????????client.connect（options）;??
????????????//訂閱消息??
????????????int[]?Qos??=?{1};??
????????????String[]?topic1?=?{TOPIC};??
????????????client.subscribe（topic1?Qos）;??
??
????????}?catch?（Exception?e）?{??
????????????e.printStackTrace（）;??
????????}??
????}??
??
????public?static?void?main（String[]?args）?throws?MqttException?{??
????????ClientMQTT?client?=?new?ClientMQTT（）;??
????????client.start（）;??
????}??
}??

?屬性????????????大小?????日期????時間???名稱
-----------?---------??----------?-----??----

?????文件???????2772??2017-05-22?16:31??MQTT相關(guān)文檔\ClientMQTT.java

?????文件????1014498??2017-05-21?21:22??MQTT相關(guān)文檔\LoRaWAN?Network?Server?V1.0安裝手冊.pdf

?????文件?????126960??2017-05-16?08:58??MQTT相關(guān)文檔\mqtt-client-1.14.jar

?????文件?????????57??2017-05-23?08:45??MQTT相關(guān)文檔\mqtt服務(wù)器配置.txt

?????文件???????1807??2017-05-22?16:33??MQTT相關(guān)文檔\PushCallback.java

?????文件???????3368??2017-05-22?21:42??MQTT相關(guān)文檔\ServerMQTT.java

?????目錄??????????0??2017-05-23?08:43??MQTT相關(guān)文檔

-----------?---------??----------?-----??----

??????????????1149462????????????????????7