Toggle navigation
首页
问答
文章
积分商城
专家
专区
更多专区...
文档中心
返回主站
搜索
提问
会员
中心
登录
注册
MQTT
onenet
5
MQTT 在“ read 0:1, break “后断开重连
发布于 2020-09-02 14:19:03 浏览:2704
订阅该版
MQTT 在 访问时一段时间会出现“ read 0:1, break ”会断开连接一次,重连可正常发送一段 试过onenet的样例,也试过和通讯猫的通讯,都一段时间后会出现这个提示,后断开重连。 ``` msh />onenet_upload_cycle [D/onenet.sample] buffer : {"temperature":8} msh />[D/onenet.sample] buffer : {"temperature":52} [D/onenet.sample] buffer : {"temperature":56} [D/onenet.sample] buffer : {"temperature":56} [D/onenet.sample] buffer : {"temperature":19} [D/onenet.sample] buffer : {"temperature":11} [D/onenet.sample] buffer : {"temperature":51} **[D/mqtt] net_read 0:1, break!** [D/onenet.mqtt] Enter mqtt_offline_callback! [E/onenet.mqtt] onenet publish failed (-1)! [E/onenet.sample] upload has an error, stop uploading [D/mqtt] restart! [D/onenet.mqtt] Enter mqtt_connect_callback! [D/mqtt] ipv4 address port: 6002 [D/mqtt] HOST = '183.230.40.39' [I/mqtt] MQTT server connect success. [D/onenet.mqtt] Enter mqtt_online_callback! **[D/mqtt] net_read 0:1, break!** [D/onenet.mqtt] Enter mqtt_offline_callback! [D/mqtt] restart! [D/onenet.mqtt] Enter mqtt_connect_callback! [D/mqtt] ipv4 address port: 6002 [D/mqtt] HOST = '183.230.40.39' [I/mqtt] MQTT server connect success. [D/onenet.mqtt] Enter mqtt_online_callback! ```
查看更多
6
个回答
默认排序
按发布时间排序
ashysage
2020-09-02
这家伙很懒,什么也没写!
补充遇到问题的代码段,MQTT的部分代码: ```c static int net_read(MQTTClient *c, unsigned char *buf, int len, int timeout) { int bytes = 0; int rc; while (bytes < len) { #ifdef MQTT_USING_TLS if (c->tls_session) { rc = mbedtls_client_read(c->tls_session, &buf[bytes], (size_t)(len - bytes)); if (rc <= 0) { bytes = -1; break; } else { bytes += rc; } goto _continue; } #endif rc = recv(c->sock, &buf[bytes], (size_t)(len - bytes), MSG_DONTWAIT); if (rc == -1) { if (errno != ENOTCONN && errno != ECONNRESET) { bytes = -1; break; } } else bytes += rc; #ifdef MQTT_USING_TLS _continue: #endif if (bytes >= len) { break; } if (timeout > 0) { fd_set readset; struct timeval interval; LOG_D("net_read %d:%d, timeout:%d", bytes, len, timeout); timeout = 0; interval.tv_sec = 1; interval.tv_usec = 0; FD_ZERO(&readset); FD_SET(c->sock, &readset); select(c->sock + 1, &readset, RT_NULL, RT_NULL, &interval); } else { LOG_D("net_read %d:%d, break!", bytes, len); break; } } return bytes; } ``` 后面这里的 的timeout=0会不会是问题啊 ```c static int MQTTPacket_readPacket(MQTTClient *c) { int rc = PAHO_FAILURE; MQTTHeader header = {0}; int len = 0; int rem_len = 0; /* 1. read the header byte. This has the packet type in it */ if (net_read(c, c->readbuf, 1, 0) != 1) goto exit; ```
Polarbear
2020-09-14
这家伙很懒,什么也没写!
我才用多个节点的时候会不断地报出这个信息,导致mqtt一直发送,是怎么回事?**[D/mqtt] net_read 0:1, break!**
smratton
2021-03-13
这家伙很懒,什么也没写!
可能是你有多台有相同客户端ID的设备和MQTT和服务端连接了,你断开,只剩一台开还会不会
Game7
2021-12-10
不断学习中
查看下发布和订阅后的Topic是否有问题,以及上线回调都做了什么。
疯狂的小车
2023-03-20
这家伙很懒,什么也没写!
这个问题我已经通过修改官方包的方式解决,可以私聊我。
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时,上述内容同样适用。
撰写答案
登录
注册新账号
关注者
2
被浏览
2.7k
关于作者
ashysage
这家伙很懒,什么也没写!
提问
8
回答
7
被采纳
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
paho_mqtt线程相关疑问
8
RT thread studio kawaii mqtt 无法连接EMQ
9
调试bc26 ,断言错误failed at rt_thread_timeout
10
paho-mqtt软件包运行时出现总线错误strlen
推荐文章
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项目助手v0.2.0 - 支持Env Windows
2
RttreadV5.10上,GD32F450Z RTC时间显示问题
3
rt-smart启动流程分析
4
EtherKit快速上手PROFINET
5
RTThread USB转串口无法接收数据
热门标签
RT-Thread Studio
串口
Env
LWIP
SPI
AT
Bootloader
Hardfault
CAN总线
FinSH
ART-Pi
USB
DMA
文件系统
RT-Thread
SCons
RT-Thread Nano
线程
MQTT
STM32
RTC
FAL
rt-smart
ESP8266
I2C_IIC
UART
WIZnet_W5500
ota在线升级
PWM
cubemx
flash
freemodbus
BSP
packages_软件包
潘多拉开发板_Pandora
定时器
ADC
flashDB
GD32
socket
编译报错
中断
Debug
rt_mq_消息队列_msg_queue
SFUD
msh
keil_MDK
ulog
MicroPython
C++_cpp
本月问答贡献
出出啊
1517
个答案
342
次被采纳
小小李sunny
1444
个答案
290
次被采纳
张世争
813
个答案
177
次被采纳
crystal266
547
个答案
161
次被采纳
whj467467222
1222
个答案
149
次被采纳
本月文章贡献
出出啊
1
篇文章
2
次点赞
小小李sunny
1
篇文章
1
次点赞
张世争
1
篇文章
3
次点赞
crystal266
2
篇文章
2
次点赞
whj467467222
2
篇文章
2
次点赞
回到
顶部
发布
问题
分享
好友
手机
浏览
扫码手机浏览
投诉
建议
回到
底部