EasyMqttAndroidClient

使Mqtt安卓客戶端變的更簡單、更好用

簡介

基於第三方開源框架Mqtt Android客戶端封裝的用於接收、釋出推送訊息的元件。

功能

1.支援訊息的訂閱與釋出
2.支援伺服器的連線與斷開
3.支援連線狀態的判斷
4.支援自動重連、清除session、心跳間隔、超時時間等配置

使用方法

第一步：在project的build.gradle 檔案中新增JitPack依賴

allprojects {
    repositories {
        ...
        maven { url 'https://jitpack.io' }
    }
}
 

第二步: 在Module的build.gradle檔案中新增對本庫的依賴

dependencies {
    ...
    compile 'com.github.ZS-ZhangsShun:EasyMqttAndroidClient:1.0'
}

第三步：開始使用 以下方法可直接拷貝到專案中使用 引數根據實際情況修改即可 詳情參考 github 上 demo中 MainActivity的示例程式碼

（1）構建MqttService物件

/**
 * 構建EasyMqttService物件
 */
private void buildEasyMqttService() {
    mqttService = new EasyMqttService.Builder()
            //設定自動重連
            .autoReconnect(true)
            //設定不清除回話session 可收到伺服器之前發出的推送訊息
            .cleanSession(false)
            //唯一標示 保證每個裝置都唯一就可以 建議 imei
            .clientId("your clientId")
            //mqtt伺服器地址 格式例如：tcp://10.0.261.159:1883
            .serverUrl("your mqtt servier url")
            //心跳包預設的傳送間隔
            .keepAliveInterval(20)
            //構建出EasyMqttService 建議用application的context
            .bulid(this.getApplicationContext());
}
 

（2）連線Mqtt伺服器

/**
 * 連線Mqtt伺服器
 */
private void connect() {
    mqttService.connect(new IEasyMqttCallBack() {
        @Override
        public void messageArrived(String topic, String message, int qos) {
            //推送訊息到達
        }

        @Override
        public void connectionLost(Throwable arg0) {
            //連線斷開
        }

        @Override
        public void deliveryComplete(IMqttDeliveryToken arg0) {

        }

        @Override
        public void connectSuccess(IMqttToken arg0) {
            //連線成功
        }

        @Override
        public void connectFailed(IMqttToken arg0, Throwable arg1) {
            //連線失敗
        }
    });
}
 

（3）訂閱主題

/**
 * 訂閱主題 這裡訂閱三個主題分別是"a", "b", "c"
 */
private void subscribe() {
    String[] topics = new String[]{"a", "b", "c"};
    //主題對應的推送策略 分別是0, 1, 2 建議服務端和客戶端配置的主題一致
    // 0 表示只會傳送一次推送訊息 收到不收到都不關心
    // 1 保證能收到訊息，但不一定只收到一條
    // 2 保證收到切只能收到一條訊息
    int[] qoss = new int[]{0, 1, 2};
    mqttService.subscribe(topics, qoss);
}

（4）關閉連線

/**
 * 關閉連線
 */
private void close() {
    mqttService.close();
}

（5）斷開連線

/**
 * 斷開連線
 */
private void disconnect() {
    mqttService.disconnect();
}

（6）判斷連線狀態

/**
 * 判斷服務是否連線
 */
private boolean isConnected() {
    return mqttService.isConnected();
}

（7）釋出訊息

/**
 * 釋出訊息
 */
private void publish(String msg, String topic, int qos, boolean retained) {
    mqttService.publish(msg, topic, qos, retained);
}