paho.mqtt.c断线重连

paho.mqtt.c是一个MQTT客户端库，用于在C语言中实现MQTT通信。断线重连是指在MQTT连接断开后，客户端自动重新连接到MQTT代理服务器的过程。

在paho.mqtt.c中，可以通过设置一些参数来实现断线重连功能。以下是一种常见的实现方式：

1. 设置断线重连的间隔时间：可以使用`MQTTClient_setReconnectInterval`函数设置断线重连的间隔时间，单位为毫秒。例如，设置为5000表示每隔5秒尝试重新连接一次。

2. 设置断线重连的最大次数：可以使用`MQTTClient_setMaxReconnectAttempts`函数设置断线重连的最大次数。例如，设置为-1表示无限次尝试重新连接。

3. 实现断线重连的回调函数：可以使用`MQTTClient_setCallbacks`函数设置一个回调函数，在连接断开时触发。在回调函数中，可以编写逻辑来处理断线重连的操作。例如，可以在回调函数中调用`MQTTClient_connect`函数重新连接到MQTT代理服务器。

下面是一个示例代码片段，演示了如何使用paho.mqtt.c实现断线重连功能：

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

#define ADDRESS     "tcp://mqtt.eclipse.org:1883"
#define CLIENTID    "ExampleClientSub"
#define TOPIC       "example/topic"
#define QOS         1
#define TIMEOUT     10000L

volatile MQTTClient_deliveryToken deliveredtoken;

int msgarrvd(void *context, char *topicName, int topicLen, MQTTClient_message *message) {
    // 处理接收到的消息
    printf("Message arrived\n");
    printf("  topic: %s\n", topicName);
    printf("  message: ");
    fwrite(message->payload, 1, message->payloadlen, stdout);
    printf("\n");
    MQTTClient_freeMessage(&message);
    MQTTClient_free(topicName);
    return 1;
}

void connlost(void *context, char *cause) {
    // 处理连接断开事件
    printf("\nConnection lost\n");
    printf("  cause: %s\n", cause);
}

int main(int argc, char* argv[]) {
    MQTTClient client;
    MQTTClient_connectOptions conn_opts = MQTTClient_connectOptions_initializer;
    int rc;

    MQTTClient_create(&client, ADDRESS, CLIENTID, MQTTCLIENT_PERSISTENCE_NONE, NULL);
    conn_opts.keepAliveInterval = 20;
    conn_opts.cleansession = 1;

    // 设置断线重连的回调函数
    MQTTClient_setCallbacks(client, NULL, connlost, msgarrvd, delivered);

    while ((rc = MQTTClient_connect(client, &conn_opts)) != MQTTCLIENT_SUCCESS) {
        printf("Failed to connect, return code %d\n", rc);
        // 等待一段时间后尝试重新连接
        usleep(5000000L); // 5秒
    }

    printf("Connected\n");

    // 订阅主题
    MQTTClient_subscribe(client, TOPIC, QOS);

    // 持续监听消息
    while (1) {
        // ...
    }

    MQTTClient_disconnect(client, 10000);
    MQTTClient_destroy(&client);
    return rc;
}

在上述示例代码中，当连接断开时，`connlost`函数会被调用，可以在该函数中实现断线重连的逻辑。在示例中，使用了一个简单的循环来尝试重新连接，每次等待5秒后再次尝试连接。