poll函数

 #include <poll.h>
int poll(struct pollfd *fds, nfds_t nfds, int timeout);

参数:

  • fds:监听的文件描述符【数组】
struct pllfd {int fd;         待监听的文件描述符short events;   待监听的文件描述符对应的监听事件short revents;  传入时,给0; 如果满足对应事件的话,返回非0
}
  • nfds:监听数组的,实际有效监听个数
  • 超时时长。单位:毫秒
//server.c
#include <unistd.h>#define SERV_PROT 8000
#define MAXLINE 80
#define OPEN_MAX 1024int main(int argc, char *argv[])
{int i, J, maxi, listenfd, connfd, sockfd;int nread;ssize_t n;char buf[MAXLINE], str[INET_ADDRSTRLEN];  //INE_ADDRSTRLEN 16socklen_t clilen;struct pollfd client[OPEN_MAX];struct sockaddr_in cliaddr, seraddr;listenfd = Socket(AF_INET, SOCK_STREAM, 0);int opt = 1;setsockopt(listenfd, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt));bzero(&serv_addr, sizeof(serv_addr));serv_addr.sin_family = AF_INET;serv_addr.sin_addr.s_addr = htonl(INADDR_ANY);serv_addr.sin_port = htons(SERV_PROT);Bind(listen, (struct sockaddr*)&serv_addr, sizeof(serv_addr));Listen(listenfd, 128);client[0].fd = listenfd;  //要监听的第一个文件描述符存入client[0]client[0].events = POLLIN; //listen监听普通读事件for (i = 1; i < OPEN_NAX; ++i)client[i].fd = -1;  //用-1初始化client[]里剩下, 0也是文件描述符,不能用mxi = 0;   //client[]数组有效元素中最大元素的下标for ( ; ; ){nread = poll(client, maxi + 1, -1);  //阻塞监听是否有客户端连接请求if (client[0].revents & POLLIN) //listen有读事件就绪{clilen = sizeof(cliaddr);connfd = Accept(listenfd, (struct sockaddr *)&cliaddr, &clilen); //接受客户端请求Accept不会阻塞printf("receive from %s at PORT %d\n",inet_ntop(AF_INET, &cliaddr.sin_addr, str, sizeof(str)),ntohs(cliaddr.sin_port));for (i = 1; i < OPEN_MAX; i++)if (client[i].fd < 0){client[i].fd = connfd; //找到client[]中空闲的位置,存放accept返回的connfdbreak;}if (i == OPEN_MAX) //达到最大客户端perr_exit("too many client");client[i].events = POLLIN; //设置刚返回的connfd监控读事件if (i > maxi)maxi = i;  //更新client[]中最大元素下标if (--nread <= 0)continue;   //没有更多就绪事件时, 继续回到poll阻塞}for (i = 1; i < maxi; i++){if ((sockfd = client[i].fd) < 0)continue;if (client[i].revents & POLLIN){if (n = Read(sockfd, buf, MAXLINE)) < 0){if (errno == ECONNRESET) //收到RST标志{printf("client[%d] aborted connection\n", i);Close(sockfd);client[i].fd = -1;   //poll中不监控该文件描述符,直接置为-1即可,不用像select中那样移除}elseperr_exit("read error");}else if (n == 0)  //说明客户端先关闭链接{printf("client[%d] closed connection\n", i);Close(sockfd);clent[i].fd = -1;}else{for (j = 0; j < n; ++j)buf[j] = toupper(buf[j]);Write(sockfd, buf, n);if (--nread <= 0)break;}}}}return 0;
}

 

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

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

相关文章

Redis高级项目实战,java配置jdk环境时

Spring Security观后感——手绘思维脑(供参考) Spring Security手绘思维脑图 手绘的思维导图&#xff0c;是我自己根据自身的情况读完这套阿里出品的Spring Security王者晋级文档之后所绘的&#xff0c;相当于是一个知识的总结与梳理&#xff0c;我将其分为***“核心组件”与“…

select函数(一)

int select(int nfds, fd_set *readfds, fd_set *writefds, fd_set *exceptfds, struct timeval *timeout); 参数&#xff1a; nfds&#xff1a;监控的文件描述符集里最大文件描述符加1&#xff0c;因为此参数会告诉内核检测前多少个文件文件描述符readfs&#xff1a;监控有读…

Redis高级项目实战,阿里P7级别面试经验总结

第一次压测 惨不忍睹&#xff0c;平均响应时间150ms&#xff0c;而且在这次压测过程中还发现其它的问题&#xff0c;后台报错&#xff0c;经查是OpenSearch每秒查询次数限制 优化代码与配置 1、修改OpenSearch配置&#xff0c;并且将压测环境中的OpenSearch连接地址改为内网地…

Makefile用法链接

Makefile的编写及四个特殊符号的意义、$、$^、$ <font face"字体" size"字号" color"颜色">这里是需要突出显示的内容</font> <font color#0099ff size12 face"黑体">黑体</font>

Redis高频面试笔记:java版本号比较算法

1.三重心智模型 先给大家科普一个概念&#xff0c;“三重心智模型”。 认知科学家斯坦诺维奇&#xff0c;将人的心智模式&#xff0c;分成了三个部分。 第一层是自主心智&#xff0c;自主心智是我们通过进化与内隐学习获得。比如&#xff0c;我们看到蛇就会害怕&#xff0c;情…

Redis高频面试笔记:mysql8.0新特性

