请教MQTT发布乱码问题

发布于 2022-11-24 16:45:29 浏览：895 订阅该版

大神们帮我看下，这两段代码有什么问题？

以下代码输出正常

static int mqtt_publish_handle1(mqtt_client_t *client)
{
    mqtt_message_t msg;
    memset(&msg, 0, sizeof(msg));
    msg.qos = 0;
    msg.payload = (void *) "123456";
    return mqtt_publish(client, "x", &msg);  //发布主题
}

以下代码输出乱码

static int mqtt_publish_handle1(mqtt_client_t *client)
{
    int load;
    cpu_usage_init();
    load = cpu_load_average();
    mqtt_message_t msg;
    memset(&msg, 0, sizeof(msg));
    msg.qos = 0;
    msg.payload = (void *) load;
    return mqtt_publish(client, "x", &msg);  //发布主题
}

ZWH 2022-11-25

这个人很勤快，没空留下点什么

我以前发现，如果内存不够，被截断，后面就会出现乱码

ZWH 2022-11-25

这个人很勤快，没空留下点什么

但是我也不清楚和你的有没有关系，您可以参考下

r59461900 2022-11-25

这家伙很懒，什么也没写！

检测过了，内存剩余还有500K

请登录后再发布评论，点击登录

追加回复

6 个回答

xiaorui 认证专家 2022-11-24

小睿手办 https://item.taobao.com/item.htm?id=674889867009

    int load;
    msg.payload = (void *) load;
    msg.payload = (void *) "123456";

运行没崩溃已经运气很好了。

r59461900 2022-11-24

这家伙很懒，什么也没写！

？？？？？？？？？？？

请登录后再发布评论，点击登录

追加回复

lchnu 2022-11-25

Witness, Understand, Skill

具体原因，在其他楼层已经讨论很清晰了。

mqtt_publish中，会判断msg payload length，代码如下：

    if ((NULL != msg->payload) && (0 == msg->payloadlen))
        msg->payloadlen = strlen((char*)msg->payload);

你的第一段代码，即使做了(void *)的强制转换，也不会有问题。在mqtt_publish中又转回了(char *)；

你的第二段代码，将int类型的load的值，作为payload传入mqtt_publish, 该函数内部将payload当作指针处理的，具体你可以看函数MQTTSerialize_publish的处理。所以，你是从load值指向的一段内存中输出了数据，直到遇到0x00。

所以，你的代码中，为了安全起见，还是设置一下msg.payloadlen，再去调用mqtt_publish为好。此外，你对load的使用是不对的。

JonasWen 2022-11-25

这家伙不懒，但是什么也不想写！

我觉得主要是楼主没有搞清楚C语言中字符串类型和指针还有其他基本数值类型的区别。
我觉得他想问的问题可能是为什么数值load在MQTT消息中发送出来是乱码，但其实他这么操作只会传入一个不知道内容是什么的内存地址。

请登录后再发布评论，点击登录

追加回复

r59461900 2022-11-24

这家伙很懒，什么也没写！

@管理员，为什么代码标记老是有问题，是我太傻吗!

RT-Thread小师弟 2022-11-24

微信：rtthread2020

markdown的代码标签标记符是键盘字母Q上面数字1左边那个键。
如果您的输入法不好控制全半角字符的话，您可以使用复制来输入那3个markdown的代码标签标记符。
另外，网页的编辑器上面有插入代码的按钮啊🐵

r59461900 2022-11-24

这家伙很懒，什么也没写！

按三个出6个，三个编辑状态没有空格，发布出来又有！

请登录后再发布评论，点击登录

追加回复

Ryan_CW 认证专家 2022-11-25

这家伙很懒，什么也没写！

你这样进行强转，先不说有没有问题。
强转赋值给msg.payload后，你也没有告诉msg.payload的长度，软件包自动判断的话，肯定是strlen判断了。 strlen的判断标准是什么

r59461900 2022-11-25

这家伙很懒，什么也没写！

大家一堆废话，这不行，那不对，人不行，就别怪路不平，既然我的智商碾压在座各位，特奉上解决方法，以下代码已测试通过

static int mqtt_publish_handle1(mqtt_client_t *client)
{
    int load;
    char loae[20];
    cpu_usage_init();
    load = cpu_load_average();
    rt_kprintf("CPU idle=%d",load);
    sprintf(loae,"CPU idle=%d",load);
   mqtt_message_t msg;
   memset(&msg, 0, sizeof(msg));
   msg.qos = 0;
   msg.payload = (void *) loae;
   return mqtt_publish(client, "cpu", &msg);
}