RT-Thread-使用AT Device(ESP8266)软件包实现webnet(理论上实现其他TCP服务器也可以)RT-Thread问答社区

使用AT Device(ESP8266)软件包实现webnet(理论上实现其他TCP服务器也可以)

发布于 2024-07-12 05:04:27 浏览：574 订阅该版

[tocm]

1. RTThread setting里需要打开AT命令-使能AT命令客户端-通过AT Command使能BSD套接字API-使能AT server BSD套接字支持
2. 使能AT server BSD套接字支持后，at_socket.c里会增加对accept和listen接口的支持，然而目前accept里没有进行事件更新，导致在使用select函数获取listen套接字状态时，无论有没有accept都会返回可读状态，同时accept到的套接字永远为不可写状态，webnet无法正常使用
# 修改
## at_socket.c
原

```c
int at_accept(int socket, struct sockaddr *name, socklen_t *namelen)
{
    struct at_socket *sock = RT_NULL;
    struct at_socket *new_sock = RT_NULL;
    char receive_buff[AT_SOCKET_INFO_LEN];
    ip_addr_t remote_addr;
    uint16_t remote_port = 0;
    int new_socket = -1;
    int result = 0;

sock = at_get_socket(socket);
    if (sock == RT_NULL)
    {
        result = -1;
        goto __exit;
    }

if (sock->state != AT_SOCKET_LISTEN)
    {
        LOG_E("Socket(%d) connect state is %d.", sock->socket, sock->state);
        result = -1;
        goto __exit;
    }

sscanf(&receive_buff[0], "SOCKET:%d", &new_socket);
    new_sock = at_get_socket(new_socket);
    if (sock == RT_NULL)
    {
        result = -1;
        goto __exit;
    }
    new_sock->state = AT_SOCKET_CONNECT;
    ip4_addr_set_any(&remote_addr);
    ipaddr_port_to_socketaddr(name, &remote_addr, &remote_port);
    LOG_D("Accept: [socket :%d, base_socket:%d]", new_socket, (int)new_sock->user_data);

__exit:
    if (result < 0)
    {
        if (sock != RT_NULL)
        {
            at_do_event_changes(sock, AT_EVENT_ERROR, RT_TRUE);
        }
    }

return new_sock->socket;
}
```
改为

sock = at_get_socket(socket);
    if (sock == RT_NULL)
    {
        result = -1;
        goto __exit;
    }

if (sock->state != AT_SOCKET_LISTEN)
    {
        LOG_E("Socket(%d) connect state is %d.", sock->socket, sock->state);
        result = -1;
        goto __exit;
    }

/* wait the receive semaphore, waiting for info */
    if (rt_sem_take(sock->recv_notice, RT_WAITING_FOREVER) < 0)
    {
        errno = EAGAIN;
        result = -1;
        goto __exit;
    }
    else
    {
        /* get receive buffer to receiver ring buffer */
        rt_mutex_take(sock->recv_lock, RT_WAITING_FOREVER);
        at_recvpkt_get(&(sock->recvpkt_list), (char *) &receive_buff, AT_SOCKET_INFO_LEN);
        rt_mutex_release(sock->recv_lock);
        /* 如果仍存在待接收数据，继续通知，否则清空接收状态 */
        if (!rt_slist_isempty(&sock->recvpkt_list))
        {
            at_do_event_changes(sock, AT_EVENT_RECV, RT_TRUE);
        }
        else
        {
            at_do_event_clean(sock, AT_EVENT_RECV);
        }
    }

__exit:
    if (result < 0)
    {
        if (sock != RT_NULL)
        {
            at_do_event_changes(sock, AT_EVENT_ERROR, RT_TRUE);
        }
    }

return new_sock->socket;
}
```
修改后正常使用webnet软件包即可