umqtt+AT device, 如何解决socket被broker关闭的情况?

发布于 2021-04-19 04:58:48 浏览：1251 订阅该版

我最近在调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这部分没有处理好返回值？