Toggle navigation
首页
问答
文章
积分商城
专家
专区
更多专区...
文档中心
返回主站
搜索
提问
会员
中心
登录
注册
MQTT
net_read 0:1, break! 这个问题是怎么解决得?
发布于 2023-10-23 10:05:14 浏览:331
订阅该版
``` [D/mqtt] net_read 0:1, break! [D/mqtt.sample] inter mqtt_offline_callback! [D/mqtt] restart! [D/mqtt.sample] inter mqtt_connect_callback! [D/mqtt] ipv4 address port: 15319 [D/mqtt] HOST = 'mcff8d08.cn-shenzhen.emqx.cloud' [I/mqtt] MQTT server connect success. [I/mqtt] Subscribe #0 8651370662548705_recv OK! [D/mqtt.sample] inter mqtt_online_callback! ```
查看更多
2
个回答
默认排序
按发布时间排序
lx1024
2024-02-29
这家伙很懒,什么也没写!
![Mqtt Publish Error.jpg](https://oss-club.rt-thread.org/uploads/20240229/36c1a296da88562c1e01f13e0865bd07.jpg.webp) Mosquitto Broker收到Puslish Message报文后,其Message Identifier为0时,Broker会断开TCP连接。 Mosquitto Broker日志: ``` 1709176157: Sending SUBACK to abcd1234 1709176158: Client abcd1234 disconnected due to protocol error. ``` ```c typedef struct MQTTMessage { enum QoS qos; unsigned char retained; unsigned char dup; unsigned short id; void *payload; size_t payloadlen; } MQTTMessage; ``` 没有找到设置MQTTMessage结构体中id的语句,在paho_mqtt_publish函数中添加了id自增语句测试后,能正常发布消息,且不会再断开TCP。 ```c int paho_mqtt_publish(MQTTClient *client, enum QoS qos, const char *topic, const char *msg_str) { static unsigned short id = 0; MQTTMessage message = {0}; if (qos != QOS1) { LOG_E("Not support Qos(%d) config, only support Qos(d).", qos, QOS1); return PAHO_FAILURE; } if (++id == 0) { ++id; } message.qos = qos; message.retained = 0; message.id = id; message.payload = (void *)msg_str; message.payloadlen = rt_strlen(message.payload); if (client->isblocking && client->pub_sem) { if(rt_sem_take(client->pub_sem, 5 * RT_TICK_PER_SECOND) < 0) { return PAHO_FAILURE; } } return MQTTPublish(client, topic, &message); } ``` 在 https://mqtt.p2hp.com/mqtt311 2.3.1 包唯一标识中找到关闭唯一标识的描述: SUBSCRIBE,UNSUBSCRIBE,PUBLISH(QoS > 0 的时候)控制包必须包含**非零**的唯一标识[MQTT-2.3.1-1]。每次客户端发送上述控制包的时候,必须分配一个未使用过的唯一标识[MQTT-2.3.1-2]。如果一个客户端重新发送一个特别的控制包,必须使用相同的唯一标识符。唯一标识会在客户端收到相应的确认包之后变为可用。例如PUBLIST在QoS1的时候对应PUBACK;在QoS2时对应PUBCOMP。对于SUBSCRIBE和UNSUBSCRIBE对应SUBACK和UNSUBACK[MQTT-2.3.1-3]。服务端发送QoS>0的PUBLISH时,上述内容同样适用。
重头来过
2024-08-22
这家伙很懒,什么也没写!
![1.png](https://oss-club.rt-thread.org/uploads/20240822/c412157b199294aa488ab6045f6f6828.png) --- ![2.png](https://oss-club.rt-thread.org/uploads/20240822/e69e867d285c119bf2526a037af5de4a.png) Message Identifier 这个字段没有见着啊 在哪设置
撰写答案
登录
注册新账号
关注者
0
被浏览
331
关于作者
重头来过
这家伙很懒,什么也没写!
提问
1
回答
3
被采纳
0
关注TA
发私信
相关问题
1
umqtt 软件包使用后,连接上emqx服务器,过一会儿就掉线了
2
使用正点原子的 潘多拉 开发板 的例程19_iot_mqtt
3
mqtt软件包,不支持直接关闭?
4
kawaii_mqtt 申请内存崩溃
5
_signal_entry() 函数中dbg_enter在哪里定义呢?
6
start to connect mqtt server 失败
7
MQTT 在“ read 0:1, break “后断开重连
8
paho_mqtt线程相关疑问
9
RT thread studio kawaii mqtt 无法连接EMQ
10
调试bc26 ,断言错误failed at rt_thread_timeout
推荐文章
1
RT-Thread应用项目汇总
2
玩转RT-Thread系列教程
3
国产MCU移植系列教程汇总,欢迎查看!
4
机器人操作系统 (ROS2) 和 RT-Thread 通信
5
五分钟玩转RT-Thread新社区
6
【技术三千问】之《玩转ART-Pi》,看这篇就够了!干货汇总
7
关于STM32H7开发板上使用SDIO接口驱动SD卡挂载文件系统的问题总结
8
STM32的“GPU”——DMA2D实例详解
9
RT-Thread隐藏的宝藏之completion
10
【ART-PI】RT-Thread 开启RTC 与 Alarm组件
最新文章
1
【RT-Thread】记录一次对主仓的bsp进行修复并提交pr的总结
2
【请投票】嵌入式大赛Top10排名等你来选!
3
【24嵌入式设计大赛】HPM5300-EVK 网络测速仪
4
RT-Thread Nano 上线ST CubeMX
5
Nordic移植笔记: RT_Thread v5.1.0(基于Nordic nRF52840的ble_app_hids_mouse工程)
热门标签
RT-Thread Studio
串口
Env
LWIP
SPI
AT
Bootloader
Hardfault
CAN总线
ART-Pi
FinSH
USB
DMA
文件系统
RT-Thread
SCons
RT-Thread Nano
线程
MQTT
STM32
RTC
rt-smart
FAL
ESP8266
I2C_IIC
WIZnet_W5500
ota在线升级
UART
flash
packages_软件包
cubemx
PWM
freemodbus
BSP
潘多拉开发板_Pandora
定时器
ADC
GD32
socket
flashDB
中断
Debug
编译报错
msh
rt_mq_消息队列_msg_queue
keil_MDK
C++_cpp
ulog
at_device
SFUD
本月问答贡献
出出啊
1515
个答案
342
次被采纳
小小李sunny
1438
个答案
289
次被采纳
张世争
786
个答案
168
次被采纳
crystal266
546
个答案
161
次被采纳
whj467467222
1222
个答案
148
次被采纳
本月文章贡献
出出啊
1
篇文章
6
次点赞
小小李sunny
1
篇文章
1
次点赞
张世争
1
篇文章
2
次点赞
crystal266
2
篇文章
1
次点赞
whj467467222
2
篇文章
1
次点赞
回到
顶部
发布
问题
分享
好友
手机
浏览
扫码手机浏览
投诉
建议
回到
底部