C语言实现一个线程与mqtt服务器联系

要实现 C 语言的线程与 MQTT 服务器联系，你需要使用一个 MQTT 客户端库和一个线程库。这里给出一个使用 `mosquitto` 和 `pthread` 库的示例代码：

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <mosquitto.h>
#include <pthread.h>

#define MQTT_HOST "localhost"
#define MQTT_PORT 1883
#define MQTT_TOPIC "test"

void *mqtt_thread(void *arg) {
    struct mosquitto *mosq = NULL;
    int rc;

    // 初始化 mosquitto 库
    mosquitto_lib_init();

    // 创建 mosquitto 客户端对象
    mosq = mosquitto_new(NULL, true, NULL);
    if (!mosq) {
        fprintf(stderr, "Error: Out of memory.\n");
        goto cleanup;
    }

    // 连接 MQTT 服务器
    rc = mosquitto_connect(mosq, MQTT_HOST, MQTT_PORT, 0);
    if (rc != MOSQ_ERR_SUCCESS) {
        fprintf(stderr, "Error: Could not connect to MQTT broker (%s).\n", mosquitto_strerror(rc));
        goto cleanup;
    }

    // 订阅主题
    rc = mosquitto_subscribe(mosq, NULL, MQTT_TOPIC, 0);
    if (rc != MOSQ_ERR_SUCCESS) {
        fprintf(stderr, "Error: Could not subscribe to topic (%s).\n", mosquitto_strerror(rc));
        goto cleanup;
    }

    // 循环处理消息
    while (1) {
        rc = mosquitto_loop(mosq, -1, 1);
        if (rc != MOSQ_ERR_SUCCESS) {
            fprintf(stderr, "Error: mosquitto_loop failed (%s).\n", mosquitto_strerror(rc));
            goto cleanup;
        }
    }

cleanup:
    if (mosq) {
        mosquitto_destroy(mosq);
    }
    mosquitto_lib_cleanup();
    pthread_exit(NULL);
}

int main() {
    pthread_t tid;
    int rc;

    // 启动 MQTT 线程
    rc = pthread_create(&tid, NULL, mqtt_thread, NULL);
    if (rc != 0) {
        fprintf(stderr, "Error: Could not create MQTT thread.\n");
        exit(EXIT_FAILURE);
    }

    // 主线程继续执行其他任务
    while (1) {
        // do something
    }

    return 0;
}

在这个示例代码中，`mqtt_thread` 函数是一个独立的线程，它使用 `mosquitto` 库连接 MQTT 服务器，并订阅了 `test` 主题。在循环中，它使用 `mosquitto_loop` 函数处理服务器发送的消息。

在主函数中，我们使用 `pthread_create` 函数创建了一个新线程来执行 `mqtt_thread` 函数。主线程可以继续执行其他任务。

请注意，这只是一个简单的示例代码，并且可能需要根据你的具体需求进行修改。例如，你可能需要在收到特定消息时执行某些操作，或者在程序退出时安全地关闭连接。