I O复用之select模型:I O复用使得程序能够同时监听多个文件描述符,但I O复用本身也是阻塞的,并且当一个或多个文件描述符准备就绪时,如果不采用其他措施,程序只能按顺序处理其中的每个文件描述符。如果要使程序能够并行运行,只能使用多进程或多线程的方式。
I/O复用之select模型:
I/O复用使得程序能够同时监听多个文件描述符,但I/O复用本身也是阻塞的,并且当一个或多个文件描述符准备就绪时,如果不采用其他措施,程序只能按顺序处理其中的每个文件描述符。如果要使程序能够并行运行,只能使用多进程或多线程的方式。
Linux中I/O复用系统调用主要有select和poll还有epoll三种,这篇博客主要讨论的是select
select函数API:
select的参数中第一个是nfds是所有监听的文件描述符的个数+1;
第二个参数是readfds是要进行读操作的文件描述符集,第三个是进行写操作的文件描述符的集合,第四个是错误的文件描述符集,第四个参数timeout是一个结构体,结构体的内容如下:
如果是把结构体中的两个变量都设置为0,那么select立即返回,如果把timeout设置为NULL那么select一直阻塞到知道一某个文件描述符准备就绪。
select的返回值:
select成功后返回值为准备就绪的文件描述符的个数,如果返回值是0的话就说明等待超时,返回值为负值就说明select执行失败。
select实现高性能服务器代码:<喎"http://www.2cto.com/kf/ware/vc/" target="_blank" class="keylink">vc3Ryb25nPjwvcD4NCjxwcmUgY2xhc3M9"brush:java;">#include#include#include#include#include#include#include#include#includeint array_fds[1024];static void usage(char* proc){ printf("usage:%s [ip][port]",proc);}ssize_t startup(char* ip,int port){ ssize_t sock=socket(AF_INET,SOCK_STREAM,0); if(sock<0) { perror("socket"); exit(2); } int flag=1; setsockopt(sock,SOL_SOCKET,SO_REUSEADDR,&flag,sizeof(flag)); struct sockaddr_in server_addr; server_addr.sin_family=AF_INET; server_addr.sin_port=htons(port); server_addr.sin_addr.s_addr=inet_addr(ip); if(bind(sock,(struct sockaddr*)&server_addr,sizeof(server_addr))<0) { perror("bind"); exit(3); } if(listen(sock,10)<0) { perror("listen"); exit(4); } return sock;}int main(int argc,char* argv[]){ if(argc!=3) { usage(argv[0]); exit(1); } int listen_sock=startup(argv[1],atoi(argv[2])); fd_set rfds; fd_set wfds; int maxfd=0; int array_size=sizeof(array_fds)/sizeof(array_fds[0]); array_fds[0]=listen_sock; int i=1; for(;i0) { FD_SET(array_fds[i],&rfds); FD_SET(array_fds[i],&wfds); if(array_fds[i]>maxfd) { maxfd=array_fds[i]; } } } switch(select(maxfd+1,&rfds,&wfds,NULL,NULL)) { case 0: printf("timeout..."); break; case -1: perror("select"); break; default: { int j=0; for(;j0) { buff[s]='