阿里mqtt怎么集成android

1.使用Eclipse的库：‍
<!-- https://mvnrepository.com/artifact/org.eclipse.paho/org.eclipse.paho.client.mqttv3 -->
<dependency>
<groupId>org.eclipse.paho</groupId>
<artifactId>org.eclipse.paho.client.mqttv3</artifactId>
<version>1.1.0</version>
</dependency>
2.启动mqtt
MemoryPersistence persistence = new MemoryPersistence();
asyncClient = new MqttClient(broker, clientId, persistence);
connOpts.setUserName(userName);
connOpts.setServerURIs(new String[] { broker });
connOpts.setPassword(passowrd.toCharArray());
connOpts.setCleanSession(false);
connOpts.setKeepAliveInterval(100);
asyncClient.setCallback(this);
asyncClient.connect(connOpts);
3.订阅主题
asyncClient.subscribe("xxx");
4.MqttCallback 里接收mqtt消息
@Override
public void messageArrived(String topic, MqttMessage mqttMessage) throws Exception {
System.out.println("messageArrived:" + topic + "------" + new String(mqttMessage.getPayload()));
}
5.发送消息
final MqttMessage message = new MqttMessage(scontent.getBytes());
message.setQos(1);
asyncClient.publish(topic, message);

温馨提示：答案为网友推荐，仅供参考

当前网址：https://verywind.cn/ee/v7yevjy277fr3xyeexx.html