mqtt

2019-11-06 09:59:02

字體：大中小

來源：轉載

供稿：網友

進入公司，用的是ibm的mqtt實現了推送，用起來效果還可以，那么我們就看一下Android如何鏈接mqtt服務器。

標題

PRivate void init() { try { //host為主機名，test為clientid即連接MQTT的客戶端ID，一般以客戶端唯一標識符表示，MemoryPersistence設置clientid的保存形式，默認為以內存保存 client = new MqttClient(host, "test", new MemoryPersistence()); //MQTT的連接設置 options = new MqttConnectOptions(); //設置是否清空session,這里如果設置為false表示服務器會保留客戶端的連接記錄，這里設置為true表示每次連接到服務器都以新的身份連接 options.setCleanSession(true); //設置連接的用戶名 options.setUserName(userName); //設置連接的密碼 options.setPassWord(passWord.toCharArray()); // 設置超時時間單位為秒 options.setConnectionTimeout(10); // 設置會話心跳時間單位為秒服務器會每隔1.5*20秒的時間向客戶端發送個消息判斷客戶端是否在線，但這個方法并沒有重連的機制 options.setKeepAliveInterval(20); //設置回調 client.setCallback(new MqttCallback() { @Override public void connectionLost(Throwable cause) { //連接丟失后，一般在這里面進行重連 System.out.println("connectionLost----------"); } @Override public void deliveryComplete(IMqttDeliveryToken token) { //publish后會執行到這里 System.out.println("deliveryComplete---------" + token.isComplete()); } @Override public void messageArrived(String topicName, MqttMessage message) throws Exception { //subscribe后得到的消息會執行到這里面 System.out.println("messageArrived----------"); Message msg = new Message(); msg.what = 1; msg.obj = topicName + "---" + message.toString(); handler.sendMessage(msg); } }); } catch (Exception e) { e.printStackTrace(); } }

這個是我在網上copy的，傳送門

上一篇：swift刪除navigationBar底部一條黑線

下一篇：gradle 詳解