MQTTClient client;
Network n;
MQTTClient_connectOptions opts = MQTTClient_connectOptions_initializer;
NetworkInit(&n, net_connect);
MQTTClientInit(&client, &n, 1000, buf, 256, buf2, 256);
opts.keepAliveInterval = 60; // 60s 保活
opts.cleansession = 1;
MQTTClient_connect(&client, &opts);
MQTTClient_subscribe(&client, "dev/001/cmd", QoS1);
MQTTClient_publish(&client, "dev/001/temp",
(char*)msg, strlen(msg), QoS1, 0);
// 收到 cmd 主题 → 执行控制指令