在paho.mqtt.c 中 设置 版本 3_1_1 例子

在Paho MQTT C库中，设置版本3.1.1通常是在初始化连接之前进行的，因为这涉及到库的配置。以下是一个简单的示例：

#include <stdio.h>
#include <stdlib.h>
#include "paho-mqtt3.c"

#define MQTT_VERSION "3.1.1"
#define MQTT_BROKER "your_mqtt_broker_address"
#define MQTT_PORT 1883
#define CLIENT_ID "your_client_id"

MQTTClient client;

void on_connect(void *client_ptr, MQTTConnectReturnCode connect_return_code, int session present, void *userdata) {
    if (connect_return_code == MQTT_CONNECTION_SUCCESS) {
        printf("Connected to broker with version %s\n", MQTT_VERSION);
    } else {
        printf("Failed to connect: %d\n", connect_return_code);
    }
}

int main() {
    mqtt_init(NULL, NULL);

    // Set the MQTT version for Paho client
    mqtt_set_protocol_version(client, MQTT_VERSION);

    client = mqtt_new();
    if (!client) {
        fprintf(stderr, "mqtt_new() failed\n");
        return -1;
    }

    mqtt_set_on_connect(&client, on_connect, NULL); // Callback function for connection events

    mqtt_username_pw_set(client, NULL, NULL); // If no username or password is needed, use this
    mqtt_connection_set_option(client, MQTT_OPT_MQTT_VERSION, MQTT_VERSION);

    mqtt_connect(client, MQTT_BROKER, MQTT_PORT, NULL, 0);

    // Your application logic goes here...
    
    mqtt_destroy(client); // Clean up when done
    mqtt_cleanup();

    return 0;
}

在这个例子中，我们首先包含了必要的头文件，然后初始化了Paho库，并设置了期望的MQTT版本。在`mqtt_new()`创建客户端后，我们将这个版本应用到连接选项中。当连接成功时，on_connect回调函数会被触发并打印出已连接的协议版本。