一、服务发布简介 分布式系统架构下&#xff0c;服务发布是一件很麻烦的事情&#xff0c;特别是在构建自动发布流程和灰度测试的策略两个核心方面。通常情况下如果不涉及数据层面的灰度流程&#xff0c;服务可以灰度上线&#xff0c;或者滚动上线&#xff0c;这两种方式很常用…

Makefile (二)

一、line1的源码 line1.h #ifndef _LINE_1_H #define _LINE_1_H void line1_print(const char *strMsg); #endifline1.cpp #include "line1.h" #include <stdio.h> void line1_print(const char *strMsg) {printf("This is line1 print %s.\r\n",st…

RocketMQ避坑指南:springcloud教程权威指南

1. Java 堆空间 **发生频率&#xff1a;**5颗星 造成原因 无法在 Java 堆中分配对象 吞吐量增加 应用程序无意中保存了对象引用&#xff0c;对象无法被 GC 回收 应用程序过度使用 finalizer。finalizer 对象不能被 GC 立刻回收。finalizer 由结束队列服务的守护线程调用&a…

IO多路复用之epoll

一、epoll函数族 1. 函数epoll_creat&#xff1a; 该函数生成一个epoll专用的文件描述符 #include <sys/epoll.h> int epoll_creae(int size); //epoll上能关注的最大描述符数 2. epoll_ctl&#xff1a;用于控制某个epoll文件描述符事件&#xff0c;可以注册、修改、删…

26. 删除排序数组中的重复项

给定一个排序数组&#xff0c;你需要在原地删除重复出现的元素&#xff0c;使得每个元素只出现一次&#xff0c;返回移除后数组的新长度。 不要使用额外的数组空间&#xff0c;你必须在原地修改输入数组并在使用 O(1) 额外空间的条件下完成。 示例 1: 给定数组 nums [1,1,2], …

Leetcode 31. Pow(x, n) 解题报告

class Solution {public:double myPow(double x, int n) {double res 1.0;for(int i n; i ! 0; i / 2){if(i % 2 ! 0)res * x;x * x;}return n < 0 ? 1 / res : res;} };

572. 另一个树的子树

给定两个非空二叉树 s 和 t&#xff0c;检验 s 中是否包含和 t 具有相同结构和节点值的子树。s 的一个子树包括 s 的一个节点和这个节点的所有子孙。s 也可以看做它自身的一棵子树。 示例 1: 给定的树 s: 3/ \4 5/ \1 2给定的树 t&#xff1a; 4 / \1 2返回 true&#x…

二叉树中序遍历的三种方法

二叉树是一种重要的数据结构&#xff0c;对二叉树的遍历也很重要。这里简单介绍三种二叉树中序遍历的方法。二叉树的中序遍历就是首先遍历左子树&#xff0c;然后访问当前节点&#xff0c;最后遍历右子树。对于下面的二叉树&#xff0c;中序遍历结果如下&#xff1a; 结果&…

reverse函数:反转容器内容

reverse函数可以反转一个容器中的内容&#xff0c;包含在<algorithm>库中。 1、函数原型 reverse函数等同于下面的代码&#xff1a; template <class BidirectionalIterator> void reverse (BidirectionalIterator first, BidirectionalIterator last) {while ((…

服务器框架

一、Reactor模式 Reactor模式&#xff0c;它要求主线程&#xff08;I/O处理单元&#xff09;只负责监听文件描述符上是否有事件发生&#xff0c;有的话就立即将该事件通知工作线程&#xff08;逻辑单元&#xff09;。除此之外&#xff0c;主线程&#xff08;I/O处理单元&#…

使用CreateFile读写文件

微软提供了强大的文件读写操作的编程接口&#xff0c;所以可以通过调用API函数实现文件的读写操作。这里通过CreateFile函数来实现。 要对文件进行读写操作&#xff0c;首先要调用CreateFile函数打开或者创建文件&#xff0c;函数具体格式如下&#xff1a; HANDLE CreateFile(…

Leetcode 9. 回文数(Palindrome Number)

判断一个整数是否是回文数。回文数是指正序&#xff08;从左向右&#xff09;和倒序&#xff08;从右向左&#xff09;读都是一样的整数。 示例 1: 输入: 121 输出: true示例 2: 输入: -121 输出: false 解释: 从左向右读, 为 -121 。 从右向左读, 为 121- 。因此它不是一个…

使用CreateThread函数创建线程

线程是进程中的一个实体&#xff0c;是被系统独立调度和分派的基本单位。一个进程可以拥有多个线程&#xff0c;但是一个线程必须有一个进程。线程自己不拥有系统资源&#xff0c;只有运行所必须的一些数据结构&#xff0c;但它可以与同属于一个进程的其它线程共享进程所拥有的…

Leetcode 16. 最接近的三数之和(3Sum Closest)

解法一&#xff1a; class Solution { public:int threeSumClosest(vector<int>& nums, int target) {int closest nums[0] nums[1] nums[2];int diff abs(closest - target);sort(nums.begin(), nums.end());for (int i 0; i < nums.size() - 2; i) {int…

BMP格式详解

BMP&#xff08;全称Bitmap&#xff09;是Windows操作系统中的标准图像文件格式&#xff0c;可以分成两类&#xff1a;设备相关位图&#xff08;DDB&#xff09;和设备无关位图&#xff08;DIB&#xff09;&#xff0c;使用非常广。它采用位映射存储格式&#xff0c;除了图像深…