RT-Thread-NK-980IOT测评之EMAC的tcp udp socket通讯RT-Thread问答社区

NK-980IOT测评之EMAC的tcp udp socket通讯

发布于 2022-03-20 14:22:18 浏览：800 订阅该版

[tocm]

### 测试环境

开发板：NK-980IOT V1.0
开发环境：RT-Thread studio 2.2.1 + NuWriter v1.18
RT-Thread版本：4.0.5
开发板网络连接到路由，开启路由WIF到有以太网的桥接功能连接到主路由

### 1、先做个简单的TCP client及UDP测试

![image.png](https://oss-club.rt-thread.org/uploads/20220320/8023fcc730c68a72d8567a52ecc73c37.png.webp)

```
#include <rtthread.h>
#include "lwip/sockets.h"
#include <lwip/netdb.h>

#define BUFSZ 1024

void tcpclient(int argc, char **argv)
{
    int ret;
    char *recv_data;
    struct hostent *host;
    int sock, bytes_received;
    struct sockaddr_in server_addr;
    const char *url;
    int port;

/* 接收到的参数小于 3 个 */
    if (argc < 3)
    {
        rt_kprintf("Usage: tcpclient URL PORT\n");
        rt_kprintf("Like: tcpclient 192.168.12.44 5000\n");
        return ;
    }

url = argv[1];
    port = strtoul(argv[2], 0, 10);

/* 通过函数入口参数 url 获得 host 地址（如果是域名，会做域名解析） */
    host = gethostbyname(url);

/* 分配用于存放接收数据的缓冲 */
    recv_data = rt_malloc(BUFSZ);
    if (recv_data == RT_NULL)
    {
        rt_kprintf("No memory\n");
        return;
    }

/* 创建一个 socket，类型是 SOCKET_STREAM，TCP 类型 */
    if ((sock = socket(AF_INET, SOCK_STREAM, 0)) == -1)
    {
        /* 创建 socket 失败 */
        rt_kprintf("Socket error\n");

/* 释放接收缓冲 */
        rt_free(recv_data);
        return;
    }

/* 初始化预连接的服务端地址 */
    server_addr.sin_family = AF_INET;
    server_addr.sin_port = htons(port);
    server_addr.sin_addr = *((struct in_addr *)host->h_addr);
    rt_memset(&(server_addr.sin_zero), 0, sizeof(server_addr.sin_zero));

/* 连接到服务端 */
    if (connect(sock, (struct sockaddr *)&server_addr, sizeof(struct sockaddr)) == -1)
    {
        /* 连接失败 */
        rt_kprintf("Connect fail!\n");
        closesocket(sock);

/* 释放接收缓冲 */
        rt_free(recv_data);
        return;
    }

while (1)
    {
        /* 从 sock 连接中接收最大 BUFSZ - 1 字节数据 */
        bytes_received = recv(sock, recv_data, BUFSZ - 1, 0);
        if (bytes_received < 0)
        {
            /* 接收失败，关闭这个连接 */
            closesocket(sock);
            rt_kprintf("\nreceived error,close the socket.\r\n");

/* 释放接收缓冲 */
            rt_free(recv_data);
            break;
        }
        else if (bytes_received == 0)
        {
            /* 打印 recv 函数返回值为 0 的警告信息 */
            rt_kprintf("\nReceived warning,recv function return 0.\r\n");

continue;
        }

/* 有接收到数据，把末端清零 */
        recv_data[bytes_received] = '\0';

if (strncmp(recv_data, "q", 1) == 0 || strncmp(recv_data, "Q", 1) == 0)
        {
            /* 如果是首字母是 q 或 Q，关闭这个连接 */
            closesocket(sock);
            rt_kprintf("\n got a'q'or'Q',close the socket.\r\n");

/* 释放接收缓冲 */
            rt_free(recv_data);
            break;
        }
        else
        {
            /* 在控制终端显示收到的数据 */
            rt_kprintf("\nReceived data = %s", recv_data);
        }

/* 发送数据到 sock 连接 */
        ret = send(sock, recv_data,  strlen(recv_data), 0);
        if (ret < 0)
        {
            /* 接收失败，关闭这个连接 */
            closesocket(sock);
            rt_kprintf("\nsend error,close the socket.\r\n");

rt_free(recv_data);
            break;
        }
        else if (ret == 0)
        {
            /* 打印 send 函数返回值为 0 的警告信息 */
            rt_kprintf("\n Send warning,send function return 0.\r\n");
        }
    }
    return;
}

#if defined(RT_USING_FINSH) && defined(FINSH_USING_MSH)
    MSH_CMD_EXPORT(tcp, tcp client test);
#endif

void udpclient(int argc, char **argv)
{
    int sock, port, count;
    struct hostent *host;
    struct sockaddr_in server_addr;
    const char *url;

/* 接收到的参数小于 3 个 */
    if (argc < 3)
    {
        rt_kprintf("Usage: udpclient URL PORT [COUNT = 10]\n");
        rt_kprintf("Like: tcpclient 192.168.12.44 5000\n");
        return ;
    }

url = argv[1];
    port = strtoul(argv[2], 0, 10);

if (argc> 3)
        count = strtoul(argv[3], 0, 10);
    else
        count = 10;

/* 通过函数入口参数 url 获得 host 地址（如果是域名，会做域名解析） */
    host = (struct hostent *) gethostbyname(url);

/* 创建一个 socket，类型是 SOCK_DGRAM，UDP 类型 */
    if ((sock = socket(AF_INET, SOCK_DGRAM, 0)) == -1)
    {
        rt_kprintf("Socket error\n");
        return;
    }

/* 总计发送 count 次数据 */
    while (count)
    {
        /* 发送数据到服务远端 */
        sendto(sock, "hello world", strlen("hello world"), 0,
               (struct sockaddr *)&server_addr, sizeof(struct sockaddr));

/* 线程休眠一段时间 */
        rt_thread_delay(1000);

/* 计数值减一 */
        count --;
    }

/* 关闭这个 socket */
    closesocket(sock);
}
#if defined(RT_USING_FINSH) && defined(FINSH_USING_MSH)
    MSH_CMD_EXPORT(udpclient, udp test);
#endif
```
TCP client客户端连接PC服务器端，收到数据向上转发
msh:输入命令 tcpclient 192.168.0.108 8080
UDP 定时向服务器发送数据
msh:输入命令 udp 192.168.0.108 8080 10

### 使用iperf命令测试四种模式下带宽

### 2、UDP客户端网络带宽测试
实测30M左右
![image.png](https://oss-club.rt-thread.org/uploads/20220320/dc6cbe4795d3128d9646552e00e3d536.png.webp)
### 3、TCP客户端网络带宽测试

实测10M左右
![image.png](https://oss-club.rt-thread.org/uploads/20220320/899ce9d6ad102b532acd54722b5e3c31.png.webp)

### 3、TCP服务器端网络带宽测试

实测12M左右
![image.png](https://oss-club.rt-thread.org/uploads/20220320/4e8b78c61759b2a892791c8797dfb8bd.png.webp)

### 4、UDP服务器端网络带宽测试

实测10M左右
![image.png](https://oss-club.rt-thread.org/uploads/20220320/90684da645a469ef2ffdabaab396553f.png.webp)