并发服务器模型：IO复用循环服务器
1、简介
前面的服务器模型主要集中在并发服务器上，并发服务器有个比较大的缺陷，它需要建立多个并行的处理单元。当客户端增加时，随着处理单元的增加，系统的负载会逐渐转移到并行单元的现场切换上。因此有一个比较新型的IO复用循环服务器。该模型在系统开始时，建立多个不同工作类型的处理单元，当客户端的请求到来时，将客户端的连接放到一个状态池中，对所有客户端的连接状态在一个处理单元中进行轮询处理。
2、tcp模型
3、服务器源代码（concurrency-server5.c）：
#include <stdio.h> #include <stdlib.h> #include <string.h> #include <errno.h> #include <sys/socket.h> #include <arpa/inet.h> #include <netinet/in.h> #include <sys/types.h> #include <unistd.h> #include <time.h> #include <pthread.h> #define BUFLEN 1024 #define THREADNUM 2 #define CLIENTNUM 1024 int connect_host[CLIENTNUM]; int connect_num = 0; /*******************并发服务器模型之五：IO复用循环服务器**********************/ static void *handle_request(void *argv){ char buf[BUFLEN]; int len; time_t now; int maxfd = -1; fd_set rfds; struct timeval tv; tv.tv_sec = 1; tv.tv_usec = 0; int i =0; int err = -1; while(1){ FD_ZERO(&rfds); for(i = 0; i < CLIENTNUM; i++){ if(connect_host[i] != -1){ FD_SET(connect_host[i],&rfds); if(maxfd < connect_host[i]) maxfd = connect_host[i]; } } err = select(maxfd+1, &rfds, NULL, NULL, &tv); switch(err){ case 0: break; case -1: break; default: if (connect_num < 0) break; for(i = 0; i < CLIENTNUM; i++){ if(connect_host[i] != -1){ if(FD_ISSET(connect_host[i],&rfds)){ /******处理客户端请求*******/ bzero(buf,BUFLEN); len = recv(connect_host[i],buf,BUFLEN,0); if(len >0 && !strncmp(buf,"TIME",4)){ bzero(buf,BUFLEN); /*获取系统当前时间*/ now = time(NULL); /*ctime将系统时间转换为字符串，sprintf使转化后的字符串保存在buf*/ sprintf(buf,"%24s\r\n",ctime(&now)); //******发送系统时间*******/ send(connect_host[i],buf,strlen(buf),0); } /*关闭通讯的套接字*/ close(connect_host[i]); /*更新文件描述符在数组中的值*/ connect_host[i] = -1; connect_num--; } } } break; } } return NULL; } static void *handle_connect(void *arg){ int sockfd = *((int *)arg); int newfd; struct sockaddr_in c_addr; socklen_t len; int i; while(1){ len = sizeof(struct sockaddr); if((newfd = accept(sockfd,(struct sockaddr*) &c_addr, &len)) >0){ printf("\n*****************通信开始***************\n"); printf("正在与您通信的客户端是：%s: %d\n",inet_ntoa(c_addr.sin_addr),ntohs(c_addr.sin_port)); for(i = 0; i < CLIENTNUM; i++){ if(connect_host[i] == -1){ connect_host[i] = newfd; /*客户端计数器*/ connect_num++; /*继续等待新的客户端*/ break; } } } } return NULL; } int main(int argc, char **argv) { int sockfd; struct sockaddr_in s_addr; unsigned int port, listnum; pthread_t thread_s[2]; /**/ memset(connect_host,-1,CLIENTNUM); /*建立socket*/ if((sockfd = socket(AF_INET, SOCK_STREAM, 0)) == -1){ perror("socket"); exit(errno); }else printf("socket create success!\n"); /*设置服务器端口*/ if(argv[2]) port = atoi(argv[2]); else port = 4567; /*设置侦听队列长度*/ if(argv[3]) listnum = atoi(argv[3]); else listnum = 3; /*设置服务器ip*/ bzero(&s_addr, sizeof(s_addr)); s_addr.sin_family = AF_INET; s_addr.sin_port = htons(port); if(argv[1]) s_addr.sin_addr.s_addr = inet_addr(argv[1]); else s_addr.sin_addr.s_addr = INADDR_ANY; /*把地址和端口帮定到套接字上*/ if((bind(sockfd, (struct sockaddr*) &s_addr,sizeof(struct sockaddr))) == -1){ perror("bind"); exit(errno); }else printf("bind success!\n"); /*侦听本地端口*/ if(listen(sockfd,listnum) == -1){ perror("listen"); exit(errno); }else printf("the server is listening!\n"); /*创建线程处理客户端的连接*/ pthread_create(&thread_s[0],NULL,handle_connect,(void *)&sockfd); /*创建线程处理客户端的请求*/ pthread_create(&thread_s[1],NULL,handle_request, NULL); /*等待线程结束*/ int i; for(i = 0; i < THREADNUM; i++){ pthread_join(thread_s[i],NULL); } /*关闭服务器的套接字*/ close(sockfd); return 0; }
4、客户端源代码（concurrency-client.c）与之前的一样。
5、编译源代码：
new@new-desktop:~/linux/c$ gcc -Wall –lpthread concurrency-server5.c -o server
new@new-desktop:~/linux/c$ gcc -Wall concurrency-client.c -o client
6、运行，试试吧