• Home
Name Date Size #Lines LOC

..--

wifi/12-May-2024-257189

BUILD.gnD12-May-2024863 2523

README.mdD12-May-20246.3 KiB198152

tcp_server_demo.cD12-May-20243.7 KiB13082

README.md

1# BearPi-HM_Nano开发板WiFi编程开发——TCP服务器
2本示例将演示如何在BearPi-HM_Nano开发板上使用socket编程创建TCP服务端,接收客户端消息并回复固定消息。
3
4
5## socket API分析
6本案例主要使用了以下几个API来完成TCP Server的编程实验。
7### socket()
8
9```c
10sock_fd = socket(AF_INET, SOCK_STREAM, 0)) //AF_INT:ipv4, SOCK_STREAM:tcp协议
11```
12**描述:**
13
14在网络编程中需要进行的第一件事情就是创建一个socket,无论是客户端还是服务器端,都需要创建一个socket。该函数返回socket文件描述符,类似于文件描述符。socket是一个结构体,被创建在内核中。
15### bind()
16```c
17bind(sockfd, (struct sockaddr*)&server_sock, sizeof(server_sock))
18```
19**描述:**
20
21把一个本地协议地址和socket绑定,比如把本机的2222端口绑定到socket。注意:在客户端不需要调用bind函数,这是因为如果没有调用bind函数绑定一个端口的话,当调用connect函数时,内核会为该socket临时分配一个端口。因为所有客户端都需要知道服务器使用的是哪个端口,所以在服务器侧需要提前绑定确定的端口号。
22
23
24### listen()
25```c
26int listen(int s, int backlog)
27```
28**描述:**
29
30当socket创建后,它通常被默认为是主动套接字,即默认要马上调用connect函数的,而作为服务器是需要被动接收的,所以需要调用listen函数将主动套接字转换成被动套接字。调用listen函数后,内核将从该socket接收连接请求。
31
32
33### accept()
34```c
35int accept(s, addr, addrlen)
36```
37**描述:**
38
39此函数返回已经完成连接的socket。注意:此处的socket不同于服务器开始时创建的监听socket,此socket是已经完成连接的套接字,监听socket只是用来监听。
40
41### recv()
42```c
43int recv(SOCKET s, char *buf, int len, int flags)
44```
45**描述:**
46
47recv函数用来从已建立TCP连接的另一端接收数据。
48
49### send()
50```c
51int send(SOCKET s, char *buf, int len, int flags)
52```
53**描述:**
54
55send函数用来向已建立TCP连接的另一端发送数据。
56
57
58## 软件设计
59
60**主要代码分析**
61
62完成TCP server的建立及收发功能实现需要以下几步:
63
641. 通过 `socket` 接口创建一个socket,`AF_INT`表示ipv4,`SOCK_STREAM`表示使用tcp协议。
652. 调用 `bind` 接口绑定socket和地址。
663. 调用 `listen` 接口监听指定port,通知操作系统去接收来自客户端的连接请求,第二个参数:指定队列长度。
674. 调用`accept`接口从队列中获得一个客户端的连接请求。
685. 调用 `recv` 接口接收客户端发来的数据。
696. 调用 `send` 接口向客户端回复固定的数据。
70
71```c
72static void TCPServerTask(void)
73{
74    //在sock_fd 进行监听,在 new_fd 接收新的链接
75    int sock_fd, new_fd;
76
77    //服务端地址信息
78    struct sockaddr_in server_sock;
79
80    //客户端地址信息
81    struct sockaddr_in client_sock;
82    int sin_size;
83
84    struct sockaddr_in *cli_addr;
85
86    //连接Wifi
87    WifiConnect(CONFIG_WIFI_SSID, CONFIG_WIFI_PWD);
88
89    //创建socket
90    if ((sock_fd = socket(AF_INET, SOCK_STREAM, 0)) == -1) {
91        perror("socket is error\r\n");
92        exit(1);
93    }
94
95    bzero(&server_sock, sizeof(server_sock));
96    server_sock.sin_family = AF_INET;
97    server_sock.sin_addr.s_addr = htonl(INADDR_ANY);
98    server_sock.sin_port = htons(CONFIG_CLIENT_PORT);
99
100    //调用bind函数绑定socket和地址
101    if (bind(sock_fd, (struct sockaddr *)&server_sock, sizeof(struct sockaddr)) == -1) {
102        exit(1);
103    }
104
105    //调用listen函数监听(指定port监听)
106    if (listen(sock_fd, TCP_BACKLOG) == -1) {
107        exit(1);
108    }
109
110    printf("start accept\n");
111
112    //调用accept函数从队列中
113    while (1) {
114        sin_size = sizeof(struct sockaddr_in);
115
116        if ((new_fd = accept(sock_fd, (struct sockaddr *)&client_sock, (socklen_t *)&sin_size)) == -1) {
117            perror("accept");
118            continue;
119        }
120
121        cli_addr = malloc(sizeof(struct sockaddr));
122
123        printf("accept addr\r\n");
124
125        if (cli_addr != NULL) {
126            int ret = memcpy_s(cli_addr, sizeof(cli_addr), &client_sock, sizeof(struct sockaddr));
127            if (!ret) {
128                perror("memcpy is error\r\n");
129                exit(1);
130            }
131        }
132        //处理目标
133        ssize_t ret;
134
135        while (1) {
136            memset_s(recvbuf, sizeof(recvbuf), 0, sizeof(recvbuf));
137            if ((ret = recv(new_fd, recvbuf, sizeof(recvbuf), 0)) == -1) {
138                printf("recv error \r\n");
139            }
140            printf("recv :%s\r\n", recvbuf);
141            sleep(TASK_DELAY_2S);
142            if ((ret = send(new_fd, buf, strlen(buf) + 1, 0)) == -1) {
143                perror("send : ");
144            }
145            sleep(TASK_DELAY_2S);
146        }
147        close(new_fd);
148    }
149}
150```
151
152## 编译调试
153
154### 修改 BUILD.gn 文件
155
156修改 `device\board\bearpi\bearpi_hm_nano\app` 路径下 BUILD.gn 文件,指定 `tcp_server` 参与编译。
157```r
158#"D1_iot_wifi_sta:wifi_sta",
159#"D2_iot_wifi_sta_connect:wifi_sta_connect",
160#"D3_iot_udp_client:udp_client",
161"D4_iot_tcp_server:tcp_server",
162#"D5_iot_mqtt:iot_mqtt",
163#"D6_iot_cloud_oc:oc_mqtt",
164```
165
166
167### 运行结果
168
169示例代码编译烧录后,按下开发板的RESET按键,通过串口助手查看日志,会打印模块的本地IP,如本例程中的 `192.168.0.164` ,并开始准备获取客户端的请求链接。
170```
171g_connected: 1
172netifapi_dhcp_start: 0
173server :
174        server_id : 192.168.0.1
175        mask : 255.255.255.0, 1
176        gw : 192.168.0.1
177        T0 : 7200
178        T1 : 3600
179        T2 : 6300
180clients <1> :
181        mac_idx mac             addr            state   lease   tries   rto
182        0       181131a48f7a    192.168.0.164   10      0       1       2
183netifapi_netif_common: 0
184start accept
185```
186使用 Socket tool 创建客户端用于测试,如下图所示。
187
188![创建TCP_Clien](../../docs/figures/D4_iot_tcp_server/createtcpclient.png)
189
190在创建客户端后点击“连接”,在数据发送窗口输入要发送的数据,点击发送后服务端会回复固定消息,如下图所示,且开发板收到消息后会通过日志打印出来。
191
192```
193start accept
194accept addr
195recv :Hello! BearPi-HM_nano TCP Server!
196```
197
198![TCP发送数据](../../docs/figures/D4_iot_tcp_server/TCPSendData.png)