【更适合初学者的开发板ELF 1】13-多线程测试-TCPServer

stm1024

0. 前言
前面测试过UDP和TCP的程序，显示功能正常，但是测试程序中都是单点之间的通讯，而且服务端和客户端，要有严格的顺序，并且，客户端或者服务端挂掉以后，另一边也会受到影响。此外，实际使用的时候可能有多个客户端连接服务端，此时我们可以考虑使用多进程或者多线程，但是使用多进程的话，占用的资源比较多，这个对一般的入门级嵌入式linux处理器不太友好，此外，还有可能会带来IPC（进程间通讯）的工作，因此，常见的嵌入式环境下，使用的是单进程+多线程，而不是多线程+单进程。

1. 编程规划
前面已经编写过了TCP的服务器端程序和客户端程序。本次重新改写TCP服务器端程序，测试多个客户端的连接。

2. 程序代码
完整的服务端测试代码如下：

1. #include <stdio.h>
   
2. #include <stdlib.h>
   
3. #include <string.h>
   
4. #include <errno.h>
   
5. #include <unistd.h>
   
6. #include <arpa/inet.h>
   
7. #include <sys/types.h>
   
8. #include <sys/socket.h>
   
9. #include <ctype.h>
   
10. #include <signal.h>
    
11. #include <pthread.h>
    
12. 
    
13. #define SERVER_PORT 12345
    
14. #define BUF_LEN 1024
    
15. #define THREAD_NUM 10
    
16. void dispErrInfo(const char* pretext,int errcode)
    
17. {
    
18.     printf("%s, errno=%d: %s\n",pretext,errcode,strerror(errcode));
    
19. }
    
20. 
    
21. void *child(void *arg)
    
22. {
    
23.     int i, rcvlen,ret,socketfd;
    
24.     i=0;
    
25.     rcvlen=-1;
    
26.     ret=-1;
    
27.     socketfd=*(int*)arg;
    
28.     char buf[BUF_LEN];
    
29.     memset(buf,0x00,256);
    
30. 
    
31.     pthread_t tid=pthread_self();
    
32.     printf("[THREAD %lu] ENTER.\n",tid);
    
33. 
    
34.     if((rcvlen=recv(socketfd,buf,BUF_LEN,0))==-1)
    
35.     {
    
36.         close(socketfd);
    
37.         dispErrInfo("[THREAD %lu] ERROR.\n",errno);
    
38.         exit(EXIT_FAILURE);
    
39.     }
    
40. 
    
41.     printf("[THREAD %lu] Received From Client:%s.\n",tid,buf);
    
42. 
    
43.     //process
    
44.     for(i=0;i<rcvlen;i++)
    
45.         buf[i]=toupper(buf[i]);
    
46.     //send back
    
47.     if(send(socketfd,buf,rcvlen,0)==-1)
    
48.     {
    
49.         close(socketfd);
    
50.         dispErrInfo("[THREAD %lu] ERROR.\n",errno);
    
51.         exit(EXIT_FAILURE);
    
52.     }
    
53.     printf("[THREAD %lu] EXIT.\n",tid);
    
54.     close(socketfd);
    
55.     pthread_exit(NULL);
    
56. }
    
57. 
    
58. 
    
59. int main(int argc, char** argv)
    
60. {      
    
61.     int socket_desc;
    
62.     int temp_socket_desc[THREAD_NUM];
    
63.     int t_num=0;   
    
64.     int address_size;   
    
65.    
    
66.     struct sockaddr_in sin;
    
67.     bzero(&sin,sizeof(sin));
    
68.     sin.sin_family = AF_INET;
    
69.     sin.sin_addr.s_addr = INADDR_ANY;                                 
    
70.     sin.sin_port = htons(SERVER_PORT);
    
71. 
    
72.     signal(SIGPIPE, SIG_IGN);
    
73.                  
    
74.     if((socket_desc = socket(AF_INET,SOCK_STREAM,0)) == -1)
    
75.     {
    
76.         dispErrInfo("Error open socket.\n",errno);
    
77.         exit(EXIT_FAILURE);
    
78.     }
    
79.          
    
80.     if(bind(socket_desc,(struct sockaddr *)&sin,sizeof(sin)) ==-1)
    
81.     {
    
82.         dispErrInfo("Error bind socket.\n",errno);
    
83.         exit(EXIT_FAILURE);
    
84.     }
    
85.     if(listen(socket_desc,20) == -1)
    
86.     {
    
87.         dispErrInfo("Error listen socket.\n",errno);
    
88.         exit(EXIT_FAILURE);
    
89.     }
    
90.     printf("Waiting connect...\n");
    
91.     pthread_attr_t attr;
    
92.         pthread_attr_init(&attr);
    
93.     pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);
    
94.     while(1)
    
95.     {         
    
96.          pthread_t tid;
    
97.         temp_socket_desc[t_num] = accept(socket_desc,NULL, NULL);
    
98.         if(temp_socket_desc[t_num] == -1)
    
99.         {
    
100.            dispErrInfo("Error accept socket.\n",errno);
     
101.            break;
     
102.         }        
     
103.          printf("create thread.\n");
     
104.          if (pthread_create(&tid,&attr,child,&temp_socket_desc[t_num]) == -1)
     
105.         {
     
106.                    dispErrInfo("Error create thread.\n",errno);
     
107.                     break;
     
108.                   }        
     
109.                   t_num = t_num+1;
     
110.                   if(t_num >= THREAD_NUM)        
     
111.                   {
     
112.                           break;
     
113.                   }                                
     
114.     }
     
115.         pthread_attr_destroy(&attr);
     
116.     return (EXIT_SUCCESS);
     
117. }

复制代码

3. 测试效果
编译，注意我们使用了多线程技术，因此在虚拟机中编译的时候，需要加入 -lpthread，如下：

上图中，agcc是我对/usr/local/arm/gcc-linaro-4.9.4-2017.01-x86_64_arm-linux-gnueabihf/bin/agcc做的link。

然后就是常规的拷贝到开发板中，赋予可执行权限等操作，最后运行。
在Windows主机上打开三个网络调试助手，以TCP客户端形式工作，连接服务端：
可见开发板上的程序可以正常收到各服务端发送的数据：


OK，今天测试就到这里。

xiaoshen-372360

支持一下大佬，向大佬看齐。