【BeagleBone Black试用体验】+MQTT服务器和手机APP实现ＭＱTT协议（第3篇）

手机

1. 本次的主要目的是实现在手机上接收AM3359的MQTT消息。
2. 首先我需要搭建一个服务器。去网上搜了一下，打算用apollo的服务器，以前没用过这个。
先去官方下载版本。 http://activemq.apache.org/apollo/download.html

3. 解压，进入安装的bin目录，这个是 cmd命令行进去的。
输入 appollo create qhq_server , qhq_server是我起的服务器名字。
进入 qhq_server ，然后再进入etcusers.properties文件，它包含连接MQTT服务器时用到的用户名和密码，默认为admin=password，即账号为admin，密码为password，可自行更改。

进入 qhq_serverbin 之后输入apollo-broker.cmd run开启服务器,成功就是下图了

4. 检查是否成功。浏览器输入http://127.0.0.1:61680/，查看是否安装成功。我的是安装成功了、

5. 接下来需要开始写APP部分了。
我现在还用的 eclipse, 听说新出了一个 android-studio工具，我还没试过。
新建一个功能，和配置

6. 创建完工程后，开始添加依赖
dependencies {
compile 'org.eclipse.paho:org.eclipse.paho.client.mqttv3:1.1.0'
compile 'org.eclipse.paho:org.eclipse.paho.android.service:1.1.0'
}

7. 注册Service


具体的代码（这一部分主要是参考网上http://www.itnose.net/detail/6652162.html这一个帖子，我以前没做过MQTT手机端，所以主要参考他的，自己研究研究拿来用）
package com.dongyk.service;
import android.app.Service;
public class MQTTService extends Service {
public static final String TAG = MQTTService.class.getSimpleName();
private static MqttAndroidClient client;
private MqttConnectOptions conOpt;
// private String host = "tcp://10.0.2.2:61613";
private String host = "tcp://192.168.1.103:61613";
private String userName = "admin";
private String passWord = "password";
private static String myTopic = "AM3359_TEST";
private String clientId = "am3359_test";

public int onStartCommand(Intent intent, int flags, int startId) {
      init();
      return super.onStartCommand(intent, flags, startId);
}

public static void publish(String msg){
      String topic = myTopic;
      Integer qos = 0;
      Boolean retained = false;
      try {
         client.publish(topic, msg.getBytes(), qos.intValue(), retained.booleanValue());
      } catch (MqttException e) {
         e.printStackTrace();
      }
}

private void MQTT_init() {
      // 服务器地址（协议+地址+端口号）
      String uri = host;
      client = new MqttAndroidClient(this, uri, clientId);
      // 设置MQTT监听并且接受消息
      client.setCallback(mqttCallback);

      conOpt = new MqttConnectOptions();
      // 清除缓存
      conOpt.setCleanSession(true);
      // 设置超时时间，单位：秒
      conOpt.setConnectionTimeout(10);
      // 心跳包发送间隔，单位：秒
      conOpt.setKeepAliveInterval(20);
      // 用户名
      conOpt.setUserName(userName);
      // 密码
      conOpt.setPassword(passWord.toCharArray());

      // last will message
      boolean doConnect = true;
      String message = "{"terminal_uid":"" + clientId + ""}";
      String topic = myTopic;
      Integer qos = 0;
      Boolean retained = false;
      if ((!message.equals("")) || (!topic.equals(""))) {
         try {
            conOpt.setWill(topic, message.getBytes(), qos.intValue(), retained.booleanValue());
         } catch (Exception e) {
            Log.i(TAG, "Exception Occured", e);
            doConnect = false;
            iMqttActionListener.onFailure(null, e);
         }
      }

      if (doConnect) {
         doClientConnection();
      }

}

/** 连接MQTT服务器 */
private void doClientConnection() {
      if (!client.isConnected() && isConnectIsNomarl()) {
         try {
            client.connect(conOpt, null, iMqttActionListener);
         } catch (MqttException e) {
            e.printStackTrace();
         }
      }

}

// MQTT是否连接成功
private IMqttActionListener iMqttActionListener = new IMqttActionListener() {

      @Override
      public void onSuccess(IMqttToken arg0) {
         Log.i(TAG, "连接成功 ");
         try {
            // 订阅myTopic话题
            client.subscribe(myTopic,1);
         } catch (MqttException e) {
            e.printStackTrace();
         }
      }

      @Override
      public void onFailure(IMqttToken arg0, Throwable arg1) {
         arg1.printStackTrace();
            // 连接失败，重连
      }
};

// MQTT监听并且接受消息
private MqttCallback mqttCallback = new MqttCallback() {
      @Override
      public void messageArrived(String topic, MqttMessage message) throws Exception {
         String str1 = new String(message.getPayload());
         MQTTMessage msg = new MQTTMessage();
         msg.setMessage(str1);
         EventBus.getDefault().post(msg);
         String str2 = topic + ";qos:" + message.getQos() + ";retained:" + message.isRetained();
         Log.i(TAG, "messageArrived:" + str1);
         Log.i(TAG, str2);
      }

      @Override
      public void deliveryComplete(IMqttDeliveryToken arg0) {

      }

      @Override
      public void connectionLost(Throwable arg0) {
         // 失去连接，重连
      }
};

/** 判断网络是否连接 */
private boolean isConnectIsNomarl() {
      ConnectivityManager connectivityManager = (ConnectivityManager) this.getApplicationContext().getSystemService(Context.CONNECTIVITY_SERVICE);
      NetworkInfo info = connectivityManager.getActiveNetworkInfo();
      if (info != null && info.isAvailable()) {
         String name = info.getTypeName();
         Log.i(TAG, "MQTT当前网络名称：" + name);
         return true;
      } else {
         Log.i(TAG, "MQTT 没有可用网络");
         return false;
      }
}

@Nullable
@Override
public IBinder onBind(Intent intent) {
      return null;
}
}
首先初始化各个参数，之后连接服务器。连接成功之后在http://127.0.0.1:61680/看到自动创建了名称为”AM3359_TEST”的topic。

8. 启动板子，用手干扰一下热释电，就可以在手机主题上看到这个消息。
9. 因为我的电脑没有公网IP地址，所以目前只能在内网测试一下了，就是把板子，电脑，手机都连接到通同一个路由器上，要不就不成功了。
10 ，其实还有一个 shell 脚本文件，就是定时检测热释电，有信号就启动一下MQTT去发个消息。
11. 目前基本功能都已经实现，扩展部分就是SPI 接口的 LCD屏和 WIFI 部分了。不过这些有时间的话做一做，后续做的话会分享给大家。
12. 项目基本完成了，不过还有许多BUG，尚待完善。继续努力。。。