https://blog.csdn.net/lianghe_work/article/details/46551871

通過epoll實現tcp并發回執服務器（客戶端給服務器發啥，服務器就給客戶端回啥）

代碼如下：

1. #include <string.h>
2. #include <stdio.h>
3. #include <stdlib.h>
4. #include <unistd.h>
5. #include <sys/select.h>
6. #include <sys/time.h>
7. #include <sys/socket.h>
8. #include <netinet/in.h>
9. #include <arpa/inet.h>
10. #include <sys/epoll.h>
11. #include <errno.h>
12. #define OPEN_MAX 100
14. int main(int argc, char *argv[])
15. {
16. struct epoll_event event; // 告訴內核要監聽什么事件
17. struct epoll_event wait_event; //內核監聽完的結果
19. //1.創建tcp監聽套接字
20. int sockfd = socket(AF_INET, SOCK_STREAM, 0);
22. //2.綁定sockfd
23. struct sockaddr_in my_addr;
24. bzero(&my_addr, sizeof(my_addr));
25. my_addr.sin_family = AF_INET;
26. my_addr.sin_port = htons(8001);
27. my_addr.sin_addr.s_addr = htonl(INADDR_ANY);
28. bind(sockfd, (struct sockaddr *)&my_addr, sizeof(my_addr));
30. //3.監聽listen
31. listen(sockfd, 10);
33. //4.epoll相應參數準備
34. int fd[OPEN_MAX];
35. int i = 0, maxi = 0;
36. memset(fd,-1, sizeof(fd));
37. fd[0] = sockfd;
39. int epfd = epoll_create(10); // 創建一個 epoll 的句柄，參數要大于 0， 沒有太大意義
40. if( -1 == epfd ){
41. perror ("epoll_create");
42. return -1;
43. }
45. event.data.fd = sockfd; //監聽套接字
46. event.events = EPOLLIN; // 表示對應的文件描述符可以讀
48. //5.事件注冊函數，將監聽套接字描述符 sockfd 加入監聽事件
49. int ret = epoll_ctl(epfd, EPOLL_CTL_ADD, sockfd, &event);
50. if(-1 == ret){
51. perror("epoll_ctl");
52. return -1;
53. }
55. //6.對已連接的客戶端的數據處理
56. while(1)
57. {
58. // 監視并等待多個文件（標準輸入，udp套接字）描述符的屬性變化（是否可讀）
59. // 沒有屬性變化，這個函數會阻塞，直到有變化才往下執行，這里沒有設置超時
60. ret = epoll_wait(epfd, &wait_event, maxi+1, -1);
62. //6.1監測sockfd(監聽套接字)是否存在連接
63. if(( sockfd == wait_event.data.fd )
64. && ( EPOLLIN == wait_event.events & EPOLLIN ) )
65. {
66. struct sockaddr_in cli_addr;
67. int clilen = sizeof(cli_addr);
69. //6.1.1 從tcp完成連接中提取客戶端
70. int connfd = accept(sockfd, (struct sockaddr *)&cli_addr, &clilen);
72. //6.1.2 將提取到的connfd放入fd數組中，以便下面輪詢客戶端套接字
73. for(i=1; i<OPEN_MAX; i++)
74. {
75. if(fd[i] < 0)
76. {
77. fd[i] = connfd;
78. event.data.fd = connfd; //監聽套接字
79. event.events = EPOLLIN; // 表示對應的文件描述符可以讀
81. //6.1.3.事件注冊函數，將監聽套接字描述符 connfd 加入監聽事件
82. ret = epoll_ctl(epfd, EPOLL_CTL_ADD, connfd, &event);
83. if(-1 == ret){
84. perror("epoll_ctl");
85. return -1;
86. }
88. break;
89. }
90. }
92. //6.1.4 maxi更新
93. if(i > maxi)
94. maxi = i;
96. //6.1.5 如果沒有就緒的描述符，就繼續epoll監測，否則繼續向下看
97. if(--ret <= 0)
98. continue;
99. }
101. //6.2繼續響應就緒的描述符
102. for(i=1; i<=maxi; i++)
103. {
104. if(fd[i] < 0)
105. continue;
107. if(( fd[i] == wait_event.data.fd )
108. && ( EPOLLIN == wait_event.events & (EPOLLIN|EPOLLERR) ))
109. {
110. int len = 0;
111. char buf[128] = "";
113. //6.2.1接受客戶端數據
114. if((len = recv(fd[i], buf, sizeof(buf), 0)) < 0)
115. {
116. if(errno == ECONNRESET)//tcp連接超時、RST
117. {
118. close(fd[i]);
119. fd[i] = -1;
120. }
121. else
122. perror("read error:");
123. }
124. else if(len == 0)//客戶端關閉連接
125. {
126. close(fd[i]);
127. fd[i] = -1;
128. }
129. else//正常接收到服務器的數據
130. send(fd[i], buf, len, 0);
132. //6.2.2所有的就緒描述符處理完了，就退出當前的for循環，繼續poll監測
133. if(--ret <= 0)
134. break;
135. }
136. }
137. }
138. return 0;
139. }

運行結果：

源碼下載：