芯祥联自研 MQTT 协议栈
Broker + Client 一体化产品解决方案

// 引入 MQTT Client SDK 头文件
#include "mqtt_client_sdk.h"
#include <string.h>

// 订阅消息回调（收到消息即触发）
void on_msg(const MqttSdkMsg* msg) {
    printf("主题[%s] 内容[%.*s]\n", msg->topic,
           (int)msg->payload_len, (const char*)msg->payload);
}

int main() {
    MqttSdkClientCfg cfg;
    MqttSdkClient   h;

    // 1. 全局初始化（整个程序仅 1 次）
    xxl_mqtt_sdk_global_init();

    // 2. 创建客户端：仅 3 个必填项，其余全默认
    memset(&cfg, 0, sizeof(cfg));
    cfg.client_id   = "gw_001";
    cfg.broker_ip   = "192.168.1.100";
    cfg.broker_port = 1883;
    h = xxl_mqtt_sdk_client_create(&cfg, on_msg, NULL);

    // 3. 连接 Broker
    xxl_mqtt_sdk_client_connect(h);

    // 4. 订阅主题（QoS1） + 发布消息
    xxl_mqtt_sdk_client_subscribe(h, "device/data", MQTT_SDK_QOS1, NULL);
    MqttSdkMsg msg = {"device/data", (const uint8_t*)"hello",
                          5, MQTT_SDK_QOS1, 0, 0};
    xxl_mqtt_sdk_client_publish(h, &msg);

    // 5. 主循环周期轮询（10~50ms）：收包/回调/心跳/断线重连
    while (1) {
        xxl_mqtt_sdk_client_loop(h);
        usleep(50 * 1000);
    }
}

// 引入 MQTT Broker SDK 头文件
#include "mqtt_broker_sdk.h"
#include <string.h>
#include <unistd.h>

// 认证回调：校验用户名 / 密码
bool auth_cb(broker_handle_t h, const char* cid,
               const char* user, const char* pwd) {
    return (user && pwd && strcmp(user, "admin") == 0
            && strcmp(pwd, "123456") == 0);
}

// 事件回调：上线 / 下线 / 发布 / 订阅 / 遗嘱（JSON 数据）
void event_cb(broker_handle_t h, BrokerEventType type, const char* json) {
    printf("事件[%d] %s\n", type, json);
}

int main() {
    // 1. 创建 Broker 实例（支持多实例）
    broker_handle_t h = xxl_sdk_mqtt_broker_create();

    // 2. 注册认证与事件回调
    xxl_sdk_mqtt_broker_register_auth_callback(h, auth_cb);
    xxl_sdk_mqtt_broker_register_event_callback(h, event_cb);

    // 3. 初始化并启动：端口 1883，最大 5000 连接
    xxl_sdk_mqtt_broker_init(h);
    xxl_sdk_mqtt_broker_start(h, 1883, 5000);

    // 4. 7×24 运行（可另开线程调用 get_stats / kick 等管理接口）
    while (1) sleep(1);

    xxl_sdk_mqtt_broker_stop(h);
    xxl_sdk_mqtt_broker_deinit(h);
    xxl_sdk_mqtt_broker_destroy(h);
    return 0;
}