如何使用Paho MQTT进行MQTT连接？

在C语言中，Paho MQTT库是一个轻量级的客户端库，用于与MQTT（Message Queuing Telemetry Transport）服务器进行通信。以下是如何使用Paho MQTT库创建一个简单的MQTT连接的步骤：

1. 首先，你需要从Eclipse Paho官网下载并安装Paho C Client Library。链接：https://eclipse.org/paho/clients/c/

2. 包含必要的头文件：

#include "mqtt_client.h"

3. 初始化MQTT客户端：

MQTTClient client;
int result;

client = mqtt_new_instance(MQTTCLIENTashboard_log_dest, NULL);
if (client == NULL) {
    // 处理错误
}

4. 设置回调函数，这些将在连接、消息接收等事件发生时被调用：

void on_connect(mqtt_client *c, char *username, char *password, int result_code) {
    if (result_code == MQTT_SUCCESS) {
        printf("Connected to MQTT broker\n");
    } else {
        printf("Connection failed: %d\n", result_code);
    }
}

void on_message(mqtt_client *c, const struct mosquitto_message *msg) {
    printf("Received message topic: %s, payload: %.*s\n",
           msg->topic, msg->payloadlen, (char *)msg->payload);
}

// 添加其他回调函数如on_disconnect() 和 on_publish()

5. 设置连接参数（这里是一个示例，根据实际情况修改）：

const char* server_address = "your_mqtt_broker_address";
int port = 1883; // 默认MQTT端口
const char* client_id = "my_client_id";
const char* username = "your_username";
const char* password = "your_password";

struct mqtt_connection_options conn_opts = {
    .clean_session = true, // 是否清除会话，每次连接是否为新连接
    .keepalive     = 60,   // 连接心跳时间间隔（秒）
};

6. 连接到MQTT服务器：

result = mqtt_connect(client, server_address, port, &conn_opts, on_connect, NULL, NULL);
if (result != MQTT_SUCCESS) {
    // 处理错误
}

7. 发布或订阅主题：

// 发布消息到特定主题
result = mqtt_publish(client, "your_topic", "Hello, MQTT!", strlen("Hello, MQTT!"), NULL, NULL);
if (result != MQTT_SUCCESS) {
    // 处理错误
}

// 或者订阅主题
result = mqtt_subscribe(client, "your_topic", 0); // QoS 0是最简单的方式
if (result != MQTT_SUCCESS) {
    // 处理错误
}

8. 停止连接和清理资源：

// 在不需要连接时关闭并删除客户端
mqtt_destroy(&client);