android studio怎麽安裝mqtt

1、 下載Apollo服務器，下載後解壓，然後運行apache-apollo-1.6\bin\apollo.cmd，輸入create mybroker（名字任意取，這裏是根據 官網 介紹的來取的）創建服務器實例，服務器實例包含了所有的配置，運行時數據等，並且和壹個服務器進程關聯。

2、create mybroker之後會在bin目錄下生成mybroker文件夾，裏面包含有很多信息，其中etc\apollo.xml文件下是配置服務器信息的文件，etc\users.properties文件包含連接MQTT服務器時用到的用戶名和密碼，後面會介紹，可以修改原始的admin=password，可以接著換行添加新的用戶名密碼。

3、打開cmd，運行…apache-apollo-1.6\bin\mybroker\bin\apollo-broker.cmd run 開啟服務器，可以在瀏覽器中輸入 http://127.0.0.1:61680/ 查看是否安裝成功，該界面展示了topic，連接數等很多信息。

經過上面的簡單步驟，服務器基本上就已經完成，下壹篇將介紹Android客戶端的編寫和註意事項。

客戶端使用的API，開始我使用的是mqtt-client，使用過後發現問題百出，不能很好的滿足要求，後來使用了官方推薦的 Eclipse Paho ，下面開始客戶端代碼的編寫，為了方便測試這裏有android和j2se兩個工程：

1、新建android工程MQTTClient

2、MainActivity代碼如下：

[java] view plaincopyprint?

package ldw.mqttclient;

import java.util.concurrent.Executors;

import java.util.concurrent.ScheduledExecutorService;

import java.util.concurrent.TimeUnit;

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;

import android.app.Activity;

import android.os.Bundle;

import android.os.Handler;

import android.os.Message;

import android.view.KeyEvent;

import android.widget.TextView;

import android.widget.Toast;

public class MainActivity extends Activity {

private TextView resultTv;

private String host = "tcp://127.0.0.1:1883";

private String userName = "admin";

private String passWord = "password";

private Handler handler;

private MqttClient client;

private String myTopic = "test/topic";

private MqttConnectOptions options;

private ScheduledExecutor