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