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.pswp.cn/news/383851.shtml
繁體地址，請注明出處：http://hk.pswp.cn/news/383851.shtml
英文地址，請注明出處：http://en.pswp.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