android-mqtt MQTT 在 Android 上的二次封装，使用更加简单方便。 @codeKK AndroidOpen Source Website

android-mqtt

Introduction: MQTT 在 Android 上的二次封装，使用更加简单方便。

Tags:

添加依赖

在 project 的 build.gradle 文件中添加 maven 仓库

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

在 app 的 build.gradle 文件中添加依赖

dependencies {
    implementation 'com.pingerx:android-mqtt:1.0.4'
}

使用流程

初始化 MQTT

MqttManager.getInstance().init(context,config)

连接 MQTT 服务端

MqttManager.getInstance().connect {
    onConnectSuccess {
        showTips("服务器连接成功")
    }
    onConnectFailed {
        showTips("服务器连接失败：${it?.message}")
    }
}

订阅一个话题

MqttManager.getInstance().subscribe(topic) {
    onSubscriberSuccess {
        showTips("订阅成功")
    }
    onSubscriberFailed {
        showTips("订阅失败：${it?.message}")
    }
    onDeliveryComplete {
        showTips("消息推送完毕：$it")
    }
    onConnectionLost {
        showTips("连接已断开")
    }
}

推送一条消息

MqttManager.getInstance().publishMessage(topic, "Hello Mqtt...")

主动断开连接
```
MqttManager.getInstance().disconnect()
```
关闭 MQTT 客户端（一般 app 退出时调用）
```
MqttManager.getInstance().close()
```

android-mqtt

添加依赖

使用流程

相关学习资料