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

int main() {
    // MQTT 连接参数
    char *host = "127.0.0.1";
    int port = 1883;
    char *clientID = "C  Client";
    char *topic = "my/test/topic";

    // MQTT 连接
    MQTTClient client;
    MQTTClient_connectOptions connOpts = MQTTClient_connectOptions_initializer;
    connOpts.keepAliveInterval = 60;
    connOpts.cleansession = 1;

    int rc = MQTTClient_create(&client, host, clientID, MQTTCLIENT_PERSISTENCE_NONE, NULL);
    if (rc != MQTTCLIENT_SUCCESS) {
        printf("MQTTClient_create() 失败: %d\n", rc);
        return -1;
    }

    rc = MQTTClient_connect(client, &connOpts);
    if (rc != MQTTCLIENT_SUCCESS) {
        printf("MQTTClient_connect() 失败: %d\n", rc);
        return -1;
    }

    // 发布消息
    const char *msg = "Hello from C  !";
    rc = MQTTClient_publish(client, topic, strlen(msg), (void *) msg, 1, 1);
    if (rc != MQTTCLIENT_SUCCESS) {
        printf("MQTTClient_publish() 失败: %d\n", rc);
        return -1;
    }

    // 关闭连接
    rc = MQTTClient_disconnect(client, 10000);
    if (rc != MQTTCLIENT_SUCCESS) {
        printf("MQTTClient_disconnect() 失败: %d\n", rc);
        return -1;
    }

    MQTTClient_destroy(&client);

    return 0;
}