Android应用中MQTTAndroidClient尝试连接后崩溃问题求助

从你的崩溃日志一眼就能看出核心问题——AndroidX和旧版Support库的兼容性冲突：你的项目用的是AndroidX架构，但你依赖的Paho Android Service版本还在寻找旧的android.support.v4.content.LocalBroadcastManager类，而AndroidX里这个类已经迁移到androidx.localbroadcastmanager.content.LocalBroadcastManager了，直接导致类找不到的崩溃。

下面一步步帮你解决：

1. 补上AndroidX版本的LocalBroadcastManager依赖 #

打开Module级别的build.gradle（就是app目录下的那个配置文件），在dependencies块里添加这个依赖：

implementation 'androidx.localbroadcastmanager:localbroadcastmanager:1.1.0'

2. 升级Paho依赖到兼容AndroidX的版本 #

别用太老的Paho版本了，换成最新的稳定版（1.1.1及以上对AndroidX友好很多），把你的Paho依赖改成这样：

implementation 'org.eclipse.paho:org.eclipse.paho.android.service:1.1.1'
implementation 'org.eclipse.paho:org.eclipse.paho.client.mqttv3:1.2.5'

3. 别忘了在Manifest里注册MqttService #

这步很容易被忽略！官方文档明确要求要在AndroidManifest.xml里注册Paho的服务，不然就算解决了类的问题，连接还是会出异常：

<service android:name="org.eclipse.paho.android.service.MqttService" />

4. 给你的连接代码做个小优化（可选但推荐） #

另外，建议你加上连接配置选项，同时确保Toast在主线程显示（虽然Paho回调大概率在主线程，但显式处理更稳妥），再加上日志方便排查问题，修改后的代码如下：

button.setOnClickListener(new View.OnClickListener() {
    @Override
    public void onClick(View view) {
        String clientId = MqttClient.generateClientId();
        MqttAndroidClient client = new MqttAndroidClient(getApplicationContext(), "tcp://broker.hivemq.com:1883", clientId);
        
        // 配置连接参数，这里用了清理会话的默认配置，你可以根据需求调整
        MqttConnectOptions options = new MqttConnectOptions();
        options.setCleanSession(true);
        
        try {
            IMqttToken token = client.connect(options);
            token.setActionCallback(new IMqttActionListener() {
                @Override
                public void onSuccess(IMqttToken asyncActionToken) {
                    // 确保Toast在主线程弹出
                    runOnUiThread(() -> Toast.makeText(MainActivity.this,"Connected",Toast.LENGTH_SHORT).show());
                }

                @Override
                public void onFailure(IMqttToken asyncActionToken, Throwable exception) {
                    runOnUiThread(() -> {
                        Toast.makeText(MainActivity.this,"Not Connected",Toast.LENGTH_SHORT).show();
                        // 打印详细错误日志，方便排查后续问题
                        Log.e("MQTT_CONNECT_ERROR", "连接失败原因", exception);
                    });
                }
            });
        } catch (MqttException e) {
            Log.e("MQTT_CONNECT_EXCEPTION", "连接抛出异常", e);
            Toast.makeText(MainActivity.this,"连接出现异常",Toast.LENGTH_SHORT).show();
        }
    }
});

做完这些步骤后，同步一下gradle，重新运行项目，应该就能顺利连接到HiveMQ的broker了。

内容的提问来源于stack exchange，提问作者alemomo