宝安第一网站,wordpress三栏中文主题,网架加工厂有招工的吗,网络营销常用的工具和方法程序简介#xff1a;这是一个运用epoll系列函数进行IO复用的服务器模型。它是目前UNIX与LINUX平台上效率最高#xff0c;最受欢迎的IO复用传输模型。 其他的不说了#xff0c;直接粘贴代码吧#xff01; 服务器端#xff1a; #include my_unp.h int main(v…程序简介这是一个运用epoll系列函数进行IO复用的服务器模型。它是目前UNIX与LINUX平台上效率最高最受欢迎的IO复用传输模型。 其他的不说了直接粘贴代码吧 服务器端 #include my_unp.h int main(void) { int listenfd, connfd, sockfd, epfd; int i, maxi, nfds; ssize_t n; char buf[MAXLINE]; socklen_t clilen; struct sockaddr_in cliaddr; struct sockaddr_in servaddr; //声明epoll_event结构体的变量,ev用于注册事件,数组用于回传要处理的事件 struct epoll_event ev, events[256]; //创建一个epoll的句柄size用来告诉内核这个监听的数目一共有多大 epfd Epoll_create(256); //创建用于TCP协议的套接字 listenfd Socket(AF_INET, SOCK_STREAM, 0); memset(servaddr, 0, sizeof(servaddr)); servaddr.sin_family AF_INET; servaddr.sin_addr.s_addr htonl(INADDR_ANY); servaddr.sin_port htons(SERV_PORT); //把socket和socket地址结构联系起来 Bind(listenfd, (SA*)servaddr, sizeof(servaddr)); //开始监听LISTENQ端口 Listen(listenfd, LISTENQ); //设置与要处理的事件相关的文件描述符和事件 ev.data.fd listenfd; ev.events EPOLLIN|EPOLLET; //注册epoll事件 Epoll_ctl(epfd, EPOLL_CTL_ADD, listenfd,ev); maxi 0; while(1) { //等待epoll事件的发生 //返回需要处理的事件数目nfds如返回0表示已超时。 nfds Epoll_wait(epfd, events, 20, 500); //处理所发生的所有事件 for(i0; i nfds; i) { //如果新监测到一个SOCKET用户连接到了绑定的SOCKET端口建立新的连接。 if(events[i].data.fd listenfd) { connfd Accept(listenfd,(SA*)cliaddr, clilen); printf(connection from %s, port %d.\n, Inet_ntop(AF_INET, (void*)cliaddr.sin_addr, buf, sizeof(buf)), ntohs(cliaddr.sin_port)); //设置用于读操作的文件描述符和事件 ev.data.fd connfd; ev.events EPOLLIN|EPOLLET; //注册事件 Epoll_ctl(epfd,EPOLL_CTL_ADD,connfd,ev); } //如果是已经连接的用户并且收到数据那么进行读入。 else if(events[i].events EPOLLIN) { sockfd events[i].data.fd; if ( sockfd 0 ) continue; n read(sockfd, buf, MAXLINE); if ( n 0) { // Connection Reset:你连接的那一端已经断开了 //而你却还试着在对方已断开的socketfd上读写数据 if (errno ECONNRESET) { Close(sockfd); events[i].data.fd -1; } else error_quit(read error); } //如果读入的数据为空 else if ( n 0 ) { Close(sockfd); events[i].data.fd -1; } else { //设置用于写操作的文件描述符和事件 ev.data.fd sockfd; ev.events EPOLLOUT|EPOLLET; //注册事件 Epoll_ctl(epfd,EPOLL_CTL_MOD,sockfd,ev); } } //如果有数据发送 else if(events[i].events EPOLLOUT) { sockfd events[i].data.fd; Writen(sockfd, buf, n); //设置用于读操作的文件描述符和事件 ev.data.fd sockfd; ev.events EPOLLIN|EPOLLET; //注册事件 Epoll_ctl(epfd, EPOLL_CTL_MOD, sockfd, ev); } } } return 0; } 客户端的测试例子 #include my_unp.h  void str_cli(FILE *fp, int sockfd)   {    char sendline[MAXLINE], recvline[MAXLINE];    int len; //从终端获取一行字符串将其写入套接字    //然后从套接字一行字符串将其写入终端    while( Fgets(sendline, MAXLINE, fp) ! NULL )    {     Writen(sockfd, sendline, strlen(sendline));     len Read(sockfd, recvline, MAXLINE);   if( len 0 )      error_quit(str_cli: server terminated prematurely);     recvline[len] 0;   Fputs(recvline, stdout);    }   }  int main(int argc, char **argv)   {    int sockfd;    struct sockaddr_in servaddr;    if( argc ! 2 )     error_quit(usage: client IPAddress);  //创建用于TCP协议的套接字    sockfd Socket(AF_INET, SOCK_STREAM, 0);    memset(servaddr, 0, sizeof(servaddr));    servaddr.sin_family AF_INET;    servaddr.sin_port htons(SERV_PORT);  //将程序的参数1(argv[1])转换成套接字地址结构    Inet_pton(AF_INET, argv[1], servaddr.sin_addr);    向服务器发起连接,连接成功后client_socket代表了客户机和服务器的一个socket连接    Connect(sockfd, (SA*)servaddr, sizeof(servaddr));  str_cli(stdin, sockfd);    return 0;   } 运行示例红色字体的为输入假设某个回射字符串的服务器已经启动 www.linuxidc.comubuntu:~/code$ gcc my_unp_v1.c client.c -o client www.linuxidc.comubuntu:~/code$ ./client 127.0.0.1 ABCD ABCD CtrlD