Android連接MQTT簡單的Demo

https://www.cnblogs.com/yangfengwu/p/11839484.html

 

項目開發:基礎篇(測試板型號:ESA2GJK1DH1K)

此為出售的教程:開發板鏈接

開發板學習交流群:

提醒:為方便代碼移植和使用,使用了大量的程序處理架構,封裝了很多處理架構包!望耐心學習體會!

如果你是學生，只需要學習內部程序處理思想即可！

其余知識點作為開闊自己的知識面！切莫浮躁！我盡量多做注解！

• 基礎開源教程:學習Android
• 基礎開源教程:微信小程序開發入門篇
• 基礎開源教程:ESP8266 SDK開發
• 基礎開源教程:ESP8266 LUA開發
• 基礎開源教程:ESP8266 AT指令開發（51單片機）
• 基礎開源教程:軟件安裝使用: OpenResty
• 基礎開源教程:網頁/網站開發基礎入門篇
• 基礎開源教程:軟件安裝使用: MySQL數據庫
• 基礎開源教程:單片機模塊化程序

以上為基礎公開教程,我這里不出售基礎教程,基礎教程全部開源,請自行學習！

該開發板全部篇章：

• 基礎篇(遠程通信控制:MQTT)：https://www.cnblogs.com/yangfengwu/category/1576745.html
• 升級篇(遠程程序更新:OTA)： https://www.cnblogs.com/yangfengwu/category/1561578.html
• 數據篇(歷史數據查詢:數據庫)：https://www.cnblogs.com/yangfengwu/category/1410242.html
• 安全篇(設備加密通信:SSL)：https://www.cnblogs.com/yangfengwu/category/1451836.html
• 微信小程序篇：(實現以上篇章所有功能)：https://www.cnblogs.com/yangfengwu/category/1580657.html
• 微信公眾號篇：(實現以上篇章所有功能)：https://www.cnblogs.com/yangfengwu/category/1587496.html

基礎篇：（自己搭建物聯網平台）

1. 硬件使用說明
2. APP使用SmartConfig綁定Wi-Fi設備並通過MQTT控制設備(V0.1)
3. APP使用SmartConfig綁定Wi-Fi設備並通過MQTT控制設備(V1.0)(AT+TCP透傳指令)
4. APP使用SmartConfig綁定Wi-Fi 設備並通過MQTT控制設備(V1.0)(AT+TCP非透傳指令)
5. APP使用APUConfig配網綁定ESP8266,實現遠程溫濕度顯示和遠程控制繼電器
6. APP掃描Air202上面的二維碼綁定設備並通過MQTT控制設備(兼容SIM800)(V0.1)
7. APP掃描Air202上面的二維碼綁定設備並通過MQTT控制設備(兼容SIM800)(V1.0)
8. 來吧! 徹底學習一下MQTT
9. 購買雲服務器
10. 安裝MQTT服務器軟件
11. 移植MQTT底層包到自己的項目(V0.1)
12. 移植MQTT底層包到自己的項目(V1.0)
13. Android連接MQTT簡單的Demo
14. Android實現MQTT封裝源碼使用說明
15. Android實現SmartConfig簡單Demo
16. 移植源碼中SmartConfig程序到自己的項目

基礎篇：（阿里雲物聯網平台）

1. 阿里雲物聯網平台: 測試MQTT連接阿里雲物聯網平台
2. 阿里雲物聯網平台: 使用阿里雲物聯網平台提供的自定義Topic通信控制(ESP8266,TCP透傳指令)
3. 阿里雲物聯網平台: 使用阿里雲物聯網平台提供的物理模型Topic通信控制(ESP8266,TCP透傳指令)
4. 阿里雲物聯網平台: 使用阿里雲物聯網平台提供的自定義Topic通信控制(Air202,TCP透傳指令)
5. 阿里雲物聯網平台: 使用阿里雲物聯網平台提供的物理模型Topic通信控制(Air202,TCP透傳指令)
6. 阿里雲物聯網平台: Android 連接阿里雲物聯網平台
7. 阿里雲物聯網平台: 阿里雲物聯網平台加入規則引擎(雲產品流轉),讓兩個MQTT設備之間實現通信

 

