当前位置： 首页 > news >正文

dedecms学校网站模板电商发展趋势和未来

news 2025/11/6 17:55:50
dedecms学校网站模板,电商发展趋势和未来,户外拓展网站源码,怎样用电脑做网站参考博客：https://blog.csdn.net/sjsjnsjnn/article/details/128371848 一、poll 介绍 poll 是 Unix/Linux 系统中用于实现多路 IO 复用的一种机制，主要用于监控多个文件描述符（File Descriptor, FD）的状态变化（如可…

参考博客：https://blog.csdn.net/sjsjnsjnn/article/details/128371848

一、poll 介绍

poll 是 Unix/Linux 系统中用于实现多路 IO 复用的一种机制，主要用于监控多个文件描述符（File Descriptor, FD）的状态变化（如可读、可写、异常等）。它允许程序在单个线程中同时处理多个客户端连接，避免了为每个连接创建单独线程的资源开销，是高性能网络服务器的基础组件之一。

二、poll 数据结构

poll 基于 pollfd 结构体来管理文件描述符，其定义如下：

struct pollfd {int   fd;         // 要监控的文件描述符short events;     // 期望监控的事件（输入事件）short revents;    // 实际发生的事件（输出事件，由内核填充）
};
  • events 可设置的事件（常用）：
    • POLLIN：数据可读（包括普通数据和带外数据）
    • POLLOUT：数据可写
    • POLLERR：发生错误
    • POLLHUP：连接挂断
    • POLLNVAL：文件描述符无效
  • revents 返回的事件：是 events 中实际发生的事件的位掩码组合。

在这里插入图片描述

我们主要关注表格中标红的事件即可；

注：

  • events成员就是用户告诉内核，需要关心哪些文件描述符上的哪些事件。
  • revents成员就是右内核告诉用户，你让我关心的这些文件描述上的事件，有哪些文件描述符已经就绪了。
三、poll 函数原型与参数解析
int poll(struct pollfd fds[], nfds_t nfds, int timeout);
  • 参数说明：
    • fds：pollfd 结构体数组，存储需要监控的文件描述符及事件
    • nfds：数组中有效元素的数量（需小于 FD_SETSIZE，通常为 1024）
    • timeout：超时时间（毫秒）：
      • -1：永久阻塞，直到有事件发生
      • 0：立即返回，不阻塞
      • >0：等待指定毫秒数，超时返回 0
  • 返回值：
    • >0：发生事件的文件描述符数量
    • 0：超时，无事件发生
    • -1：错误（如 EINTR 被信号中断，或 ENOMEM 内存不足）

四、poll的基本工作流程

我们要实现一个简单的poll服务器，该服务器要做的就是读取客户端发来的数据并进行打印，那么这个poll服务器的工作流程应该是这样的：

  1. 首先完成基本的套接字创建、绑定和监听。

  2. poll的第一个参数是一个数组结构，里面包含了文件描述符、需要关心的事件和实际发送的事件。poll实现的服务器就不需要再利用额外的数组，只需要定义出struct pollfd fd_array数组，每个数组元素都对应着一个文件描述和所关心的事件，只需要内核检测到对应的文件描述符上的事件是否就绪并给予填充。

  3. 调用poll函数之前，我们需要将监听套接字设置到这个struct pollfd fd_array数组。因为监听套接字的读事件就绪就是有新的连接到来，所有是我们要关心的文件描述符。

  4. 紧接着不断的事件循环，与select不同的是，poll不需要每次重新设置文件描述符和相应的事件，只要在最初设置好后，以后就会一直帮我们关心相应的文件描述符和事件。因为注册事件和实际事件是分开的。

  5. 当调用poll函数时，poll检测到某些文件描述符有读事件就绪后，会将其设置到对应文件描述的结构体中的第三个成员中。已告知用户，就可以执行相应的读操作了。

  6. 如果读事件就绪是监听套接字，则调用accept函数从底层全连接队列中获取已经建立连接好的连接，并将这些连接设置到struct pollfd fd_array数组中，设置好你所需要关心的事件，偏于再次调用poll函数时，关心这些连接上的对应事件。

  7. 如果读事件就绪是普通的套接字（即建立好连接的哪些套接字），则调用read函数读取客户端发来的数据并进行打印输出。

  8. 当然读事件就绪也可能是因为客户端关闭了连接，此时服务器应该调用close关闭该套接字，并将该套接字从struct pollfd fd_array数组中清除，因为下一次不需要再关心该文件描述符了。

