Android MQTT的使用以及一些常见的问题

1.Android MQTT

使用步骤

• 引入依赖
  
• 先连接
  
• 订阅
  
• 发布
  
• 取消订阅
  
• 取消连接
  

起首，确保你的AndroidManifest.xml文件中声明白这些权限

1.     <uses-permission android:name="android.permission.INTERNET"/>
2.     <uses-permission android:name="android.permission.SYSTEM_ALERT_WINDOW"/>
3.     <uses-permission android:name="android.permission.WAKE_LOCK"/>
4.     <uses-permission android:name="android.permission.ACCESS_NETWORK_STATE"/>

复制代码

2.Android连接mqtt

往build.gradle引入
Android开辟mqtt客户端主流使用的是eclipse提供的paho.mqtt

1.   implementation 'org.eclipse.paho:org.eclipse.paho.android.service:1.1.1'
2.   implementation 'org.eclipse.paho:org.eclipse.paho.client.mqttv3-1.1.0'

复制代码

这是使用的是Android12(api30)  
1.MQTTService类

1. import android.app.Service;
2. import android.content.Intent;
3. import android.os.Binder;
4. import android.os.IBinder;
5. import android.util.Log;
7. import org.eclipse.paho.android.service.MqttAndroidClient;
8. import org.eclipse.paho.client.mqttv3.IMqttActionListener;
9. import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
10. import org.eclipse.paho.client.mqttv3.IMqttToken;
11. import org.eclipse.paho.client.mqttv3.MqttCallback;
12. import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
13. import org.eclipse.paho.client.mqttv3.MqttException;
14. import org.eclipse.paho.client.mqttv3.MqttMessage;
16. import java.util.Date;
18. // MQTT服务类，继承自Service
19. public class MQTTService extends Service {
21.     // MQTT服务器地址
22.     public static String host = "tcp://192.168.**";
23.     // 订阅的主题
24.     public static String topic = "order";
25.     // MQTT客户端实例
26.     private MqttAndroidClient client;
27.     // MQTT连接选项
28.     private MqttConnectOptions mqttConnectOptions;
30.     // 构造方法，通常用于初始化成员变量（这里为空）
31.     public MQTTService() {
32.     }
34.     // onBind方法，当其他组件（如Activity）绑定到此服务时调用
35.     @Override
36.     public IBinder onBind(Intent intent) {
37.         // 返回一个CustomBinder实例，允许客户端与服务进行通信
38.         return new CustomBinder();
39.     }
41.     // onCreate方法，当服务创建时调用
42.     @Override
43.     public void onCreate() {
44.         super.onCreate();
45.         Log.d("tag", "服务启动成功");
46.         try {
47.             // 初始化MQTT客户端和连接
48.             init();
49.         } catch (MqttException e) {
50.             // 打印异常堆栈信息
51.             e.printStackTrace();
52.         }
53.     }
55.     // 自定义Binder类，用于客户端与服务之间的通信
56.     public class CustomBinder extends Binder {
57.         // 获取MQTTService实例的方法
58.         public MQTTService getService() {
59.             return MQTTService.this;
60.         }
61.     }
63.     // 初始化MQTT客户端的方法
64.     public void init() throws MqttException {
65.         // 创建MqttAndroidClient实例，传入上下文、服务器地址、客户端ID和自动确认消息模式
66.         client = new MqttAndroidClient(this, host, String.valueOf(new Date().getTime()), MqttAndroidClient.Ack.AUTO_ACK);
67.         // 设置MQTT回调
68.         client.setCallback(mqttCallback);
69.         // 创建MqttConnectOptions实例
70.         mqttConnectOptions = new MqttConnectOptions();
71.         // 如果客户端未连接，则尝试连接
72.         if (!client.isConnected()) {
73.             client.connect(mqttConnectOptions, null, iMqttActionListener);
74.         }
75.     }
77.     // MQTT连接操作的监听器
78.     IMqttActionListener iMqttActionListener = new IMqttActionListener() {
79.         @Override
80.         public void onSuccess(IMqttToken iMqttToken) {
81.             try {
82.                 // 连接成功后订阅指定主题
83.                 client.subscribe(topic, 1); // QoS等级为1
84.             } catch (MqttException e) {
85.                 // 打印异常堆栈信息
86.                 e.printStackTrace();
87.             }
88.         }
90.         @Override
91.         public void onFailure(IMqttToken iMqttToken, Throwable throwable) {
92.             // 连接失败时打印异常堆栈信息
93.             throwable.printStackTrace();
94.         }
95.     };
97.     // MQTT回调接口的实现，用于处理连接丢失、消息到达和消息发送完成事件
98.     MqttCallback mqttCallback = new MqttCallback() {
99.         @Override
100.         public void connectionLost(Throwable throwable) {
101.             // 连接丢失时的处理（此处为空）
102.         }
104.         @Override
105.         public void messageArrived(String s, MqttMessage mqttMessage) throws Exception {
106.             // 当消息到达时打印消息内容、主题、QoS等级和保留标志
107.             Log.d("string", mqttMessage.getPayload().toString());
108.      
109.         }
111.         @Override
112.         public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {
113.             // 消息发送完成时的处理（此处为空）
114.         }
115.     };
116. }

