poll函数实现多路复用

http://blog.csdn.net/xluren/article/details/8206371

结构体pollfd

struct pollfd
{
int fd;               //file descriptor
short event;   //event of interest on fd
short reven;  //event that occurred on fd
}

每一个pollfd结构体指定了一个被监视的文件描述符，可以传递多个结构体，指示poll()监视多个文件描述符。每个结构体的events域是监视该文件描述符的事件掩码，由用户来设置这个域。revents域是文件描述符的操作结果事件掩码。内核在调用返回时设置这个域。events域中请求的任何事件都可能在revents域中返回。

pollfd结构体合法的事件

POLLIN
有数据可读。
POLLRDNORM
有普通数据可读。
POLLRDBAND
有优先数据可读。
POLLPRI
有紧迫数据可读。
POLLOUT
写数据不会导致阻塞。
POLLWRNORM
写普通数据不会导致阻塞。
POLLWRBAND
写优先数据不会导致阻塞。
POLLMSG
SIGPOLL 消息可用。
此外，revents域中还可能返回下列事件：
POLLER
指定的文件描述符发生错误。
POLLHUP
指定的文件描述符挂起事件。
POLLNVAL
指定的文件描述符非法。
这些事件在events域中无意义，因为它们在合适的时候总是会从revents中返回。使用poll()和select()不一样，你不需要显式地请求异常情况报告。
POLLIN | POLLPRI等价于select()的读事件，POLLOUT |POLLWRBAND等价于select()的写事件。POLLIN等价于POLLRDNORM |POLLRDBAND，而POLLOUT则等价于POLLWRNORM。
例如，要同时监视一个文件描述符是否可读和可写，我们可以设置 events为POLLIN |POLLOUT。在poll返回时，我们可以检查revents中的标志，对应于文件描述符请求的events结构体。如果POLLIN事件被设置，则文件描述符可以被读取而不阻塞。如果POLLOUT被设置，则文件描述符可以写入而不导致阻塞。这些标志并不是互斥的：它们可能被同时设置，表示这个文件描述符的读取和写入操作都会正常返回而不阻塞。
timeout参数指定等待的毫秒数，无论I/O是否准备好，poll都会返回。timeout指定为负数值表示无限超时；timeout为0指示poll调用立即返回并列出准备好I/O的文件描述符，但并不等待其它的事件。这种情况下，poll()就像它的名字那样，一旦选举出来，立即返回。

函数原型

int poll(struct pollfd fdarray[], nfds_t nfds, int timeout);
poll返回值和错误代码
成功时，poll()返回结构体中revents域不为0的文件描述符个数；如果在超时前没有任何事件发生，poll()返回0；失败时，poll()返回-1，并设置errno为下列值之一：
EBADF
一个或多个结构体中指定的文件描述符无效。
EFAULT
fds指针指向的地址超出进程的地址空间。
EINTR
请求的事件之前产生一个信号，调用可以重新发起。
EINVAL
nfds参数超出PLIMIT_NOFILE值。
ENOMEM
可用内存不足，无法完成请求。

以上理论摘自http://www.cnblogs.com/nathan-1988/archive/2012/07/01/2571786.html 谢谢~~~

代码如下所示：