五、基于poll 的服务器设计

5.1 代码实现

下面是封装的socket接口

#pragma once
#include <iostream>
#include <sys/socket.h>
#include <sys/types.h>
#include <unistd.h>
#include <arpa/inet.h>
#include <cstring>
#include <netinet/in.h>class Sock
{public:static int Socket(){int sock = socket(AF_INET, SOCK_STREAM, 0);if (sock < 0){std::cerr << "socket error" << std::endl;exit(1);}return sock;}static void Bind(int sock, uint16_t port){struct sockaddr_in local;memset(&local, 0, sizeof(local));local.sin_family = AF_INET;local.sin_addr.s_addr = INADDR_ANY;local.sin_port = htons(port);if (bind(sock, (struct sockaddr *)&local, sizeof(local)) < 0){std::cout << "bind error !" << std::endl;exit(2);}}static void Listen(int sock){if (listen(sock, 5) < 0){std::cerr << "listen error" << std::endl;exit(3);}}static int Accept(int sock){struct sockaddr_in peer;socklen_t len = sizeof(peer);int fd = accept(sock, (struct sockaddr *)&peer, &len);if (fd >= 0){return fd;}else{return -1;}}static void Connect(int sock, std::string ip, uint16_t port){struct sockaddr_in server;memset(&server, 0, sizeof(server));server.sin_family = AF_INET;server.sin_port = htons(port);server.sin_addr.s_addr = inet_addr(ip.c_str());if (connect(sock, (struct sockaddr *)&server, sizeof(server) == 0)){std::cout << "connect sucess" << std::endl;}else{std::cout << "connect failed" << std::endl;exit(4);}}
};

完整的poll服务器代码

