https://blog.csdn.net/men_wen/article/details/53456474

Linux網絡編程—I/O復用模型之poll

1.函數poll

poll系統調用和select類似，也是在指定時間內輪詢一定數量的文件描述符，以測試其中是否有就緒者。

#include <poll.h>int poll(struct pollfd *fds, nfds_t nfds, int timeout); //返回值：若成功，返回就緒的描述符個數，若超時則為0，若出錯則為-1

• fds是指向一個pollfd結構第一個元素的指針。每一個元素都是pollfd結構類型，用于測試某個給定描述符fd的條件

struct pollfd {int fd; /* file descriptor */short events; /* requested events */short revents; /* returned events */ };

要測試的條件在events中指定，函數相應的revents成員返回該描述符的狀態，一個為調用值，一個為返回結果，這與select的傳入傳出參數不同。?
events和revents可以設置以下常量的一個或多個的按位或結果：

POLLIN //普通或帶外優先數據可讀,即POLLRDNORM | POLLRDBAND POLLRDNORM //數據可讀 POLLRDBAND //優先級帶數據可讀 POLLPRI //高優先級可讀數據 POLLOUT //普通或帶外數據可寫 POLLWRNORM //數據可寫 POLLWRBAND //優先級帶數據可寫 //下面三個revents不包含 POLLERR //發生錯誤 POLLHUP //發生掛起 POLLNVAL //描述字不是一個打開的文件

• out指定poll函數返回前等待多長時間，它是一個指定應等待毫秒數的正值。

|timeout值|說明|?
|：-：|：-：|?
|-1|永遠等待|?
|0|立即返回，不阻塞進程|?
|>0|等待指定數目的毫秒數|

• nfds 是監控數組中有多少文件描述符需要被監控

如果我們不關心某個特定的描述符，那么可以把與它對應的pollfd結構的fd成員設置為一個負值。poll函數會忽略這樣的pollfd結構的events成員，返回時將其revents成員的值置為0。

select模型最多可以創建一個1024個文件描述符大小的集合，這是因為受到fd_set的固定數據類型的限制，而poll則沒有這樣的問題，因為分配一個pollfd結構的數組并把數組中的元素通知內核稱為調用者的責任。但是poll模型任然使用的是輪詢模型，效率比較低下。

2. poll模型實現

2.1 服務器端

#include "wrap.h" #include <poll.h> #include <limits.h> #include <sys/stropts.h>#define MAXLINE 1024 #define INFTIM -1 #define OPEN_MAX 3000 int main(int argc, char *argv[]) {int i, maxi, listenfd, connfd, sockfd;int nready;ssize_t n;char buf[MAXLINE];socklen_t clilen;struct pollfd client[OPEN_MAX];struct sockaddr_in clientaddr;listenfd = start_ser(argv[1], argv[2]);//監聽文件描述符 該函數參考selectclient[0].fd = listenfd;//將監聽文件描述符加入pollfd數組中client[0].events = POLLIN;//設置為輸入可讀for(i = 1; i < OPEN_MAX; i++){//初始化結構體數組client[i].fd = -1;}maxi = 0;while(1){nready = poll(client, maxi+1, INFTIM); //阻塞等待注冊時間發生if(client[0].revents & POLLIN){//當監聽文件描述符響應有新連接請求clilen = sizeof(clientaddr);connfd = Accept(listenfd, (struct sockaddr *)&clientaddr, &clilen);//接受新客戶for(i = 1; i < OPEN_MAX; i++){if(client[i].fd < 0){client[i].fd = connfd; //把新客戶的文件描述符加入數組break;}}if(i == OPEN_MAX){ //連接新客戶上限Close(connfd);perr_exit("too many clients");}client[i].events = POLLIN; //新客戶端的處理事件if(i > maxi){maxi = i; //更新最大值}if(--nready == 0){ //沒有可讀的描述符跳過本次循環continue;}}for(i = 1; i <= maxi; i++){ //請求所有客戶端的數據if((sockfd = client[i].fd) < 0){continue;}if(client[i].revents & POLLIN){ //POLLIN事件發生memset(buf, '\0', MAXLINE);if((n = Read(sockfd, buf, MAXLINE-1)) < 0){if(errno == ECONNRESET){ //當客戶端發送resetClose(sockfd);client[i].fd = -1;}else{perr_exit("read err");}}else if(n == 0){Close(sockfd);client[i].fd = -1;}else{printf("client : %s\n", buf);}if(--nready == 0){ //沒有可讀的描述符跳過本次循環break;}}}}Close(connfd);Close(listenfd);return 0; }

• 
  

2.2客戶端

#include "wrap.h"int main(int argc, char *argv[]) {struct sockaddr_in serveraddr;int connfd;connfd = Socket(AF_INET, SOCK_STREAM, 0);bzero(&serveraddr, sizeof(serveraddr));serveraddr.sin_family = AF_INET;serveraddr.sin_port = htons(atoi(argv[2]));inet_pton(AF_INET, argv[1], &serveraddr.sin_addr);Connect(connfd, (struct sockaddr *)&serveraddr, sizeof(serveraddr));char buf[1024];while((fgets(buf, 1024, stdin)) != NULL){Write(connfd, buf, strlen(buf));}Close(connfd);return 0; }

• 
  

2.3程序測試結果

創作挑戰賽新人創作獎勵來咯，堅持創作打卡瓜分現金大獎

總結

以上是生活随笔為你收集整理的Linux网络编程---I/O复用模型之poll的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。