[cpp] view plain copy
  1. #include <stdio.h>  
  2. #include <stdlib.h>  
  3. #include <unistd.h>  
  4. #include <errno.h>  
  5. #include <string.h>  
  6. #include <sys/types.h>  
  7. #include <sys/socket.h>  
  8. #include <netinet/in.h>  
  9. #include <arpa/inet.h>  
  10. #include <poll.h>  
  11. #define MYPORT 6666    // the port users will be connecting to  
  12.   
  13. #define BACKLOG 5     // how many pending connections queue will hold  
  14. #ifndef INFTIM  
  15. #define INFTIM -1  
  16. #endif  
  17. #define BUF_SIZE 1024  
  18. #define MAXLINE 100  
  19. #define MAXCLIENT 5  
  20. int fd_access[BACKLOG];    // accepted connection fd  
  21. int conn_amount;    // current connection amount  
  22.   
  23. int main(void)  
  24. {  
  25.         int sock_fd, new_fd,len,conn_no;  // listen on sock_fd, new connection on new_fd  
  26.         struct sockaddr_in server_addr;    // server address information  
  27.         struct sockaddr_in client_addr; // connector's address information  
  28.         socklen_t sin_size;  
  29.         char buf[BUF_SIZE];  
  30.         int result;  
  31.         int i;  
  32.         int maxsock=0;  
  33.         int conn_fd;  
  34.         struct pollfd client[MAXCLIENT];  
  35.         if ((sock_fd = socket(AF_INET, SOCK_STREAM, 0)) == -1)   
  36.         {  
  37.                 perror("socket");  
  38.                 exit(1);  
  39.         }   
  40.         server_addr.sin_family = AF_INET;         // host byte order  
  41.         server_addr.sin_port = htons(MYPORT);     // short, network byte order  
  42.         server_addr.sin_addr.s_addr = INADDR_ANY; // automatically fill with my IP  
  43.         memset(server_addr.sin_zero, '\0', sizeof(server_addr.sin_zero));  
  44.         if (bind(sock_fd, (struct sockaddr *)&server_addr, sizeof(server_addr)) == -1)   
  45.         {  
  46.                 perror("bind");  
  47.                 exit(1);  
  48.         }  
  49.         if (listen(sock_fd, BACKLOG) == -1)   
  50.         {  
  51.                 perror("listen");  
  52.                 exit(1);  
  53.         }  
  54.         printf("listen port %d\n", MYPORT);  
  55.   
  56.         sin_size = sizeof(client_addr);  
  57.         client[0].fd=sock_fd;  
  58.         client[0].events=POLLIN;  
  59.         for(i=1;i<MAXCLIENT;i++)  
  60.                 client[i].fd=-1;  
  61.         while (1)   
  62.         {  
  63.                 printf("helo\n");  
  64.                 result=poll(client,maxsock+1,INFTIM);  
  65.                 if(client[0].revents&POLLIN)  
  66.                 {  
  67.                         new_fd=accept(sock_fd,(struct sockaddr*)&client_addr,&sin_size);  
  68.                         for(i = 1; i < MAXCLIENT;++i)  
  69.                         {  
  70.                                 if( client[i].fd < 0 )  
  71.                                 {         
  72.                                         client[i].fd = new_fd;  
  73.                                         client[i].events = POLLIN;//POLLRDNORM;  
  74.                                         break;  
  75.                                 }  
  76.                         }  
  77.                         if( i == MAXCLIENT)  
  78.                         {  
  79.                                 printf("too many clients");   
  80.                                 exit(1);  
  81.                         }  
  82.                         if( i > maxsock )  
  83.                                 maxsock = i;  
  84.                         if( --result<= 0 )  
  85.                                 continue;  
  86.                 }  
  87.                 for(i = 1; i <= maxsock; i++)  
  88.                 {  
  89.                         if( (conn_fd = client[i].fd) < 0)  
  90.                                 continue;  
  91.                         if(client[i].revents & (POLLIN | POLLERR))  
  92.                         {  
  93.                                 if( (len = read(conn_fd, buf, MAXLINE)) < 0)   
  94.                                 {  
  95.                                         if( errno == ECONNRESET)  
  96.                                         {  
  97.                                                 close(conn_fd);  
  98.                                                 client[i].fd = -1;  
  99.                                         }  
  100.                                         else  
  101.                                                 perror("read error");  
  102.                                 }  
  103.                                 else if(len == 0)  
  104.                                 {  
  105.                                         close(conn_fd);  
  106.                                         client[i].fd = -1;  
  107.                                 }  
  108.                                 else  
  109.                                         printf("%s\n",buf);  
  110.                                 if(--conn_no <= 0)  
  111.                                         break;  
  112.   
  113.                         }  
  114.                 }  
  115.         }  
  116.         exit(0);  
  117. }  
  118.   
  119. (END)   


以上是服务器端

客户端代码见http://blog.csdn.net/xluren/article/details/8043484#t15


本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/383851.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

抽象类（纯虚函数、虚函数）和虚基类（虚继承）

抽象类（纯虚函数、虚函数）和虚基类（虚继承）

C多态 C的多态包括静态多态和动态多态&#xff0c;静态多态包括函数重载和泛型编程&#xff0c;动态多态包括虚函数。静态多态实在编译期间就能确定&#xff0c;动态多态实直在程序运行时才能确定。 抽象类 虚函数 在默认情况下对函数成员调用实施的是静态连编&#xff0c;…
阅读更多...
socket通信之最简单的socket通信

