epoll 框架问题

teng0210

我写的基本的epoll框架，使用apache ab测试，
ab -c 1000 -n 10000 http://localhost:8080/   
之后打开浏览器  页面不动  感觉阻塞了
然后继续ab测试 页面就刷出来了
大家帮忙看看。

1. 
   
2. #include<iostream>
   
3. #include<string>
   
4. #include<map>
   
5. #include<sys/types.h>
   
6. #include<sys/socket.h>
   
7. #include<arpa/inet.h>
   
8. #include<unistd.h>
   
9. #include<fcntl.h>
   
10. #include<signal.h>
    
11. #include<sys/epoll.h>
    
12. #include<string.h>
    
13. #include<error.h>
    
14. #include<errno.h>
    
15. #include<stdlib.h>
    
16. #include<sys/resource.h>
    
17. #include<pthread.h>
    
18. #include<time.h>
    
19. 
    
20. using namespace std;
    
21. 
    
22. #define LISTENQ 64
    
23. #define MAX_EVENTS 256
    
24. #define BUFSIZE 8192
    
25. 
    
26. struct client_t{
    
27.         int fd;
    
28.         string ip;
    
29.         string read_buf;
    
30.         string write_buf;
    
31.         time_t last_alive_time;
    
32.         int is_timeout;
    
33.         client_t(){
    
34.                 is_timeout=0;
    
35.         }
    
36. };
    
37. 
    
38. map<int, struct client_t *> fds;
    
39. pthread_mutex_t fds_mutex = PTHREAD_MUTEX_INITIALIZER;
    
40. 
    
41. //initialize server socket
    
42. //正常返回fd,否则返回-1
    
43. static int
    
44. init_servsock()
    
45. {
    
46.         int fd;
    
47.         struct sockaddr_in serveraddr;
    
48.         //socket
    
49.         if((fd=socket(AF_INET,SOCK_STREAM,0))<0){
    
50.                 perror("socket ");
    
51.                 return -1;
    
52.         }
    
53. 
    
54.         //可重用
    
55.         socklen_t reuse=1;
    
56.         if(setsockopt(fd,SOL_SOCKET,SO_REUSEADDR,&reuse,sizeof(reuse))<0){ //否则程序挂掉马上重启,会报端口不可用
    
57.                 perror("setsockopt()");
    
58.         }
    
59. 
    
60.         serveraddr.sin_family=AF_INET;
    
61.         serveraddr.sin_port=htons(8080);
    
62.         serveraddr.sin_addr.s_addr=htonl(INADDR_ANY);
    
63.         bzero(&(serveraddr.sin_zero),8);
    
64.         //bind
    
65.         if(bind(fd,(struct sockaddr *)&serveraddr,sizeof(sockaddr))<0){
    
66.                 perror("bind ");
    
67.                 return -1;
    
68.         }
    
69.         //listen
    
70.         if(listen(fd,LISTENQ)){
    
71.                 perror("listen ");
    
72.                 return -1;
    
73.         }
    
74. 
    
75.         return fd;
    
76. }
    
77. 
    
78. static int
    
79. set_fl(int fd,int flags)
    
80. {
    
81.         int val;
    
82. 
    
83.         if((val = fcntl(fd,F_GETFL,0)) < 0){
    
84.                 printf("fcntl F_GETFL error\n");
    
85.                 return -1;
    
86.         }
    
87. 
    
88.         val |=flags;
    
89. 
    
90.         if(fcntl(fd,F_SETFL,val) < 0){
    
91.                 printf("fcntl F_SETFL error\n");
    
92.                 return -1;
    
93.         }
    
94. 
    
95.         return 0;
    
96. }
    
97. 
    
98. //超时检测
    
99. static void *
    
100. check_time_out(void * arg){
     
101.         int epollfd=*((int *)&arg);
     
102.         while(1){
     
103.                 map<int,client_t *>::iterator it = fds.begin();
     
104.                 time_t tm;
     
105.                 time_t run_tm;
     
106.                 time(&tm);
     
107.                 for(; it!=fds.end(); ++it){
     
108.                         if(it->second != NULL){
     
109.                                 run_tm = tm - it->second->last_alive_time;
     
110.                                 if(run_tm >= 10){
     
111.                                         pthread_mutex_lock(&fds_mutex);
     
112.                                         close(it->second->fd);
     
113.                                         delete it->second;
     
114.                                         it->second = NULL;
     
115.                                         epoll_ctl(epollfd, EPOLL_CTL_DEL, it->second->fd, NULL);
     
116.                                         pthread_mutex_unlock(&fds_mutex);
     
117.                                 }
     
118.                         }
     
119.                 }
     
120.                 sleep(1);
     
121.         }
     
122. }
     
123. 
     
124. int
     
125. main()
     