复制代码

2.MqttCerviceConn类

1. import android.content.ComponentName;
2. import android.content.ServiceConnection;
3. import android.os.IBinder;
5. // MqttCerviceConn类实现了ServiceConnection接口，用于处理MQTT服务的连接和断开
6. public class MqttCerviceConn implements ServiceConnection {
7.     // MQTTService类的实例，用于与服务进行交互
8.     public MQTTService mqttService;
10.     // 当服务成功连接时调用此方法
11.     @Override
12.     public void onServiceConnected(ComponentName name, IBinder service) {
13.         // 将IBinder转换为MQTTService中定义的CustomBinder类型，并获取MQTTService的实例
14.         // 这里假设MQTTService有一个名为CustomBinder的内部类，它实现了IBinder接口，并有一个getService()方法返回MQTTService的实例
15.         mqttService = ((MQTTService.CustomBinder)service).getService();
16.         //你可以在这里实现其他业务功能 比如 aidl接口
17.     }
19.     // 当服务断开连接时调用此方法
20.     @Override
21.     public void onServiceDisconnected(ComponentName name) {
22.         // 在这里可以处理服务断开连接的逻辑，比如清理资源或更新UI
23.         // 当前方法体为空，表示没有特定的断开连接处理逻辑
24.     }
25. }

复制代码

• ServiceConnection接口：用于监听与服务的连接状态。当服务连接乐成或断开时，系统会分别调用onServiceConnected和onServiceDisconnected方法。
  
• IBinder接口：服务通过它与客户端（如Activity或其他组件）进行通信。在onServiceConnected方法中，你可以通过通报给你的IBinder对象来获取服务的实例。
  
• MQTTService：假设这是一个自界说的服务类，用于处理MQTT相干的操作。它有一个为CustomBinder的单独的Binder类，该类实现了IBinder接口，并提供了一个方法来获取MQTTService的实例。
  

这个类通常用于在Activity或其他组件中，当需要与服务进行交互时，通过绑定服务来使用。绑定服务后，你可以通过mqttService实例来调用服务中界说的方法。
在MainActivity启动Mqtt服务

1. @Override
2. protected void onCreate(Bundle savedInstanceState) {
3.     super.onCreate(savedInstanceState);
4.     setContentView(R.layout.activity_main);
6.     // 创建MqttCerviceConn的实例，这个类实现了ServiceConnection接口，用于处理服务连接和断开的回调
7.     MqttCerviceConn mqttCerviceConn = new MqttCerviceConn();
8.    
9.     // 创建一个Intent，用于指定要绑定的服务。这里指定的是MQTTService类
10.     Intent intent = new Intent(this, MQTTService.class);
11.    
12.     // 绑定服务。这个方法会异步地尝试连接到指定的服务
13.     // 第一个参数是Intent，用于指定要绑定的服务
14.     // 第二个参数是ServiceConnection的实例，用于接收服务连接和断开的回调
15.     // 第三个参数是一个标志，这里使用的是Context.BIND_AUTO_CREATE，表示如果服务尚未创建，则自动创建它
16.     bindService(intent, mqttCerviceConn, Context.BIND_AUTO_CREATE);
17. }

复制代码

3.常见的报错

1. 在连接的时候 千万别忘记tcp:// 否则会连接失败。

2.如果报cannot start service org.eclipse.paho.android.service.MqttService

你需要在AndroidManifest.xml中添加
<service android:name="org.eclipse.paho.android.service.MqttService"/>


免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。