socket通信之最简单的socket通信

http://blog.csdn.net/xluren/article/details/8043484#t15 套接字有三种类型 流式套接字&#xff08;SOCK_STREAM&#xff09;&#xff0c;数据报套接字&#xff08;SOCK_DGRAM&#xff09;及原始套接字。 1.流式套接字提供面向连接、可靠的数据传输服务&#xff0c;数据按字节…
阅读更多...
Java环境配置

Java环境配置

自己安装的时候按照一般的安装方法先配置了JDK的环境&#xff0c;能够成功显示java版本后我在安装eclipse的时候一直提示错误&#xff1a; Unfortunately the Java version needed to run Eclipse Installer couldn’t be found on your system. You need the following versio…
阅读更多...
Linux I/O复用之select函数详解

Linux I/O复用之select函数详解

http://blog.csdn.net/y396397735/article/details/55004775 select函数的功能和调用顺序 使用select函数时统一监视多个文件描述符的&#xff1a; 1、 是否存在套接字接收数据&#xff1f; 2、 无需阻塞传输数据的套接字有哪些? 3、 哪些套接字发生了异常&#xff1f; sel…
阅读更多...
【Java学习笔记一】类和对象

【Java学习笔记一】类和对象

面向对象程序设计的一个一个重要特点是&#xff1a;封装性。 这里的封装性有两方面含义&#xff1a;一是将有关的数据和操作代码封装在一个对象中形成一个基本单位&#xff0c;各个对象之间相互独立互不干扰&#xff0c;二是将对象中某些部分对外隐蔽&#xff0c;即隐蔽其内部细…
阅读更多...
深入研究socket编程（3）——使用select函数编写客户端和服务器

深入研究socket编程（3）——使用select函数编写客户端和服务器

http://blog.csdn.net/chenxun_2010/article/details/50488394 首先看原先《UNIX网络编程——并发服务器&#xff08;TCP&#xff09;》的代码&#xff0c;服务器代码serv.c&#xff1a; [cpp] view plaincopy #include<stdio.h> #include<sys/types.h> #inclu…
阅读更多...
Java简单输入输出

Java简单输入输出

不同于面向过程中有直接的输入输出函数&#xff0c;Java中的输入输出只能通过类来实现。 比较常见的一种是使用Scanner类 需要引入java.util包&#xff0c;即在文件开始加上语句import java.util.*;创建Scanner类对象&#xff0c;属于标准输入流。 例如Scanner snew Scanner(S…
阅读更多...
Ubuntu安装搭建Clion环境

Ubuntu安装搭建Clion环境

呜呜呜&#xff0c;太辛苦了&#xff0c;我终于安装好这个了。 大概过程就是先在官网下载安装包&#xff0c;然后解压以后用终端移动到对应文件夹下运行clin.sh 运行完以后会有一些窗口&#xff0c;第一个选择don’t~~&#xff0c;然后点击ok 接受&#xff08;你可以不接受…
阅读更多...
UNIX网络编程——select函数的并发限制和 poll 函数应用举例

UNIX网络编程——select函数的并发限制和 poll 函数应用举例

http://blog.csdn.net/chenxun_2010/article/details/50489577 一、用select实现的并发服务器&#xff0c;能达到的并发数&#xff0c;受两方面限制 1、一个进程能打开的最大文件描述符限制。这可以通过调整内核参数。可以通过ulimit -n来调整或者使用setrlimit函数设置&#x…
阅读更多...
【Java学习笔记二】继承和多态

【Java学习笔记二】继承和多态

与C不同的是&#xff0c;在Java中&#xff0c;一个类只能直接继承另一个类&#xff0c;而不允许继承多个类&#xff0c;这个新类称为继承类、派生类或者子类&#xff0c;而被继承的类称为基类或者父类。 继承类能够继承基类的群不属性和行为。 面向对象程序设计的三大特点为&…
阅读更多...
使用poll实现的io多路复用服务端和客户端

使用poll实现的io多路复用服务端和客户端

