Toggle navigation
首页
问答
文章
积分商城
专家
专区
更多专区...
文档中心
返回主站
搜索
提问
会员
中心
登录
注册
at_device
MQTT
umqtt+AT device, 如何解决socket被broker关闭的情况?
发布于 2021-04-19 04:58:48 浏览:1042
订阅该版
我最近在调umqtt和AT device, 用的是ESP8266模块。Broker用的是emqx的服务器。 在发送速度比较高的时候,过几分钟半小时broker那边会出现错误记录,错误具体内容不一样,但都是MQTT解析错误,应该是验证错误。 这种情况下,AT device 这边的socket状态会变成closed at_socket.c 文件下 ~~~ int at_sendto(int socket, const void *data, size_t size, int flags, const struct sockaddr *to, socklen_t tolen) ....... switch (sock->type) { case AT_SOCKET_TCP: if (sock->state == AT_SOCKET_CLOSED) { result = 0; //<- 会跳到这里。 goto __exit; } ~~~ 这个函数返回0,会导致umqtt的发送函数进入死循环。 umqtt_transport.c 文件内 ~~~ /** * TCP/TLS send datas on configured transport. * * @param sock the input socket * @param send_buf the input, transport datas buffer * @param buf_len the input, transport datas buffer length * @param timeout the input, tcp/tls transport timeout * * @return <0: failed or other error * =0: success */ int umqtt_trans_send(int sock, const rt_uint8_t *send_buf, rt_uint32_t buf_len, int timeout) { int _ret = 0; rt_uint32_t offset = 0U; while (offset < buf_len) { _ret = send(sock, send_buf + offset, buf_len - offset, 0); // <-- 上面的函数会返回到这里,因为返回的是0,所以这里会是死循环。 if (_ret < 0) return -errno; offset += _ret; } return _ret; } ~~~ 我尝试添加了如果返回为0的情况,退出这个循环,返回错误。 但是外部并没有相关的处理代码,下一次还是会进入同样的函数而不是重新建立一个socket。 这种情况应该怎么解决呢? 感觉umqtt这部分没有处理好返回值?
查看更多
3
个回答
默认排序
按发布时间排序
mii
2021-04-19
这家伙很懒,什么也没写!
umqtt_trans_send 上层应该还有处理函数才对,不然返回错误值,mqtt client 应该判断为掉线,然后执行重连动作。实现过程可参考Paho mqtt实现。
flashman2002
2021-04-19
这家伙很懒,什么也没写!
请核查一下函数_ret = send(sock, send_buf + offset, buf_len - offset, 0);的返回值,如果为0,可以返回一个错误码,在此函数的调用端再做具体处理,如重新连接等操作即可。
majianjia
2021-04-19
这家伙很懒,什么也没写!
好的,谢谢二位。 我去参考一下paho。 ~~~ umqtt_trans_send(int sock, const rt_uint8_t *send_buf, rt_uint32_t buf_len, int timeout) ~~~ 这个函数的返回值永远为0,看来这部分也需要修改一下。 他返回的是线程错误,线程根本没错。
撰写答案
登录
注册新账号
关注者
0
被浏览
1k
关于作者
majianjia
这家伙很懒,什么也没写!
提问
5
回答
21
被采纳
2
关注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
机器人操作系统 (ROS2) 和 RT-Thread 通信
4
国产MCU移植系列教程汇总,欢迎查看!
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
NXP MCXN947测评(二)ETH设备使用
2
【RA8D1-Vision Board】适配 LVGL V8
3
VISION BOARD 第二弹 基础工程配置和点亮一个LED灯
4
musb移植问题记录【设备注册3次挂起】
5
关于使用CherryUSB时候使用外挂的usb phy 芯片配置的一点注意事项
热门标签
RT-Thread Studio
串口
LWIP
Env
SPI
Bootloader
AT
ART-Pi
Hardfault
CAN总线
FinSH
USB
文件系统
RT-Thread
DMA
SCons
线程
RT-Thread Nano
MQTT
STM32
RTC
FAL
rt-smart
ESP8266
ota在线升级
WIZnet_W5500
I2C_IIC
UART
flash
cubemx
packages_软件包
freemodbus
潘多拉开发板_Pandora
PWM
定时器
ADC
BSP
中断
keil_MDK
编译报错
socket
MicroPython
GD32
msh
Debug
ulog
SDIO总线
SFUD
rt_mq_消息队列_msg_queue
C++_cpp
本月问答贡献
xiaorui
7
个答案
3
次被采纳
sakumisu
4
个答案
3
次被采纳
三世执戟
31
个答案
1
次被采纳
梦笑真美
18
个答案
1
次被采纳
踩姑娘的小蘑菇
14
个答案
1
次被采纳
本月文章贡献
Z_Y
2
篇文章
5
次点赞
Alipay
2
篇文章
3
次点赞
2345vor
2
篇文章
1
次点赞
比特饼干
1
篇文章
6
次点赞
Lu_盼盼
1
篇文章
3
次点赞
回到
顶部
发布
问题
分享
好友
手机
浏览
扫码手机浏览
投诉
建议
回到
底部