10 onenet云平台下发消息怎么回复

发布于 2024-03-31 23:01:35 浏览：485 订阅该版

我现在使用 onenet软件包订阅了设备属性设置，能接受到平台下发消息，但没有恢复平台，平台那边显示超时，我该怎么才能回复平台
mqtt_sub_callback1会打印接收到平台下发的设置设备属性，但没有回复，我改怎么回复

```c
static void mqtt_sub_callback(MQTTClient *c, MessageData *msg_data)
{
    *((char *)msg_data->message->payload + msg_data->message->payloadlen) = '\0';
    LOG_D("mqtt sub callback: %.*s %.*s",
               msg_data->topicName->lenstring.len,
               msg_data->topicName->lenstring.data,
               msg_data->message->payloadlen,
               (char *)msg_data->message->payload);
}
static void mqtt_sub_callback1(MQTTClient *c, MessageData *msg_data)
{
    *((char *)msg_data->message->payload + msg_data->message->payloadlen) = '\0';
    LOG_D("mqtt sub callback: %.*s %.*s",
               msg_data->topicName->lenstring.len,
               msg_data->topicName->lenstring.data,
               msg_data->message->payloadlen,
               (char *)msg_data->message->payload);
}
static rt_err_t onenet_mqtt_entry(void)
{
    MQTTPacket_connectData condata = MQTTPacket_connectData_initializer;

mq_client.uri = onenet_info.server_uri;
    memcpy(&(mq_client.condata), &condata, sizeof(condata));
    mq_client.condata.clientID.cstring = onenet_info.device_id;
    mq_client.condata.keepAliveInterval = 30;
    mq_client.condata.cleansession = 1;
    mq_client.condata.username.cstring = onenet_info.pro_id;
    mq_client.condata.password.cstring = onenet_info.auth_info;

mq_client.buf_size = mq_client.readbuf_size = 1024 * 2;
    mq_client.buf = (unsigned char *) ONENET_CALLOC(1, mq_client.buf_size);
    mq_client.readbuf = (unsigned char *) ONENET_CALLOC(1, mq_client.readbuf_size);
    if (!(mq_client.buf && mq_client.readbuf))
    {
        LOG_E("No memory for MQTT client buffer!");
        return -RT_ENOMEM;
    }

/* registered callback */
    mq_client.connect_callback = mqtt_connect_callback;
    mq_client.online_callback = mqtt_online_callback;
    mq_client.offline_callback = mqtt_offline_callback;
    mq_client.messageHandlers[0].topicFilter = rt_strdup(ONENET_MQTT_SUBTOPIC);
    mq_client.messageHandlers[0].qos = QOS1;
    mq_client.messageHandlers[0].callback = mqtt_sub_callback;
    mq_client.messageHandlers[1].topicFilter = rt_strdup(ONENET_MQTT_SUBTOPIC1);
    mq_client.messageHandlers[1].qos = QOS1;
    mq_client.messageHandlers[1].callback = mqtt_sub_callback1;
//    mq_client.defaultMessageHandler = mqtt_callback;

paho_mqtt_start(&mq_client);

return RT_EOK;
}
```

![screenshot_image.png](https://oss-club.rt-thread.org/uploads/20240401/13adc0df88018bbe806ca50408d7870a.png)