Eclipse Paho MQTT Client：如何检查并复用现有连接？

我之前也碰到过这个问题，频繁创建销毁MQTT客户端确实会带来不小的性能开销，而且直接用MQTTClient_isConnected()出现段错误，多半是因为你在客户端句柄还没初始化（或者已经被销毁释放）的时候就调用了这个函数，它内部会访问无效的内存地址，自然就崩了。下面给你一套完整的解决方案：

要复用客户端，关键是在整个程序生命周期里维护一个有效的客户端句柄，同时跟踪它的连接状态，不要每次发布都从头创建。

1. 用静态变量保存客户端句柄和状态 #

可以在发布函数（或单独的初始化模块）里用静态变量保存MQTTClient句柄和连接状态标志，这样每次调用发布函数时，都能复用之前创建的客户端：

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include "MQTTClient.h"

#define ADDRESS     "tcp://mqtt.example.com:1883"
#define CLIENTID    "BatchPublishClient"
#define TOPIC       "test/batch"
#define QOS         1
#define TIMEOUT     10000L

// 静态变量，跨函数调用保留客户端状态
static MQTTClient client = NULL;
static int is_client_connected = 0;

int mqtt_batch_publish(const char* payload) {
    MQTTClient_message pubmsg = MQTTClient_message_initializer;
    MQTTClient_deliveryToken token;
    int rc;

    // 第一步：检查客户端是否已初始化
    if (client == NULL) {
        // 创建客户端实例
        rc = MQTTClient_create(&client, ADDRESS, CLIENTID,
            MQTTCLIENT_PERSISTENCE_NONE, NULL);
        if (rc != MQTTCLIENT_SUCCESS) {
            printf("创建客户端失败，错误码：%d\n", rc);
            return rc;
        }

        // 配置连接参数
        MQTTClient_connectOptions conn_opts = MQTTClient_connectOptions_initializer;
        conn_opts.keepAliveInterval = 20;
        conn_opts.cleansession = 1;

        // 建立连接
        rc = MQTTClient_connect(client, &conn_opts);
        if (rc != MQTTCLIENT_SUCCESS) {
            printf("连接MQTT服务器失败，错误码：%d\n", rc);
            MQTTClient_destroy(&client);
            client = NULL;
            return rc;
        }
        is_client_connected = 1;
        printf("客户端连接成功\n");
    }
    // 第二步：检查连接有效性，断开则尝试重连
    else if (!is_client_connected) {
        MQTTClient_connectOptions conn_opts = MQTTClient_connectOptions_initializer;
        conn_opts.keepAliveInterval = 20;
        conn_opts.cleansession = 1;

        rc = MQTTClient_connect(client, &conn_opts);
        if (rc != MQTTCLIENT_SUCCESS) {
            printf("重连失败，错误码：%d\n", rc);
            return rc;
        }
        is_client_connected = 1;
        printf("客户端重连成功\n");
    }

    // 第三步：执行消息发布
    pubmsg.payload = (void*)payload;
    pubmsg.payloadlen = strlen(payload);
    pubmsg.qos = QOS;
    pubmsg.retained = 0;
    rc = MQTTClient_publishMessage(client, TOPIC, &pubmsg, &token);
    if (rc != MQTTCLIENT_SUCCESS) {
        printf("发布消息失败，错误码：%d\n", rc);
        // 发布失败标记连接失效，下次调用自动尝试重连
        is_client_connected = 0;
        return rc;
    }

    printf("等待消息投递完成（超时%d秒）...\n", (int)(TIMEOUT/1000));
    rc = MQTTClient_waitForCompletion(client, token, TIMEOUT);
    printf("消息投递完成，投递令牌：%d\n", token);

    return rc;
}

// 程序退出前务必调用，清理客户端资源
void mqtt_client_cleanup() {
    if (client != NULL) {
        MQTTClient_disconnect(client, 10000);
        MQTTClient_destroy(&client);
        client = NULL;
        is_client_connected = 0;
        printf("客户端资源已清理\n");
    }
}

2. 为什么之前的MQTTClient_isConnected()会崩？ #

官方文档其实隐含了一个前提：调用MQTTClient_isConnected()时，传入的client必须是已经通过MQTTClient_create()创建成功的有效句柄。如果client是NULL，或者已经被MQTTClient_destroy()销毁，调用这个函数就会访问非法内存，直接触发段错误。

正确的检查顺序应该是：

• 先判断client是否为NULL（是否已初始化）
• 如果不为NULL，再调用MQTTClient_isConnected()检查连接状态
• 结合自己维护的is_client_connected标志（网络波动可能导致连接断开，但客户端句柄仍有效）

比如可以把连接检查部分改成：

else {
    // 先确保句柄有效，再检查连接状态
    if (MQTTClient_isConnected(client)) {
        is_client_connected = 1;
    } else {
        is_client_connected = 0;
        // 执行重连逻辑...
    }
}

3. 额外注意事项 #

• 线程安全：如果发布函数会被多线程调用，记得给客户端操作加互斥锁，避免多线程同时操作导致的竞态问题。
• 重连策略优化：可以根据实际需求增加重连次数限制、指数退避等待时间，避免频繁重连给服务器带来压力。
• 资源泄漏防范：在程序退出或不再需要MQTT服务时，一定要调用mqtt_client_cleanup()断开连接并销毁客户端，释放资源。

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