126. {
     
127.         struct epoll_event ev, events[MAX_EVENTS];
     
128.         int listen_sock;
     
129.         int epollfd;
     
130.         int nfds;
     
131.         int err;
     
132. 
     
133.         //更改系统打开文件限制
     
134.         struct rlimit limit;
     
135.         limit.rlim_cur=getdtablesize();
     
136.         limit.rlim_max=limit.rlim_cur;
     
137.         if(setrlimit(RLIMIT_NOFILE,&limit)<0){
     
138.                 perror("setrlimit");
     
139.                 exit(1);
     
140.         }
     
141.        
     
142. 
     
143.         epollfd = epoll_create(512);
     
144.         if(epollfd == -1){
     
145.                 perror("epoll_create");
     
146.                 exit(1);
     
147.         }
     
148. 
     
149.         //创建超时检测线程
     
150.         pthread_t pid;
     
151.         err = pthread_create(&pid, NULL, check_time_out, (void *)epollfd);
     
152.         if(err !=0 ){
     
153.                 printf("创建超时检测线程失败！\n");
     
154.                 exit(1);
     
155.         }
     
156. 
     
157.         if((listen_sock = init_servsock())<0){
     
158.                 exit(1);
     
159.         }
     
160. 
     
161.         //设置为非阻塞
     
162.         if(set_fl(listen_sock,O_NONBLOCK) < 0){
     
163.                 exit(1);
     
164.         }
     
165. 
     
166.         //忽略信号
     
167.         signal(SIGPIPE,SIG_IGN);
     
168. 
     
169.         ev.events = EPOLLIN | EPOLLET;
     
170.         ev.data.fd = listen_sock;
     
171.         if(epoll_ctl(epollfd,EPOLL_CTL_ADD,listen_sock,&ev) == -1){
     
172.                 perror("epoll_ctl:listen_sock");
     
173.                 exit(1);
     
174.         }
     
175. 
     
176.         while(1){
     
177.                 nfds = epoll_wait(epollfd,events,MAX_EVENTS,-1);
     
178.                 if(nfds == -1){
     
179.                         perror("epoll_wait");
     
180.                         exit(1);
     
181.                 }
     
182. 
     
183.                 int n;
     
184.                 for(n = 0; n < nfds; ++n){
     
185.                         if(events[n].data.fd == listen_sock){
     
186.                                 struct sockaddr_in addr_in;
     
187.                                 size_t addrlen = sizeof(struct sockaddr_in);
     
188.                                 int conn_sock = accept(listen_sock, (struct sockaddr *)&addr_in, &addrlen);
     
189.                                 if(conn_sock == -1){
     
190.                                         perror("accept");
     
191.                                         continue;
     
192.                                 }
     
193. 
     
194.                                 if(set_fl(conn_sock, O_NONBLOCK) < 0){
     
195.                                         exit(1);
     
196.                                 }
     
197.                                 ev.events = EPOLLIN | EPOLLET;
     
198.                                 ev.data.fd = conn_sock;
     
199.                                 if(epoll_ctl(epollfd, EPOLL_CTL_ADD, conn_sock, &ev) == -1){
     
200.                                         perror("epoll_ctl:conn_sock");
     
201.                                         exit(1);
     
202.                                 }
     
203. 
     
204.                                 client_t *client_ptr = new client_t;
     
205.                                 fds[conn_sock] = client_ptr;
     
206.                                 fds[conn_sock]->fd = conn_sock;
     
207.                                 fds[conn_sock]->ip = string(inet_ntoa(addr_in.sin_addr));
     
208.                                 fds[conn_sock]->last_alive_time=time(NULL);
     
209.                         }else if(events[n].events & EPOLLIN){
     
210.                                 int fd = events[n].data.fd;
     
211.                                 pthread_mutex_lock(&fds_mutex);
     
212.                                 while(1){
     
213.                                         char buf[BUFSIZE];
     
214.                                         memset(buf, 0, BUFSIZE);
     
215.                                         int n=read(fd, buf, BUFSIZE);
     
216.                                         if(n>0){
     
217.                                                 fds[fd]->read_buf.append(buf,BUFSIZE);
     
218.                                         }
     
219.                                         if(n < BUFSIZE){
     
220.                                                 break;
     
221.                                         }
     
222.                                         if(errno == EAGAIN){
     
223.                                                 break;
     
224.                                         }
     
225.                                 }
     
226.                                 pthread_mutex_unlock(&fds_mutex);
     
227.                                 ev.events = EPOLLOUT | EPOLLET;
     
228.                                 ev.data.fd = fd;
     
229.                                 epoll_ctl(epollfd, EPOLL_CTL_MOD ,fd ,&ev);
     
230.                         }else if(events[n].events & EPOLLOUT){
     
231.                                 int fd = events[n].data.fd;
     
232.                                 pthread_mutex_lock(&fds_mutex);
     
233.                                 fds[fd]->write_buf = "HTTP/1.1 200 Ok\r\n";
     
234.                                 fds[fd]->write_buf += "Content-Type: text/plain\r\n";
     
235.                                 fds[fd]->write_buf += "Content-Length: 11\r\n";
     
236.                                 fds[fd]->write_buf += "\r\n";
     
237.                                 fds[fd]->write_buf += "hello world";
     
238.                                 int n = write(fd, fds[fd]->write_buf.data(), fds[fd]->write_buf.length());
     
239.                                 if(n < 0){
     
240.                                         perror("write");
     
241.                                 }
     
242. 
     
243.                                 epoll_ctl(epollfd, EPOLL_CTL_DEL, fd, NULL);
     
244.                                 close(fd);
     
245.                                 delete fds[fd];
     
246.                                 fds[fd] = NULL;
     
247.                                 pthread_mutex_unlock(&fds_mutex);
     
248. 
     
249.                                 /*ev.events = EPOLLIN | EPOLLET;
     
250.                                 ev.data.fd = fd;
     
251.                                 epoll_ctl(epollfd, EPOLL_CTL_MOD, fd, &ev);*/
     
252.                         }
     
253.                 }
     
254.         }
     
255. 
     
256. 
     
257.         close(listen_sock);
     
258. 
     
259.         return 0;
     
260. }
     

复制代码

aoegiss

strace之