• 本系列博客学习由非官方人员 半颗心脏 潜心所力所写，仅仅做个人技术交流分享，不做任何商业用途。如有不对之处，请留言，本人及时更改。

  • ① 对物联网爱不释手，在Android手机集成使用MQTT协议 ，实现搞掂移动控制硬件端。

  • ① 新年新气象，封装一个esp8266一键配网XSmartConfig , 支持自定义回调。

一、认识MQTT协议。

如果你对MQTT协议的连接过程不熟悉，那没关系；请看我前面的8266硬件上介绍的MQTT介绍 ，其实也没啥难，这个MQTT的好处是短小，信息传递快捷 ，适合在有限的空间的硬件的开发，比如8266 ， 或者其他通讯模块。

二、新建Android项目，集成MQTT的架包。

• 我是用AndroidStudio工具开发的，所以集成比较简单，我也强烈推荐大家去使用AS 。

• 第一步：找到eclipse下开源的项目，GitHub地址 ，因为AS是grdle来编译的，所以在您新建的工程下的build.gradle下的目录加进以下代码：

repositories {
    maven {
        url "https://repo.eclipse.org/content/repositories/paho-snapshots/"
    }
}

• 第二步：在你的APP的模块下的build.gradle ，添加依赖 ，目前最新版3.1.1：

    compile 'org.eclipse.paho:org.eclipse.paho.client.mqttv3:1.1.0'
    compile 'org.eclipse.paho:org.eclipse.paho.android.service:1.1.1'

• 第三步：在你的清单文件加上，MQTT所依赖的服务和权限：

  <!-- Permissions the Application Requires -->
    <uses-permission android:name="android.permission.WAKE_LOCK" />
    <uses-permission android:name="android.permission.WRITE_EXTERNAL_STORAGE" />
    <uses-permission android:name="android.permission.ACCESS_NETWORK_STATE" />

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

    <service android:name="org.eclipse.paho.android.service.MqttService"/>      

三、开始你的代码。

注意必须要初始化客户端，才可以订阅主题和发布消息操作！否则异常 ！

• ① 初始化客户端和连接选项。MqttAndroidClient 类是整个连接的核心 ， 而MqttConnectOptions 是连接的选项配置。

    //客户端
     private MqttAndroidClient client;

    //连接选项
    private MqttConnectOptions mqttConnectOptions;


 //第一个参数上下文，第二个服务器地址，注意下面的格式!!!! 第三个是 客户端ID，注意 必须唯一，如果存在此ID连接了服务器。那么连接失败！
       client = new MqttAndroidClient(this, "tcp://iot.eclipse.org:1883", "androidID");

        //配置连接信息
         mqttConnectOptions=new MqttConnectOptions();
        //是否清除缓存
        mqttConnectOptions.setCleanSession(true);
        //是否重连
        mqttConnectOptions.setAutomaticReconnect(true);
        //设置心跳,30s
        mqttConnectOptions.setKeepAliveInterval(30);
        //登陆的名字,根据服务器要求，一般不用写
        mqttConnectOptions.setUserName("xuhong");
        //登陆的密码,
        mqttConnectOptions.setPassword("123545".toCharArray());
        //超时时间
        mqttConnectOptions.setConnectionTimeout(30);
        //监听服务器发来的 信息
        client.setCallback(new MqttCallback() {
            @Override
            public void connectionLost(Throwable cause) {
                //连接丢失异常
            }

            @Override
            public void messageArrived(String topic, MqttMessage message) throws Exception {
                //收到服务器的信息

            }

            @Override
            public void deliveryComplete(IMqttDeliveryToken token) {

            }
        });

• ② 开始连接服务器，当然你可以不用监听，如果不抛出异常，也是连接成功啦！

如果您的服务器是没有账号密码登陆的话，那么可以不用第二个参数；
如果你的服务器是有账号密码的，请参考以下方法，中间传个 null ，切记切记 ！本工程的下载的Demo是没有的！

   //开始连接服务器
        try {
            client.connect(mqttConnectOptions, null , new IMqttActionListener() {
                @Override
                public void onSuccess(IMqttToken asyncActionToken) {
                       //连接成功
                }

                @Override
                public void onFailure(IMqttToken asyncActionToken, Throwable exception) {
                     //连接失败
                }
            });

        } catch (MqttException e) {
            e.printStackTrace();
            //连接失败
        }

• ③ 订阅信息！，主题是 /xuhong , 质量是0 。

      try {
            client.subscribe("/xuhong", 0, null, new IMqttActionListener() {
                @Override
                public void onSuccess(IMqttToken asyncActionToken) {
                    tvShow.setText("订阅成功！");
                }

                @Override
                public void onFailure(IMqttToken asyncActionToken, Throwable exception) {
                    tvShow.setText("订阅失败！" + exception);
                }
            });
        } catch (MqttException e) {
            e.printStackTrace();
        }

• ④ 发布信息，主题是 /xuhong ,质量是0信息是 hello xuhong 。

    MqttMessage mqttMessage = new MqttMessage();
        mqttMessage.setPayload("hello xuhong".getBytes());

        try {
            client.publish("/xuhong", mqttMessage, null, new IMqttActionListener() {
                @Override
                public void onSuccess(IMqttToken asyncActionToken) {
                    tvShow.setText("发布消息成功");
                }

                @Override
                public void onFailure(IMqttToken asyncActionToken, Throwable exception) {
                    tvShow.setText("发布消息失败");
                }
            });
        } catch (MqttException e) {
            e.printStackTrace();
            tvShow.setText("发布消息失败");
        }

• ⑤ 欣赏下；

• 下载地址：http://download.csdn.net/download/xh870189248/10178871