单路UDP实现异步发送接收

发布于 2019-10-20 22:50:50 浏览：1772 订阅该版

* 本帖最后由 wofei1314 于 2019-10-20 22:56 编辑 *

如题，使用RTT 4.0.1,    lwIP-1.4.1 时如何实现异步收发？
对于单片机端，我想使用5000作为发送和接收数据的端口，调用recvfrom函数时会阻塞，导致不能发数据
于是我重新建立了一个Socket，在第二个线程里，当第二个线程发送数据时，发现第一个线程收不到数据了，并且报错...
```hard fault on thread: tcpip

thread          pri     status       sp                    stack size          max       used left tick         error
---------------- ---      -------        ----------            ----------             ------       ---------- ---
Thread1       15     suspend   0x00000094    0x00000800     18%       0x00000034          -02
Thread2       15     ready        0x00000184    0x00000800     20%       0x0000004f           000
tshell            20  suspend 0x000000b4 0x00001000    04%   0x0000000a 000
led               19  suspend 0x00000068 0x00000080    81%   0x00000064 000
tcpip             10  running 0x000000ac 0x00000800    17%   0x00000014 000
etx               12  suspend 0x0000007c 0x00000400    15%   0x00000010 000
erx               12  ready   0x00000094 0x00000400    14%   0x00000010 000
tidle0            31  ready   0x0000005c 0x00000100    35%   0x00000014 000
main              10  suspend 0x0000011c 0x00000800    20%   0x0000000a 000
mem manage fault:
SCB_CFSR_MFSR:0x01 IACCVIOL
```这个错误如何解决？求大神指点另外，是否可以实现我的异步收发？
大致代码如下，线程1
```    /* 初始化本地UDP服务端地址 */
    server_addr.sin_family = AF_INET;
    server_addr.sin_port = htons(5000);
    server_addr.sin_addr.s_addr = INADDR_ANY;
    rt_memset(&(server_addr.sin_zero), 0, sizeof(server_addr.sin_zero));
    /* 绑定socket到服务端地址 */
    if (bind(sock, (struct sockaddr *)&server_addr,
             sizeof(struct sockaddr)) == -1)
    {
        /* 绑定地址失败 */
        rt_kprintf("Bind error<br>");
        /* 释放接收用的数据缓冲 */
        rt_free(recv_data);
        return;
    }
    addr_len = sizeof(struct sockaddr);
while(1)
{
    bytes_read = recvfrom(sock, recv_data, UDP_BUFSZ - 1, 0,
                              (struct sockaddr *)&client_addr, &addr_len);

...
}```
线程2代码
``` url = "192.168.1.9";
    port = strtoul("5000", 0, 10);

/* 通过函数入口参数url获得host地址（如果是域名，会做域名解析） */
    host = (struct hostent *) gethostbyname(url);
    /* 初始化预连接的服务端地址 */
    dst_addr.sin_family = AF_INET;
    dst_addr.sin_port = htons(port);
    dst_addr.sin_addr = *((struct in_addr *)host->h_addr);
    rt_memset(&(dst_addr.sin_zero), 0, sizeof(dst_addr.sin_zero));

while(1)
{
    			rt_thread_delay(1500);
			rt_kprintf("thread Send test-------<br>");
			sendto(sock, str, strlen(str), 0,
				(struct sockaddr *)&dst_addr, sizeof(struct sockaddr));
}```