題外話

 　　我老爸也問我物聯網發展的趨勢是什么!!!!!!

　　我自己感覺的:(正在朝着 "我,機器人" 這部電影的服務器方向發展)

　　以后的設備都會和服務器交互,就是說本地不再做處理,全部的處理數據是在一個龐大的服務器端

　　咱現在手機上的各種軟件以后也不會安裝在手機了,所有的都是在服務器端

　　現在的微信小程序,阿里小程序等等,正是在把應用程序放到了他們的服務器端運行.

　　這種運行方式考驗兩方面:

　　　　1.服務器處理能力

　　　　2.網絡數據通信速度

　　只要是這兩方面達到了,就會使很多東西革新換代(像電腦和手機),當前也會促使其它行業發展起來.

前言

　　這節讓大家知道Android是怎么連接的MQTT

　　使用的是下面這個包

　　

 

 

 

 

　　官方下載地址

　　https://repo.eclipse.org/content/repositories/paho-releases/org/eclipse/paho/org.eclipse.paho.client.mqttv3/

　　選擇1.2.0 或者1.2.1或者1.2.2都可以

　　

 

 

　　

 

 

 

新建工程,導入jar包(以下兩種方式選擇一個即可)

方式一: build.gradle添加sdk依賴

　　implementation 'org.eclipse.paho:org.eclipse.paho.client.mqttv3:1.2.2'

 

 

 

 

方式二:   jar包拷貝到新工程的app/libs目錄

 

　　

 

 

 

　　軟件設置加載jar包

　　

 

 

 

 

　　

 

 

　　

 

 

 

基礎篇:源碼使用注意事項和程序優化

 

 

連接MQTT

public class MainActivity extends AppCompatActivity {

    private static MqttClient mqttClient;
    private static MqttConnectOptions mqttConnectOptions;
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        mqttConnectOptions  = new MqttConnectOptions();//MQTT的連接設置
        mqttConnectOptions.setCleanSession(true);//清除連接信息
        mqttConnectOptions.setUserName("yang");//設置連接的用戶名
        mqttConnectOptions.setPassword("11223344".toCharArray());//設置連接的密碼
        mqttConnectOptions.setConnectionTimeout(3);// 設置連接超時時間 單位為秒
        mqttConnectOptions.setKeepAliveInterval(60);//心跳包時間60S
        try { mqttClient = new MqttClient(
                    "tcp://47.92.31.46:1883",//連接的地址信息
                    System.currentTimeMillis()+"",//ClientID,使用當前時間戳
                    new MemoryPersistence());//
            mqttClient.setCallback(new MqttCallback() {//回調函數
                @Override//連接斷開
                public void connectionLost(Throwable throwable) { }
                @Override//接收到消息
                public void messageArrived(String s, MqttMessage mqttMessage) throws Exception { }
                @Override//沒用過
                public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) { }
            });
            new Thread(new Runnable() {//用任務
                @Override
                public void run() {
                    try {
                        mqttClient.connect(mqttConnectOptions);
                        if (mqttClient.isConnected()) {
                            Log.e("Mqtt Info", "ConnectSuccess");
                        }
                    }catch (Exception e){
                        Log.e("Mqtt Err", e.toString());
                    }
                }
            }).start();
        }
        catch (Exception e){
            Log.e("Mqtt Err", e.toString());
        }
    }
}

　　

 

 

 

final MqttMessage msgMessage = new MqttMessage(mqttMessage.toString().getBytes());
new Thread(new Runnable() {//用任務
    @Override
    public void run() {
        try {
            mqttClient.publish("2222",msgMessage);//發布主題為2222的消息
        }catch (Exception e){
            Log.e("Mqtt Err", e.toString());
        }
    }
}).start();

　　

 

 

 

 

 

 

 

 

 

測試

 

 

 

 

添加網絡通信權限

<uses-permission android:name="android.permission.INTERNET" />

 

 

下載到手機測試

 

訂閱主題,打印接收的消息

Log.e("MqttMsg:", "Topic:"+s+" "+"Msg:"+mqttMessage.toString());

mqttClient.subscribe("1111",0);//訂閱1111,消息等級0

 

 

 

 

測試

 

 

 

 

發送消息