STM32H7板子RTT上Mqtt连接OneNet云发数据失败

发布于 2023-10-11 21:50:36 浏览：786 订阅该版

1. 在mqtt start函数中配置如下

```c
int mqtt_start(void)
{
    /* init condata param by using MQTTPacket_connectData_initializer */
    MQTTPacket_connectData condata = MQTTPacket_connectData_initializer;

if (is_started)
    {
        DEBUG_PRINT("mqtt client is already connected.");
        return -1;
    }
    /* config MQTT context param */
    {
        client.isconnected = 0;
        client.uri = MQTT_SERVER_URI;

/* generate the random client ID */
        /* config connect param */
        rt_memcpy(&client.condata, &condata, sizeof(condata));
        client.condata.clientID.cstring = MQTT_CLIENTID;
        client.condata.keepAliveInterval = 60;
        client.condata.cleansession = 1;

client.condata.username.cstring = MQTT_USERNAME;
        client.condata.password.cstring = MQTT_PASSWORD;

/* config MQTT will param. */
        client.condata.willFlag = 0;
//        client.condata.will.qos = 1;
//        client.condata.will.retained = 0;
//        client.condata.will.topicName.cstring = MQTT_PUBTOPIC;
//        client.condata.will.message.cstring = MQTT_WILLMSG;

/* rt_malloc buffer. */
        client.buf_size = client.readbuf_size = 1024 * 2;
        client.buf = rt_calloc(1, client.buf_size);
        client.readbuf = rt_calloc(1, client.readbuf_size);
        if (!(client.buf && client.readbuf))
        {
            DEBUG_PRINT("no memory for MQTT client buffer!");
            return -1;
        }

/* set event callback function */
        client.connect_callback = mqtt_connect_callback;
        client.online_callback = mqtt_online_callback;
        client.offline_callback = mqtt_offline_callback;

/* set subscribe table and event callback */
        client.messageHandlers[0].topicFilter = rt_strdup(MQTT_SUBTOPIC);
        client.messageHandlers[0].callback = mqtt_sub_callback;
        client.messageHandlers[0].qos = QOS1;

/* set default subscribe event callback */
        client.defaultMessageHandler = mqtt_sub_default_callback;
    }

/* run mqtt client */
    paho_mqtt_start(&client);
    is_started = 1;

mapp_mqtt_subscribe();

return 0;
}
```
其中
```c
#define MQTT_SERVER_URI                 "tcp://mqtts.heclouds.com:1883"
//#define MQTT_SERVER_URI                 "tcp://183.230.40.96:1883"

#define MQTT_CLIENTID                   "mCtrl_Device"
#define MQTT_USERNAME                   "q03px7K8O9"
#define MQTT_PASSWORD                   "version=2018-10-31&res=products%2Fq03px7K8O9%2Fdevices%2FmCtrl_Device&et=1924833600&method=md5&sign=j2Nrp%2FoZSqHQAR%2F%2FlZ5lQw%3D%3D"
#define MQTT_SUBTOPIC                   "$sys/q03px7K8O9/mCtrl_Device/thing/property/set"
//#define MQTT_PUBTOPIC                 "$sys/q03px7K8O9/mCtrl_Device/thing/property/set_reply"
#define MQTT_PUBTOPIC                   "$sys/q03px7K8O9/mCtrl_Device/thing/property/post"

#define MQTT_WILLMSG                    "Willexit"
```

设备start后没啥问题，后台也显示在线
![screenshot_image.png](https://oss-club.rt-thread.org/uploads/20231011/a0ca01bd3d7207839d62ccc1f60b47cd.png)

![screenshot_image.png](https://oss-club.rt-thread.org/uploads/20231011/b42acb8c48bd75b4d6fd1cc4a0b67caa.png.webp)

而且订阅的消息也是可以收到：
![screenshot_image.png](https://oss-club.rt-thread.org/uploads/20231011/70b820c95b64117d02e9316164259d08.png)

一发数据就会掉线，数据发不上去：

![screenshot_image.png](https://oss-club.rt-thread.org/uploads/20231011/042923e384647ebe120612a01f5eaeb4.png)

打印上显示这里直接跳出去了
![screenshot_image.png](https://oss-club.rt-thread.org/uploads/20231011/94e3cd4b13aaebf726240546f13d50a4.png)