Android MQTT
MQTT
Android MQTT连接,重新编译Service-1.1.1兼容Android高版本服务
Paho Android Service-1.1.1
Paho Client Mqtt3-1.1.0
资源
| 名字 | 资源 |
|---|---|
| AAR | 下载 |
| GitHub | 查看 |
| Gitee | 查看 |
Maven
1.build.grade
allprojects {repositories {...maven { url 'https://jitpack.io' }}
}
2./app/build.grade
dependencies {implementation 'com.github.RelinRan:MQTT:2023.9.23.1'
}
初始化
配置权限
<uses-permission android:name="android.permission.INTERNET" />
<uses-permission android:name="android.permission.WAKE_LOCK" />
<uses-permission android:name="android.permission.ACCESS_NETWORK_STATE" />
<uses-permission android:name="android.permission.READ_PHONE_STATE" />
Service配置
<service android:name="org.eclipse.paho.android.service.MqttService"/>
初始化服务端
MqttOptions options = new MqttOptions();
options.setHost("tcp://xxx.iot-as-mqtt.cn-shanghai.aliyuncs.com:1883");
options.setClientId("xxxx.301F9A89A749|securemode=2,signmethod=hmacsha256,timestamp=1189770888615|");
options.setUserName("321F9A89A749&xxxx");
options.setPassword("64ac769d2f523d48730294bffe6323a566005543e3e372c802903f748f118a");
Imqtt mqtt = Mqtt.initialize(this,options);
监听连接
long cid = mqtt.addConnectListener(new OnConnectListener() {@Overridepublic void onConnectionLost(Throwable cause) {}@Overridepublic void onConnectionSuccessful(IMqttToken token) {}@Overridepublic void onConnectionFailed(IMqttToken token, Throwable exception) {}
});
监听消息
long mid = mqtt.addMessageListener(new OnMessageListener() {@Overridepublic void onMessageReceived(String topic, MqttMessage message) {}@Overridepublic void onMessageDelivered(IMqttDeliveryToken token) {}});
服务连接
mqtt.connect();
监听移除
mqtt.remove(mid,cid);
监听清空
mqtt.clear();
发送内容
mqtt.publish(String topic, String payload);
订阅主题
mqtt.subscribe(String topic);