http://blog.csdn.net/robertkun/article/details/52269313 参考&#xff1a;http://www.cnblogs.com/Anker/p/3261006.html 使用poll实现的io多路复用服务端和客户端。 客户端通过子进程创建多个客户端连接。 客户端每隔1秒向服务端发送一个时间戳&#xff0c; 服务端接收到时…
阅读更多...
【Java学习笔记三】抽象类与接口

【Java学习笔记三】抽象类与接口

对象的类型转换分为自动转换和强制转换两种 派生类向基类转换是自动转换&#xff0c;因为派生类中包含基类基类向派生类的转换是强制转换 强制类型转换是通过在转换对象前面使用圆括号运算符来实现&#xff0c;圆括号内为要转换的目标类型&#xff0c;格式为&#xff1a; (&…
阅读更多...
Epoll 的tcp通信代码（服务器+客户端）

Epoll 的tcp通信代码（服务器+客户端）

http://blog.csdn.net/libinbin_1014/article/details/50096187 Epoll 的tcp通信代码&#xff08;服务器客户端&#xff09; /* gcc -D_LARGEFILE64_SOURCE -D_FILE_OFFSET_BITS64 -I${ORACLE_HOME}/rdbms/public -I${ORACLE_HOME}/rdbms/demo -L${ORACLE_HOME}/lib -lclntsh …
阅读更多...
【Java学习笔记四】Java中的包

【Java学习笔记四】Java中的包

包的声明和引入&#xff1a;在Java语言系统中&#xff0c;Java编译器为每一个类生成一个字节码文件&#xff08;.class&#xff09;&#xff0c;为了对类文件进行分层和按用途分类管理&#xff0c;同时也为了解决相同类名的文件冲突的问题&#xff0c;Java提供了包机制来管理类…
阅读更多...
Linux系统编程——线程池

Linux系统编程——线程池

http://blog.csdn.net/tennysonsky/article/details/46490099# 线程池基本原理 在传统服务器结构中&#xff0c;常是有一个总的监听线程监听有没有新的用户连接服务器&#xff0c;每当有一个新的用户进入&#xff0c;服务器就开启一个新的线程用户处理这 个用户的数据包。这个线…
阅读更多...
【Java学习笔记五】Java异常处理

【Java学习笔记五】Java异常处理

异常通常分为三类&#xff1a; 程序可控制的异常&#xff1a;一般是可预见的错误&#xff0c;不是致命的。例如&#xff1a;除数为0&#xff0c;数组下标越界。程序不可控制的的异常&#xff1a;这种异常往往是致命的&#xff0c;但是系统可以预见的。例如&#xff1a;系统栈溢…
阅读更多...
【C++学习笔记一】C++类和对象详解

【C++学习笔记一】C++类和对象详解

类定义是以关键字class开头&#xff0c;后面跟类的名称。主体是包含在一对花括号中。类定义后必须跟着一个分号或一个声明列表。 类的对象的公共数据成员可以使用直接成员访问运算符.来访问。需要注意的是&#xff0c;私有的成员和受保护的成员不能直接使用成员访问运算符来访…
阅读更多...
C语言实现的简单的线程池

C语言实现的简单的线程池

http://www.linuxidc.com/Linux/2013-01/77619.htm 有时我们会需要大量线程来处理一些相互独立的任务&#xff0c;为了避免频繁的申请释放线程所带来的开销&#xff0c;我们可以使用线程池。下面是一个C语言实现的简单的线程池。 头文件&#xff1a; 1: #ifndef THREAD_POOL_H_…
阅读更多...
C++获取当前时间

C++获取当前时间

可以使用windowsAPI直接获取。 例如&#xff1a; #include<windows.h> #include<cstdio>using namespace std;int main() {SYSTEMTIME now;GetLocalTime(&now);printf("现在是%02d时%02d分%02d秒\n",now.wHour,now.wMinute,now.wSecond);printf(&…
阅读更多...
成员函数后面加上const的作用

成员函数后面加上const的作用

const表示成员函数不会修改类中的数据成员。 规则&#xff1a; 在类中被const 声明的函数只能访问const 函数&#xff0c;而非const 函数可以访问任意成员函数。在成员函数中不管数据是否具有const 属性&#xff0c;编译器检查的的是是否有修改&#xff08;赋值&#xff0c;自…
阅读更多...
最新文章

Copyright @ 2022~2023