FreeMQTT/demo/demo.c

#include <rtthread.h>
#include <wlan_mgnt.h>

#define DBG_TAG "MQTT"
#define DBG_LVL DBG_LOG

#include "mqtt_api.h"

void mqtt_client_start(void)
{
    rt_wlan_unregister_event_handler(RT_WLAN_EVT_READY);

    rt_thread_t tid = rt_thread_create("mqtt", mqttClientTask,
    RT_NULL, 4096, 10, 20);
    if (tid != RT_NULL)
    {
        rt_thread_startup(tid);
        MQTT_PRINT("MQTT client thread started\n");
    }
    else
    {
        MQTT_PRINT("Failed to create MQTT client thread\n");
    }
}

static int mqtt_pub(int argc, char **argv)
{
    MQTTStatus_t status;
    MQTTPublishInfo_t publishInfo;

    if (argc != 2)
    {
        rt_kprintf("Usage: mqtt_pub <message>\n");
        return -RT_ERROR;
    }

    publishInfo.qos = MQTTQoS0;
    publishInfo.pTopicName = MQTT_TOPIC_PUB;
    publishInfo.topicNameLength = strlen(MQTT_TOPIC_PUB);
    publishInfo.pPayload = argv[1];
    publishInfo.payloadLength = strlen(argv[1]);

    status = mqttPublish(&publishInfo);
    if (status != MQTTSuccess)
    {
        rt_kprintf("MQTT publish failed: %d\n", status);
        return -RT_ERROR;
    }

    rt_kprintf("Published message: %s to topic: %s\n", argv[1], MQTT_TOPIC_PUB);
    return RT_EOK;
}
#ifdef RT_USING_FINSH
MSH_CMD_EXPORT_ALIAS(mqtt_pub, mqtt_pub, Send MQTT message);
#endif

static int mqtt_sub(int argc, char **argv)
{
    MQTTStatus_t status;
    MQTTSubscribeInfo_t subscribeInfo;

    if (argc != 2)
    {
        rt_kprintf("Usage: mqtt_sub <topic>\n");
        return -RT_ERROR;
    }

    subscribeInfo.qos = MQTTQoS0;
    subscribeInfo.pTopicFilter = argv[1];
    subscribeInfo.topicFilterLength = strlen(argv[1]);

    status = mqttSubscribe(&subscribeInfo);
    if (status != MQTTSuccess)
    {
        rt_kprintf("MQTT subscribe failed: %d\n", status);
        return -RT_ERROR;
    }

    rt_kprintf("Subscribed to topic: %s\n", argv[1]);
    return RT_EOK;
}
#ifdef RT_USING_FINSH
MSH_CMD_EXPORT_ALIAS(mqtt_sub, mqtt_sub, Subscribe MQTT message);
#endif