mqtt客户端连接服务器的C语言代码实现

下面是一个简单的MQTT客户端连接服务器的C语言代码实现：

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

int main(int argc, char *argv[])
{
    struct mosquitto *mosq = NULL;
    int rc = 0;

    // 初始化库
    mosquitto_lib_init();

    // 创建mosquitto实例
    mosq = mosquitto_new(NULL, true, NULL);
    if(!mosq){
        fprintf(stderr, "Error: Out of memory.\n");
        return 1;
    }

    // 连接到MQTT服务器
    rc = mosquitto_connect(mosq, "localhost", 1883, 60);
    if(rc != MOSQ_ERR_SUCCESS){
        fprintf(stderr, "Error: Could not connect to MQTT server %s\n", mosquitto_strerror(rc));
        mosquitto_destroy(mosq);
        return 1;
    }

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

    // 等待消息
    mosquitto_loop_forever(mosq, -1, 1);

    // 断开连接并清理
    mosquitto_destroy(mosq);
    mosquitto_lib_cleanup();

    return 0;
}

以上代码实现了连接到本地MQTT服务器，并订阅了一个主题。其中mosquitto_connect()函数用于连接到MQTT服务器，mosquitto_subscribe()函数用于订阅主题，mosquitto_loop_forever()函数用于等待消息。当有消息到达时，程序将打印出消息内容。需要注意的是，在使用完mosquitto实例后，必须调用mosquitto_destroy()函数来释放资源。