#include<poll.h>
#include<string>#include"sock.hpp"
using namespace std;#define NUM 128
struct pollfd fd_array[NUM]; //pollfd数组
int listen_sock = 0;void handle(int index){if(fd_array[index].revents & POLLIN){std::cout << "sock:" << fd_array[index].fd << " is ready to read !" << std::endl;if(fd_array[index].fd == listen_sock){std::cout << "listen_sock:" << listen_sock << "has a new connection !" << std::endl;int sock = Sock::Accept(fd_array[index].fd);if(sock >= 0){std::cout << "get a new connection:" << sock << std::endl;int pos = 1;for(pos ; pos < NUM ; ++ pos){if(fd_array[pos].fd == -1){break;}}if(pos < NUM){fd_array[pos].fd = sock;fd_array[pos].events = 0;fd_array[pos].revents = 0;std::cout << "new connection has been added to fd_array[" << pos << "]" << std::endl;}else{std::cout << "server has been full!" << std::endl;close(sock);}}}else{std::cout << "sock:" << fd_array[index].fd << " has s read event !" << std::endl;char buffer[1024];memset(buffer,0,sizeof(buffer));ssize_t len = recv(fd_array[index].fd,buffer,sizeof(buffer),0);if(len < 0){std::cout << "recv failed !" << std::endl;exit(2);}else if(len == 0){close(fd_array[index].fd);fd_array[index].fd = -1;fd_array[index].events = 0;fd_array[index].revents = 0;std::cout << "fd_array[" << index <<"] has been set -1" << std::endl;std::cout << "connection has been closed !" << std::endl;}else{buffer[len] = '\0';std::cout << "sock:" << fd_array[index].fd << "send:" << buffer << std::endl;}}}
}int main(int argc , char* argv[]){if(argc < 2){std::cerr << "argc < 2" << std::endl;return 1;}uint16_t port = (uint16_t)atoi(argv[1]);listen_sock = Sock::Socket();Sock::Bind(listen_sock,port);Sock::Listen(listen_sock);fd_array[0].fd = listen_sock;for(int i = 0 ; i < NUM ; ++i){fd_array[i].fd = -1;fd_array[i].events = 0;fd_array[i].revents = 0; //由内核填充}std::cout << "server is listening on:" << port << std::endl;while(true){int timeout = -1;int ret = poll(fd_array,NUM,timeout);if(ret == -1){std::cerr << "poll error !" << std::endl;break;}else if(ret == 0){std::cerr << "poll timeout !" << std::endl;continue;}else{for(int i = 0 ; i < NUM ; ++i){handle(i);}}}for(int i = 0 ; i < NUM ; ++i){if(fd_array[i].fd != -1){close(fd_array[i].fd);fd_array[i].fd = -1;fd_array[i].events = 0;fd_array[i].revents = 0;}}return 0;}

编写Makefile进行编译

CXX = g++CXXFLAGS = -Wall -std=c++14SRCS = main.cpp OBJS = $(SRCS:.cpp=.o)TARGET = serverall:$(TARGET)$(TARGET):$(OBJS)$(CXX) $(CXXFLAGS) -o $(TARGET) $(OBJS)%.o:%.cpp$(CXX) $(CXXFLAGS) -c $< -o $@clean:rm -f $(OBJS) $(TARGET).PHONY:all clean

在这里插入图片描述

5.2 运行结果

客户端连接服务器

在这里插入图片描述

客户端发送信息到服务端
在这里插入图片描述

客户端关闭

在这里插入图片描述

六、总结

6.1 poll的优缺点

优点：

不同与select使用三个位图来表示三个fdset的方式，poll使用一个pollfd的指针实现。

  • pollfd结构包含了要监视的event和发生的event，不再使用select“参数-值”传递的方式。接口使用比select更方便。
  • poll并没有最大数量限制 (但是数量过大后性能也是会下降)。

缺点：

poll中监听的文件描述符数目增多时

  • 和select函数一样，poll返回后，需要轮询pollfd来获取就绪的描述符。
  • 每次调用poll都需要把大量的pollfd结构从用户态拷贝到内核中。
  • 同时连接的大量客户端在一时刻可能只有很少的处于就绪状态, 因此随着监视的描述符数量的增长, 其效率也会线性下降。

6.2 poll与select对比

特性selectpoll
数据结构fd_set（固定大小数组）pollfd 结构体数组
最大连接数受限于 FD_SETSIZE（通常 1024）理论上无固定限制（受系统资源限制）
事件管理基于位掩码，需手动重置结构体数组，事件独立设置
性能线性扫描所有 fd，O (n)线性扫描所有 fd，O (n)
移植性跨平台（Unix/Linux/Windows）主要用于 Unix/Linux

总结：poll 相比 select 解决了 fd_set 大小固定的问题，但两者在高并发场景下仍存在共同缺陷：每次调用都需遍历所有监控的 fd，当连接数较多而活跃连接较少时，性能会大幅下降

更多资料：https://github.com/0voice

http://www.yayakq.cn/news/493415/

相关文章：

  • 大收录量的网站怎么做it外包服务平台
  • 网站建设 睿达科网站开发微信公众号自定义菜单
  • 企业网站建设规划的基本原则有哪些有哪些做问卷调查赚钱的网站6
  • 织梦网站流动广告代码网站开发时间段
  • 做喜报的网站ppt模板怎么直接套用
  • 江西省住房城乡建设厅网站软件推广赚佣金渠道
  • 神秘网站房产网站建设方案
  • 旅游地网站制作二手旧书网站开发设计报告
  • 360免费建站官网如何制作app软件演示教程
  • 枣庄网站建设制作wordpress 侧边栏插件
  • 中文个人网站欣赏网站建站视频教程
  • 哪个网站抢注域名快wdcp创建网站
  • 网站设计的内容网站地图的好处
  • 网站建设方案详解网站运营流程
  • 开封建设局网站网站首页做几个关键词
  • 建设银行网站上交医保新干做网站
  • 优秀英文企业网站绍兴网站建设哪家专业
  • 电子商务网站建设的总体设计新建网站怎么保存
  • 网站开发的关系图和e-r图百度网站建设怎么联系
  • 做电影网站的软件大连网站建设网站建设
  • 网站做电子商务需要什么资质注重网站建设 把好宣传思想关口
  • 进行优化简阳seo排名优化课程
  • 做网站公司长沙哪家好福田莲花网站建设
  • google seo整站优化凡客诚品官网app
  • 做教育的网站女生wordpress网站适合
  • 网站设计要求网站统计 wordpress
  • 用脚手架如何搭建项目做网站赤峰微信网站建设
  • wordpress 扒站教程青岛做网站费用
  • 大良手机网站建设怎么在网站做外部链接
  • 有什么网站用名字做图片广州百度竞价开户