QMqttClient自动断开重连实现及Qt Android应用后台持续运行方案咨询

你搭建的MQTT门铃系统场景我挺熟悉的，之前做过类似的家庭IoT设备对接，碰到过一样的问题，给你梳理下具体的解决方案：

1. 解决QMqttClient自动断开与自动重连问题 #

setAutoKeepAlive(true)只是开启了自动发送心跳包，但实际断开的原因可能有很多，得从主动预防和被动重连两方面入手：

主动预防断开的关键点 #

• 匹配Broker的KeepAlive配置：客户端设置的keepalive时间（比如_client->setKeepAlive(30)，单位秒）要和MQTT Broker的配置一致，避免Broker因未收到心跳主动断开连接。
• 禁用CleanSession（按需）：如果设置_client->setCleanSession(false)，Broker会保留你的会话状态，重连后自动恢复之前的订阅，减少手动处理的麻烦；但如果是临时连接场景，保持true也可以。
• 检查网络稳定性：如果是家庭WiFi波动导致的断开，可以在客户端监听网络状态变化（Qt可以用QNetworkConfigurationManager），网络恢复后触发重连。

实现可靠的自动重连逻辑 #

QMqttClient提供了disconnected()信号，我们可以基于这个信号实现重连机制，核心是延迟重试+状态判断：

// 在类的构造函数或初始化代码中连接信号
connect(_client, &QMqttClient::disconnected, this, &YourClass::onMqttDisconnected);

// 重连槽函数
void YourClass::onMqttDisconnected() {
    // 避免频繁重试，用QTimer延迟5秒后尝试重连
    if (!_reconnectTimer) {
        _reconnectTimer = new QTimer(this);
        connect(_reconnectTimer, &QTimer::timeout, this, &YourClass::reconnectMqtt);
    }
    if (!_reconnectTimer->isActive()) {
        _reconnectTimer->start(5000); // 5秒后重试
    }
}

// 实际重连函数
void YourClass::reconnectMqtt() {
    if (_client->state() == QMqttClient::Disconnected) {
        _client->connectToHost();
        // 如果CleanSession为true，重连成功后需要重新订阅主题
        connect(_client, &QMqttClient::connected, this, [this](){
            _client->subscribe("your/doorbell/topic", 1); // 按需设置QoS
            if (_reconnectTimer->isActive()) {
                _reconnectTimer->stop();
            }
        });
    }
}

注意：重连时可以加个最大重试次数限制，或者根据网络状态动态调整重试间隔，避免无限循环占用资源。

2. 防止Qt Android应用被系统杀死 #

只设置android:persistence="true"远远不够，尤其是Android 8.0（API 26）之后，系统对后台应用的限制非常严格，得结合以下几种方案：

核心方案：使用前台服务（Foreground Service） #

前台服务会在通知栏显示一个常驻通知，系统会赋予它更高的优先级，不会轻易杀死。实现步骤：

1. 在AndroidManifest.xml中添加权限：

<uses-permission android:name="android.permission.FOREGROUND_SERVICE" />
<!-- Android 13+ 还需要通知权限 -->
<uses-permission android:name="android.permission.POST_NOTIFICATIONS" />

<!-- 注册服务 -->
<service android:name=".MqttForegroundService" android:foregroundServiceType="connectedDevice" />

2. 创建Android服务类：继承Service，在onStartCommand中启动前台服务，返回START_STICKY（服务被杀死后系统会尝试重启）：

public class MqttForegroundService extends Service {
    private static final int NOTIFICATION_ID = 1001;
    private static final String CHANNEL_ID = "MqttDoorbellChannel";

    @Override
    public void onCreate() {
        super.onCreate();
        // 创建通知渠道（Android 8.0+ 必需）
        if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) {
            NotificationChannel channel = new NotificationChannel(CHANNEL_ID,
                    "门铃服务", NotificationManager.IMPORTANCE_LOW);
            NotificationManager manager = getSystemService(NotificationManager.class);
            manager.createNotificationChannel(channel);
        }
    }

    @Override
    public int onStartCommand(Intent intent, int flags, int startId) {
        Notification notification = new NotificationCompat.Builder(this, CHANNEL_ID)
                .setContentTitle("门铃服务运行中")
                .setContentText("等待门铃呼叫")
                .setSmallIcon(R.mipmap.ic_launcher)
                .build();
        // 启动前台服务
        startForeground(NOTIFICATION_ID, notification);
        return START_STICKY;
    }

    @Nullable
    @Override
    public IBinder onBind(Intent intent) {
        return null;
    }
}

3. 在Qt中调用启动服务：通过JNI在应用启动或进入后台时启动前台服务：

#include <QAndroidJniObject>
#include <QAndroidJniEnvironment>

void startForegroundService() {
    QAndroidJniObject activity = QAndroidJniObject::callStaticObjectMethod("org/qtproject/qt5/android/QtNative", "activity", "()Landroid/app/Activity;");
    if (activity.isValid()) {
        QAndroidJniObject intent("android/content/Intent");
        intent.callObjectMethod("setClass", "(Landroid/content/Context;Ljava/lang/Class;)Landroid/content/Intent;",
                                activity.object<jobject>(),
                                QAndroidJniObject::fromString("com/your/package/MqttForegroundService").object<jclass>());
        if (QAndroidJniEnvironment().ExceptionCheck()) {
            QAndroidJniEnvironment().ExceptionClear();
            return;
        }
        // Android 8.0+ 用startForegroundService，之前用startService
        if (QAndroidJniObject::getStaticField<jint>("android/os/Build$VERSION", "SDK_INT") >= 26) {
            activity.callMethod<void>("startForegroundService", "(Landroid/content/Intent;)V", intent.object<jobject>());
        } else {
            activity.callMethod<void>("startService", "(Landroid/content/Intent;)V", intent.object<jobject>());
        }
    }
}

辅助优化措施 #

• 禁用电池优化：引导用户将应用加入电池白名单，避免系统在低电量时杀死应用。可以通过Intent跳转到电池优化设置页面。
• 处理配置变化：在AndroidManifest.xml的activity中添加android:configChanges="orientation|screenSize|keyboardHidden"，避免应用因屏幕旋转等配置变化重启。
• 优化内存占用：及时释放无用资源，避免内存泄漏，系统会优先杀死内存占用高的应用。
• 适配国产ROM：小米、华为、OPPO等国产ROM有独立的后台管理机制，需要在应用中提示用户手动将应用加入“后台保护”或“自启动白名单”，这部分无法通过代码完全解决。

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