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

 

 

 

 

测试

 

 

 

 

发送消息