paho mqtt c断线从连接

好的，下面是使用 paho mqtt c 实现断线重连的代码示例：

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

#define ADDRESS     "tcp://localhost:1883"
#define CLIENTID    "ExampleClientSub"
#define TOPIC       "test/topic"
#define QOS         1
#define TIMEOUT     10000L

volatile MQTTClient_deliveryToken deliveredtoken;

void delivered(void *context, MQTTClient_deliveryToken dt) {
    printf("Message with token value %d delivery confirmed\n", dt);
    deliveredtoken = dt;
}

int msgarrvd(void *context, char *topicName, int topicLen, MQTTClient_message *message) {
    printf("Message arrived\n");
    printf("  topic: %s\n", topicName);
    printf("  message: %.*s\n", message->payloadlen, (char*) message->payload);
    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;

    while ((rc = MQTTClient_connect(client, &conn_opts)) != MQTTCLIENT_SUCCESS) {
        printf("Failed to connect, return code %d\n", rc);
        sleep(1);
    }

    printf("Connected\n");

    MQTTClient_setCallbacks(client, NULL, connlost, msgarrvd, delivered);

    MQTTClient_subscribe(client, TOPIC, QOS);

    while (1) {
        sleep(1);
    }

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

在代码中，我们首先定义了需要用到的一些宏和变量。其中 `ADDRESS` 是 MQTT 服务器的地址和端口，`CLIENTID` 是客户端的 ID，`TOPIC` 是订阅的主题，`QOS` 是订阅的 QoS 级别，`TIMEOUT` 是超时时间。

然后我们定义了 `delivered`、`msgarrvd` 和 `connlost` 三个回调函数，并在主函数中将它们绑定到了 `client` 上。

在主函数中，我们首先创建了一个 MQTT 客户端 `client`，然后设置了连接参数 `conn_opts`。接着我们使用一个 `while` 循环不断尝试连接 MQTT 服务器，直到连接成功为止。在连接成功后，我们打印出 `Connected`，然后使用 `MQTTClient_setCallbacks` 函数将回调函数绑定到 `client` 上。

接下来，我们使用 `MQTTClient_subscribe` 函数订阅了一个主题。最后我们进入一个死循环，以保持程序运行。如果程序出现异常情况导致连接断开，回调函数 `connlost` 就会被调用，并在函数中进行重连操作。

在程序结束前，我们使用 `MQTTClient_disconnect` 函数断开连接，然后使用 `MQTTClient_destroy` 函数销毁客户端。