MQTT協議 Android 客戶端使用筆記

2021-10-14 00:24:14 字數 4032 閱讀 2263

簡單使用（客戶端）

注意點(報錯)

完整的**（android 客戶端 簡單的）

選則乙個

0.變數

mqttclient mqttclient;


edittext edittext;


static string host=


"tcp:"


;//服務端位址，埠


static string client_id=


"androidd"


,tag=


"tag"


;//client_id 服務端標識 tag 列印日誌資訊


mqttconnectoptions mqttconnectoptions;
1.初始化

private


void


init()


catch


(mqttexception e)


}
2.連線服務端

mqttclient.


connect


(mqttconnectoptions)


;
3.訂閱和取消訂閱 edittext.gettext().tostring().trim() 獲取要訂閱的 標題（可以看成乙個訂閱的id標識）

public


void


oncick


(view view)


catch


(mqttexception e)


break


;case r.id.button3:


//取消訂閱


trycatch


(mqttexception e)


break


;case r.id.button4:


//連線


trycatch


(mqttexception e)


break;}


}
4.獲取訂閱內容

private


voiddy(


)@override


public


void


messagearrived


(string s, mqttmessage mqttmessage)


throws exception 


@override


public


void


deliverycomplete


(imqttdeliverytoken imqttdeliverytoken)})


;while


(true


)catch


(interruptedexception e)}}


}).start()


;}
1.要重複接收訂閱資料，要阻塞方法。（解決只能接收一次訂閱資訊的方法）

private


voiddy(


)@override


public


void


messagearrived


(string s, mqttmessage mqttmessage)


throws exception 


@override


public


void


deliverycomplete


(imqttdeliverytoken imqttdeliverytoken)})


;while


(true


)catch


(interruptedexception e)}}


}).start()


;}
2.接收的資料是byte型別

@override


public


void


messagearrived


(string s, mqttmessage mqttmessage)


throws exception
3.報錯url位址格式不對

//正確的格式 tcp://***x:***


static string host=


"tcp:"


;
package com.example.lzz.mqttclient;


import android.media.timedtext;


import android.os.bundle;


import android.util.log;


import android.view.view;


import android.widget.edittext;


import android.widget.textview;


import org.eclipse.paho.client.mqttv3.imqttdeliverytoken;


import org.eclipse.paho.client.mqttv3.mqttcallback;


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.mqttmessage;


import org.eclipse.paho.client.mqttv3.persist.memorypersistence;


public


class


mainactivity


extends


private


void


init()


catch


(mqttexception e)


}private


voiddy(


)@override


public


void


messagearrived


(string s, mqttmessage mqttmessage)


throws exception 


@override


public


void


deliverycomplete


(imqttdeliverytoken imqttdeliverytoken)})


;while


(true


)catch


(interruptedexception e)}}


}).start()


;}public


void


oncick


(view view)


catch


(mqttexception e)


break


;case r.id.button3:


trycatch


(mqttexception e)


break


;case r.id.button4:


trycatch


(mqttexception e)


break;}


}}

android訊息推送 mqtt協議

對與訊息推送是什麼個概念，在此就不贅述啦。google自帶的c2md服務，可以幫助我們實現該功能，可以該伺服器在國外，所以鑑於網速等各種條件限制，我們也沒法實現。為解決該問題，在讀了大量的部落格等質料之後，終於見到啦陽光。第三個是由ibm提供的mqtt協議的實現，就相當於乙個 開啟1883埠，在se...

MQTT協議 MQTT協議簡介

mqtt messagequeuing telemetry transport，訊息佇列遙測傳輸 是ibm開發的乙個即時通訊協議。mqtt是面向m2m和物聯網的連線協議，採用輕量級發布和訂閱訊息傳輸機制。它的設計思想是輕巧 開放 簡單 規範，因此易於實現。這些特點使得它對很多場景來說都是很好的選擇，...

MQTT協議 MQTT協議解析

協議就是通訊雙方的乙個約定，即，表示第1位傳輸的什麼 第2位傳輸的什麼 在mqtt協議中，乙個mqtt資料報由 固定頭 fixed header 可變頭 variable header 訊息體 payload 三部分構成。mqtt 資料報結構 固定頭存在於所有mqtt資料報中，其結構如下 bit76...