广西建设厅招投标中心网站,网站建设费用会计分录,庆阳平面设计招聘网,创建一个网站的技术I/O 复用使得程序能同时监听多个文件描述符#xff0c;这对于提高程序的性能至关重要。通常#xff0c; 网络程序在下列情况下需要使用 I/O 复用技术#xff1a; 1.TCP服务器同时要处理监听套接字和连接套接字 2.服务器同时要处理TCP请求和UDP请求。 3.程序同时要处理多个套… I/O 复用使得程序能同时监听多个文件描述符这对于提高程序的性能至关重要。通常 网络程序在下列情况下需要使用 I/O 复用技术 1.TCP服务器同时要处理监听套接字和连接套接字 2.服务器同时要处理TCP请求和UDP请求。 3.程序同时要处理多个套接字。 4.客服端程序要同时处理用户输入和网络连接。 5.服务器要同时监听多个端口。 需要指出的是 I/O 复用虽然能同时监听多个文件描述符但它本身是阻塞的。并且当 多个文件描述符同时就绪时如果不采取额外的措施程序就只能按顺序依处理其中的每一 个文件描述符这使得服务器看起来好像是串行工作的。如果要提高并发处理的能力可以 配合使用多线程或多进程等编程方法。 1select 1.1select的接口介绍 select系统调用的用途是再一段指定时间内监听用户感兴趣的文件描述符的可读、可写和异常事件。 select系统调用的原型如下 # include sys/select.h
int select (int maxfd,fd_set*readfds,fd_set*writefds,fd_set*exceptfds,struct timeval*timeout);
/*
select 成功时返回就绪可读、可写和异常文件描述符的总数。如果在超时间内没有任何文件描述符就绪select将返回0.select失败返回-1如果是在select等待期间程序接收到信号则select立即返回-1并设置errno为EINTR。
maxfd 参数指定的被监听的文件描述符的总数。它通常被设置为 select 监听的所
有文件描述符中的最大值1
readfds、 writefds 和 exceptfds 参数分别指向可读、可写和异常等事件对应的文件
描述符集合。应用程序调用 select 函数时通过这 3 个参数传入自己感兴趣的文件
描述符。 select 返回时内核将修改它们来通知应用程序哪些文件描述符已经就绪
通过下列宏可以访问 fd_set 结构中的位
FD_ZERO(fd_set *fdset); // 清除 fdset 的所有位
FD_SET(int fd, fd_set *fdset); // 设置 fdset 的位 fd,fd添加到集合置一
FD_CLR(int fd, fd_set *fdset); // 清除 fdset 的位 fd
int FD_ISSET(int fd, fd_set *fdset);// 测试 fdset 的位 fd 是否被设置
timeout 参数用来设置 select 函数的超时时间。它是一个 timeval 结构类型的指
针采用指针参数是因为内核将修改它以告诉应用程序 select 等待了多久。 timeval
结构的定义如下
struct timeval
{long tv_sec;//秒数long tv_usec://微秒数
};
如果给 timeout 的两个成员都是 0则 select 将立即返回。如果 timeout 传递
NULL则 select 将一直阻塞直到某个文件描述符就绪
*/ 1.2select的示例代码 使用select实现的TCP服务器如下 初始化服务器端的sockfd套接字 int initsocket()
{int sockfdsocket(AF_INET,SOCK_STREAM,0);if (sockfd-1)return -1;struct sockaddr_in saddr;memset(saddr,0,sizeof (saddr));saddr.sin_familyAF_INET;saddr.sin_porthtons(6000);saddr.sin_addr.s_addrinet_addr(127.0.0.1);int resbind(sockfd,(struct sockaddr*)saddr,sizeof (saddr));if (res-1)return -1;reslisten(sockfd,5);if (res-1)return -1;return sockfd;
} 初始化记录服务器套接字的数组 void initFds(int fds[],int n)
{int i0;for (;in;i){fds[i]-1;}
} 将套接字描述符添加到数组中 void AddFdToFds(int fds[],int fd,int n)
{ int i0;for (;in;i){if (fds[i]-1){fds[i]fd;break;}}
} 删除数组中的套接字描述符 void DelFromFds(int fds[],int fd,int n)
{for (int i0;in;i){if (fds[i]fd){fds[i]-1;break;}}
} 将数组中的套接字描述符设置到fd_set变量中并返回当前最大文件描述符 int SetFsToFdset(fd_set*fdset,int fds[],int n)
{FD_ZERO(fdest);//fdest置零int i0;int maxfdfds[0];//最大文件描述符的值for (;in;i){if (fds[i]!-1){FD_SET(fds[i],fdest);//将fdest的位fds[i]的值置为1if (fds[i]maxfd){maxfdfds[i];}}}return maxfd;
} 服务器和客户端的连接 void GetClientLink(int sockfd,int fds[],int n)
{ struct sockaddr_in caddr;int lensizeof (caddr);memset(caddr,0,sizeof(caddr));int caccept(sockfd,(struct sockaddr*)caddr,len);if (c0){return;}AddFdToFds(fds,c,n);
} 处理客户端数据 void DealClientData(int fds[],int n,int clifd)
{char data[128];int numrecv(clifd,data,127,0);if (num0){DelFdFromFds(fds,clifd,n);close(clifd);}else{printf (%d:%s\n,clifd,data);send(clifd,ok,2,0);}
} 处理select返回的就绪事件 void DealReadyEvent(int fds[],int n,fd_set*fdset,int sockfd)
{int i0;for (;in;i){if (fds[i]!-1FD_ISSET(fds[i],fdest)){if(fds[i]sockfd){GetClientLink(sockfd,fds,n);}else{DealClientLink(fds,n,fds[i]);}}}
}主函数 int main()
{int sockfdinitsocket();assert(sockfd!-1);fd_set readfds;int fds[1024];initFds(fds,1024);AddFdToFds(fds,sockfd,1024);while(1){int maxfdSetFdToFdset(readfds,fds,MAX_FD);struct timeval timeout;timeout.tv_sec2;//秒数timeout.tv_usec0;//微秒数int nselect(maxfd1,readfds,NULL,NULL,timeout);if (n0){printf (select error\n); break; }else if (n0){printf (timeout\n);continue;}DealReadyEvent(fds, 1024, readfds, sockfd);}exit(0);
} TCP 的客户端代码如下 #include stdio.h
#include stdlib.h
#include string.h
#include unistd.h
#include assert.h
#include sys/types.h
#include sys/socket.h
#include arpa/inet.h
#include netinet/in.h
int initsocket()
{int sockfdsocket(AF_INET,SOCK_STREAM,0);if (sockfd-1)return -1;struct sockaddr_in saddr;memset(saddr,0,sizeof (saddr));saddr.sin_familyAF_INET;saddr.sin_porthtons(6000);saddr.sin_addr.s_addrinet_addr(127.0.0.1);int resbind(sockfd,(struct sockaddr*)saddr,sizeof (saddr));if (res-1)return -1;reslisten(sockfd,5);if (res-1)return -1;return sockfd;
}
int main ()
{int sockfdinitsocket();assert(sockfd!-1);while(1){printf (please input:);char buff[128]{0};fgets(buff,127,stdin);if (strncmp(buff,bye,3)){break;}int nsend(sockfd,buff,strlen(buff)-1,0);if (n0){printf (send error\n);break;}memset(buff,0,128);nrecv(sockfd,buff,127,0);if(n0){printf (recv error\n);break;}printf (%s\n,buff);}close(sockfd);exit(0);
}
