159 Linux C++ 通讯架构实战14,epoll 函数代码实战
ngx_epoll_init函数的调用
//(3.2)ngx_epoll_init函数的调用(要在子进程中执行)
//四章,四节 project1.cpp:nginx中创建worker子进程;
//nginx中创建worker子进程
//官方nginx ,一个master进程,创建了多个worker子进程;
// master process ./nginx
// worker process
//(i)ngx_master_process_cycle() //创建子进程等一系列动作
//(i) ngx_setproctitle() //设置进程标题
//(i) ngx_start_worker_processes() //创建worker子进程
//(i) for (i = 0; i < threadnums; i++) //master进程在走这个循环,来创建若干个子进程
//(i) ngx_spawn_process(i,"worker process");
//(i) pid = fork(); //分叉,从原来的一个master进程(一个叉),分成两个叉(原有的master进程,以及一个新fork()出来的worker进程
//(i) //只有子进程这个分叉才会执行ngx_worker_process_cycle()
//(i) ngx_worker_process_cycle(inum,pprocname); //子进程分叉
//(i) ngx_worker_process_init(); //ngx_epoll_init函数的调用
//(i) sigemptyset(&set);
//(i) sigprocmask(SIG_SETMASK, &set, NULL); //允许接收所有信号
//(i) g_socket.ngx_epoll_init(); //初始化epoll相关内容,同时 往监听socket上增加监听事件,从而开始让监听端口履行其职责
//(i) m_epollhandle = epoll_create(m_worker_connections);
//(i) ngx_epoll_add_event((*pos)->fd....);
//(i) epoll_ctl(m_epollhandle,eventtype,fd,&ev);
//(i) ngx_setproctitle(pprocname); //重新为子进程设置标题为worker process
//(i) for ( ;; ) {
ngx_process_events_and_timers(); //处理网络事件和定时器事件
}. .... //子进程开始在这里不断的死循环
//(i) sigemptyset(&set);
//(i) for ( ;; ) {}. //父进程[master进程]会一直在这里循环
ngx_epoll_init 函数内容
该函数从完成的事情有:
1.epoll_create 创建红黑树
2.m_pconnections = new ngx_connection_t[m_connection_n]; 创建连接池 并初始化连接池
3.遍历所有监听socket【监听端口】,我们为每个监听socket增加一个 连接池中的连接
for(pos = m_ListenSocketList.begin(); pos != m_ListenSocketList.end(); ++pos){
c = ngx_get_connection((*pos)->fd); //从连接池中获取一个空闲连接对象
c->listening = (*pos); //连接对象 和监听对象关联,方便通过连接对象找监听对象
(*pos)->connection = c; //监听对象 和连接对象关联,方便通过监听对象找连接对象
//对监听端口的读事件设置处理方法,因为监听端口是用来等对方连接的发送三路握手的,所以监听端口关心的就是读事件
c->rhandler = &CSocekt::ngx_event_accept;
//往监听socket上增加监听事件,从而开始让监听端口履行其职责【如果不加这行,虽然端口能连上,但不会触发ngx_epoll_process_events()里边的epoll_wait()往下走】if(ngx_epoll_add_event((*pos)->fd, //socekt句柄1,0, //读,写【只关心读事件,所以参数2:readevent=1,而参数3:writeevent=0】0, //其他补充标记EPOLL_CTL_ADD, //事件类型【增加,还有删除/修改】c //连接池中的连接 ) == -1) {exit(2); //有问题,直接退出,日志 已经写过了}
}
4.ngx_epoll_add_event 函数 本质上就是epoll_ctl。并设置了回调函数。
#和网络相关
[Net]
#监听的端口数量,一般都是1个,当然如果支持多于一个也是可以的
ListenPortCount = 2
#ListenPort+数字【数字从0开始】,这种ListenPort开头的项有几个,取决于ListenPortCount的数量,
ListenPort0 = 80
ListenPort1 = 443#epoll连接的最大数【是每个worker进程允许连接的客户端数】,实际其中有一些连接要被监听socket使用,实际允许的客户端连接数会比这个数小一些
worker_connections = 1024
//初始化函数【fork()子进程之前干这个事】
//成功返回true,失败返回false
bool CSocekt::Initialize()
{ReadConf(); //读配置项bool reco = ngx_open_listening_sockets(); //打开监听端口return reco;
}//专门用于读各种配置项
void CSocekt::ReadConf()
{CConfig *p_config = CConfig::GetInstance();m_worker_connections = p_config->GetIntDefault("worker_connections",m_worker_connections); //epoll连接的最大项数m_ListenPortCount = p_config->GetIntDefault("ListenPortCount",m_ListenPortCount); //取得要监听的端口数量return;
}
//连接池: 数组,元素数量就是worker_connections【1024】,每个数组元素类型为 ngx_connection_t【结构】; ---结构数组;
//为什么要引入这个数组: 2个监听套接字, 用户连入进来,每个用户多出来一个套接字;
//把 套接字数字跟一块内存捆绑,达到的效果就是将来我通过这个套接字,就能够把这块内存拿出来;
初始化 连接池
当执行完成如下的代码后,参考图
do {i--; //注意i是数字的末尾,从最后遍历,i递减至数组首个元素//好从屁股往前来---------c[i].data = next; //设置连接对象的next指针,注意第一次循环时next = NULL;c[i].fd = -1; //初始化连接,无socket和该连接池中的连接【对象】绑定c[i].instance = 1; //失效标志位设置为1【失效】,此句抄自官方nginx,这句到底有啥用,后续再研究c[i].iCurrsequence = 0; //当前序号统一从0开始//----------------------next = &c[i]; //next指针前移} while (i); //循环直至i为0,即数组首地址m_pfree_connections = next; //设置空闲连接链表头指针,因为现在next指向c[0],注意现在整个链表都是空的m_free_connection_n = m_connection_n; //空闲连接链表长度,因为现在整个链表都是空的,这两个长度相等;
ngx_get_connection()重要函数:从连接池中找空闲连接;注意在这段代码中 应该只是给 监听fd 一个空闲连接对象。
for(pos = m_ListenSocketList.begin(); pos != m_ListenSocketList.end(); ++pos){c = ngx_get_connection((*pos)->fd); //从连接池中获取一个空闲连接对象
理论上,后面应该要给每一个connectfd也要给一个 空闲连接对象。
//c)ngx_epoll_add_event() ************
// epoll_ctl();
//d)ev.data.ptr = (void *)( (uintptr_t)c | c->instance); 把一个指针和一个位 合二为一,塞到一个void *中去,
//后续能够把这两个值全部取出来,如何取,取出来干嘛,后续再说;
//ps -eo pid,ppid,sid,tty,pgrp,comm,stat,cmd | grep -E 'bash|PID|nginx'
//如下命令用root权限执行
//sudo su 获得root权限
//lsof -i:80 列出哪些进程在监听80端口
//netstat -tunlp | grep 80
//总结:
//a)epoll_create();epoll_ctl();
//b)连接池技巧ngx_get_connection(),ngx_free_connection();学习这种编程方法;
//c)同时传递 一个指针和一个二进制数字技巧;
//(3.2)ngx_epoll_init函数的调用(要在子进程中执行)
//四章,四节 project1.cpp:nginx中创建worker子进程;
//nginx中创建worker子进程
//官方nginx ,一个master进程,创建了多个worker子进程;
// master process ./nginx
// worker process
//(i)ngx_master_process_cycle() //创建子进程等一系列动作
//(i) ngx_setproctitle() //设置进程标题
//(i) ngx_start_worker_processes() //创建worker子进程
//(i) for (i = 0; i < threadnums; i++) //master进程在走这个循环,来创建若干个子进程
//(i) ngx_spawn_process(i,"worker process");
//(i) pid = fork(); //分叉,从原来的一个master进程(一个叉),分成两个叉(原有的master进程,以及一个新fork()出来的worker进程
//(i) //只有子进程这个分叉才会执行ngx_worker_process_cycle()
//(i) ngx_worker_process_cycle(inum,pprocname); //子进程分叉
//(i) ngx_worker_process_init();
//(i) sigemptyset(&set);
//(i) sigprocmask(SIG_SETMASK, &set, NULL); //允许接收所有信号
//(i) g_socket.ngx_epoll_init(); //初始化epoll相关内容,同时 往监听socket上增加监听事件,从而开始让监听端口履行其职责
//(i) m_epollhandle = epoll_create(m_worker_connections);
//(i) ngx_epoll_add_event((*pos)->fd....);
//(i) epoll_ctl(m_epollhandle,eventtype,fd,&ev);
//(i) ngx_setproctitle(pprocname); //重新为子进程设置标题为worker process
//(i) for ( ;; ) {}. .... //子进程开始在这里不断的死循环
//(i) sigemptyset(&set);
//(i) for ( ;; ) {}. //父进程[master进程]会一直在这里循环
上述,我们已经完成了epoll_init,对于 listenfd的 epoll_ctl
那么epoll_wait是什么时候呢?以及对于connectfd的 epoll_ctl以及对于 connectfd的epoll_wait在哪里呢?
ngx_process_events_and_timers(); 这个函数就是做epoll_wait的 //处理网络事件和定时器事件
g_socket.ngx_epoll_process_events(-1); //-1表示卡着等待把。 -1表示阻塞等待,为什么要阻塞等待,这是 epoll模型决定的,多路IO复用,listenfd wait的时候是阻塞等待。
//等待事件,事件会返回到m_events里,最多返回NGX_MAX_EVENTS个事件【因为我只提供了这些内存】;//阻塞timer这么长时间除非:a)阻塞时间到达 b)阻塞期间收到事件会立刻返回c)调用时有事件也会立刻返回d)如果来个信号,比如你用kill -1 pid测试//如果timer为-1则一直阻塞,如果timer为0则立即返回,即便没有任何事件//返回值:有错误发生返回-1,错误在errno中,比如你发个信号过来,就返回-1,错误信息是(4: Interrupted system call)// 如果你等待的是一段时间,并且超时了,则返回0;// 如果返回>0则表示成功捕获到这么多个事件【返回值里】int events = epoll_wait(m_epollhandle,m_events,NGX_MAX_EVENTS,timer);
如果是读事件,注意这里是的读事件,是listenfd的读事件,对应的是 客户端有连接过来了。
对应的回调函数是: ngx_event_accept; 该设定在前面
if(revents & EPOLLIN) //如果是读事件{//一个客户端新连入,这个会成立//c->r_ready = 1; //标记可以读;【从连接池拿出一个连接时这个连接的所有成员都是0】 (this->* (c->rhandler) )(c); //注意括号的运用来正确设置优先级,防止编译出错;【如果是个新客户连入//如果新连接进入,这里执行的应该是CSocekt::ngx_event_accept(c)】 //如果是已经连入,发送数据到这里,则这里执行的应该是 CSocekt::ngx_wait_request_handler}
c->rhandler = &CSocekt::ngx_event_accept;
void CSocekt::ngx_event_accept(lpngx_connection_t oldc) 函数调用:
通过accept4函数得到 connectfd。注意这里都是NON_BLOCK,取到值
if(use_accept4){s = accept4(oldc->fd, &mysockaddr, &socklen, SOCK_NONBLOCK); //从内核获取一个用户端连接,最后一个参数SOCK_NONBLOCK表示返回一个非阻塞的socket,节省一次ioctl【设置为非阻塞】调用}else{s = accept(oldc->fd, &mysockaddr, &socklen);}
设置copnnectfd的 回调函数为 ngx_wait_request_handler函数
通过ngx_epoll_add_event,将 connectfd 加入红黑树。 这时候如果客户端有数据发送过来,就会调用 ngx_wait_request_handler 函数
newc->rhandler = &CSocekt::ngx_wait_request_handler; //设置数据来时的读处理函数,其实官方nginx中是ngx_http_wait_request_handler()//客户端应该主动发送第一次的数据,这里将读事件加入epoll监控if(ngx_epoll_add_event(s, //socket句柄1,0, //读,写EPOLLET, //其他补充标记【EPOLLET(高速模式,边缘触发ET)】EPOLL_CTL_ADD, //事件类型【增加,还有删除/修改】 newc //连接池中的连接) == -1)
也就是说,当客户端有数据发送过来的时候,会调用 ngx_wait_Request_handler函数。在这个函数中
1. 收包,这里就要涉及到一个问题,当我们
相关文章:
159 Linux C++ 通讯架构实战14,epoll 函数代码实战
ngx_epoll_init函数的调用 //(3.2)ngx_epoll_init函数的调用(要在子进程中执行) //四章,四节 project1.cpp:nginx中创建worker子进程; //nginx中创建worker子进程 //官方nginx ,一个…...
【鹅厂摸鱼日记(一)】(工作篇)认识八大技术架构
💓博主CSDN主页:杭电码农-NEO💓 ⏩专栏分类:重生之我在鹅厂摸鱼⏪ 🚚代码仓库:NEO的学习日记🚚 🌹关注我🫵带你学习更多知识 🔝🔝 认识八大架构 1. 前言2. 架构简介&…...
CA根证书——https安全保障的基石
HTTPS通信中,服务器端使用数字证书来证明自己的身份。客户端需要验证服务器发送的证书的真实性。这就需要一个可信的第三方机构,即CA,来颁发和管理证书。CA根证书是证书颁发机构层次结构的顶级证书,客户端信任的所有证书都可以追溯…...
Spark-Scala语言实战(10)
在之前的文章中,我们学习了如何在spark中使用RDD的filter,distinct,intersection三种方法。想了解的朋友可以查看这篇文章。同时,希望我的文章能帮助到你,如果觉得我的文章写的不错,请留下你宝贵的点赞,谢谢。 Spark-…...
【C++庖丁解牛】高阶数据结构---红黑树详解(万字超详细全面介绍红黑树)
🍁你好,我是 RO-BERRY 📗 致力于C、C、数据结构、TCP/IP、数据库等等一系列知识 🎄感谢你的陪伴与支持 ,故事既有了开头,就要画上一个完美的句号,让我们一起加油 目录 前言1.红黑树的概念2.红黑…...
汽车网络安全管理
汽车网络安全管理 我是穿拖鞋的汉子,魔都中坚持长期主义的汽车电子工程师。 老规矩,分享一段喜欢的文字,避免自己成为高知识低文化的工程师: 屏蔽力是信息过载时代一个人的特殊竞争力,任何消耗你的人和事,…...
文本自动粘贴编辑器:支持自动粘贴并筛选手机号码,让信息处理更轻松
在信息时代的浪潮中,文本处理已成为我们日常工作与生活的重要组成部分。无论是商务沟通、社交互动还是个人事务处理,手机号码的筛选与粘贴都显得尤为关键。然而,传统的文本处理方式效率低下、易出错,已无法满足现代人的高效需求。…...
Linux云计算之网络基础9——园区网络架构项目
要求构建大型园区网络架构,方案如下: 园区A 园区c 公司B 要求: 1、A公司园区网络 一台汇聚层三层交换机,两台接入层二层交换机。 出口有一台路由器。 2、A园区有五台服务器。 分别为两台 WEB 服务器,…...
Java 中的 List 集合
文章目录 添加元素获取元素检查元素删除元素修改元素获取列表大小检查列表是否为空清空列表查找元素索引获取列表的子列表 List 是 Java 集合框架中的一个接口,它表示一个有序的集合(序列),允许存储重复的元素。List 接口提供了许…...
数据库之DDL操作(数据库,表,字段)
Data Definition Language,数据库定义语言,用来定义数据库对象(数据库,表,字段) 1.数据库操作 1.1查询所有数据库 show databases; 1.2查询当前数据库 show databases(); 1.3创建数据库 create da…...
5.3.1 配置交换机 SSH 管理和端口安全
5.3.1 实验1:配置交换机基本安全和 SSH管理 1、实验目的 通过本实验可以掌握: 交换机基本安全配置。SSH 的工作原理和 SSH服务端和客户端的配置。 2、实验拓扑 交换机基本安全和 SSH管理实验拓扑如图所示。 交换机基本安全和 SSH管理实验拓扑 3、实验步骤 &a…...
Django--数据库连接
数据库配置 打开mysite/settings.py配置文件,这是整个Django项目的设置中心。Django默认使用SQLite3数据库,因为Python原生支持SQLite3数据库,所以你无须安装任何程序,就可以直接使用它。 下面是默认的数据库配置: …...
CKA 基础操作教程(二)
Kubernetes Deployment 理论学习 Kubernetes Deployment (部署)是一种 Kubernetes 资源对象,用于定义和管理容器化应用程序的部署和更新。Deployment 提供了一种声明性的方式来定义应用程序的期望状态,并负责确保所需数量的 Pod…...
【SQLServer】快速查看SQL Server中所有数据库中所有表的行数
1.查看某个数据库中每个表的行数 SELECT @@servername as servername, db_name() as databasename, s.name AS schemaname, t.name AS tablename,p.rows AS rowcounts,SUM(a...
Node.js------Express
◆ 能够使用 express.static( ) 快速托管静态资源◆ 能够使用 express 路由精简项目结构◆ 能够使用常见的 express 中间件◆ 能够使用 express 创建API接口◆ 能够在 express 中启用cors跨域资源共享 一.初识Express 1.Express 简介 官方给出的概念:Express 是基…...
CSS - 你实现过0.5px的线吗
难度级别:中级及以上 提问概率:75% 我们知道在网页显示或是网页打印中,像素已经是最小单位了,但在很多时候,即便是最小的1像素,精度却不足以呈现所需的线条精度和细节。因此,为了在网页显示和网页打印中呈现更加细致的线条,为了在视觉…...
hbuilderX创建的uniapp项目转移到vscode
场景:一直使用hbuilderX开发的朋友想转移到vscode获取更好的TypeScript支持,所以想把整个项目目录拖到vscode进行开发,但发现运行不了,提示没有package.json等,并且不能执行pnpm命令 首先,我们先来看一下h…...
JavaScript 事件流
JavaScript与HTML之间的交互是通过事件实现的,而用户与浏览器页面的互动也是通过事件来实现的事件就是文档或浏览器窗口中发生的一些特定的交互瞬间,所以分为两种事件,一是发生在 浏览器对象(BOM)上的事件,…...
HTML——5.表单、框架、颜色
一、表单 HTML 表单用于在网页中收集用户输入的数据,例如登录信息、搜索查询等。HTML 提供了一系列的表单元素,允许用户输入文本、选择选项、提交数据等。 <!DOCTYPE html> <html lang"en"> <head> <meta charset&q…...
Docker、Kubernetes之间的区别
比较容器化工具:了解 Docker、Kubernetes 在应用程序部署和管理方面的差异。 基本概述 Docker 是一个流行的容器化平台,允许开发人员在容器中创建、部署和运行应用程序。 Docker 提供了一组工具和 API,使开发人员能够构建和管理容器化应用程…...
【21-40】计算机网络基础知识(非常详细)从零基础入门到精通,看完这一篇就够了
【21-40】计算机网络基础知识(非常详细)从零基础入门到精通,看完这一篇就够了 以下是本文参考的资料 欢迎大家查收原版 本版本仅作个人笔记使用21、HTTPS是如何保证数据传输的安全,整体的流程是什么?(SSL是…...
软考111-上午题-【计算机网络】-URL和DNS
一、URL解析 org:各类组织结构(非盈利团队) 1-1、顶级域 顶级域名是域名的最后一个部分,即是域名最后一点之后的字母,例如:www.baidu.com这个域名中,顶级域是.com(或.COMÿ…...
EasyCVR视频汇聚平台海康Ehome2.0与5.0设备接入时的配置区别
安防视频监控/视频集中存储/云存储/磁盘阵列EasyCVR平台可拓展性强、视频能力灵活、部署轻快,可支持的主流标准协议有国标GB28181、RTSP/Onvif、RTMP等,以及支持厂家私有协议与SDK接入,包括海康Ehome、海大宇等设备的SDK等。平台既具备传统安…...
echarts实现炫酷科技感的流光效果
前言: echarts实现炫酷科技感的流光效果 效果图: 实现步骤: 1、引入echarts,直接安装或者cdn引入 npm i echarts https://cdn.jsdelivr.net/npm/echarts5.4.3/dist/echarts.min.js 2、封装 option方法,第一个数据是折线数据&a…...
从多模态生物图数据中学习Gene的编码-MuSeGNN
由于数据的异质性,在不同的生物医学背景下发现具有相似功能的基因对基因表示学习提出了重大挑战。在本研究中,作者通过引入一种称为多模态相似性学习图神经网络的新模型来解决这个问题,该模型结合了多模态机器学习和深度图神经网络࿰…...
Redis Desktop Manager可视化工具
可视化工具 Redis https://www.alipan.com/s/uHSbg14XmsL 提取码: 38cl 点击链接保存,或者复制本段内容,打开「阿里云盘」APP ,无需下载极速在线查看,视频原画倍速播放。 官网下载(不推荐):http…...
ARM汇编与逆向工程:揭秘程序背后的神秘世界
文章目录 一、ARM汇编语言:底层世界的密码二、逆向工程:软件世界的侦探工作三、ARM汇编与逆向工程的完美结合四、ARM汇编逆向工程的风险与挑战五、ARM汇编逆向工程的未来展望《ARM汇编与逆向工程 蓝狐卷 基础知识》内容简介作者简介译者简介ChaMd5安全团…...
idea使用docker将Java项目生成镜像并使用
1:开启docker 远程访问 使用 vim 编辑docker服务配置文件 vim /lib/systemd/system/docker.service [Service] Typenotify # the default is not to use systemd for cgroups because the delegate issues still # exists and systemd currently does not suppor…...
clickhouse sql使用2
1、多条件选择 multiIf(cond_1, then_1, cond_2, then_2, …, else) select multiIf(true,0,1) 当第一条件不成立看第二条件判断 第一个参数条件参数,第二参数条件成立时走 2、clickhouse 在计算时候长出现NaN和Infinity异常处理 isNaN()和isInfinite()处理...
jrebel
JRebel最新版(2024.1.2)在线激活_jrebel 激活 2024-CSDN博客 JRebelXRebel热部署插件激活支持IDEA2023.1_jrebel and xrebel 激活-CSDN博客...
泰州住房和城乡建设网站/搜索引擎优化seo培训
记录游戏编辑器开发。 一般使用C# winform WPF,及C QT 进行开发 游戏编辑器开发一: QT开发环境配置 cocos2dx 3.3 QT5.3制作游戏编辑器 把 Cocos2d 嵌入 Qt 窗口中(2) cocosdx窗口(win32)嵌入wpf项目的初步实现 与Cocos2dx作者王哲及其团队技术讨论…...
iis两个网站做ssl/网络营销做得好的酒店
tensorflow read_data_sets 下载mnist数据报错 [Errno socket error] [Errno 101] Network is unreachable 解决方法: 手工下载数据包,放入temp目录,read_data_sets 会先判断本地是否存在数据包。 http://yann.lecun.com/exdb/mnist/ train-images…...
本地做网站教程/中国旺旺(00151) 股吧
关于VB中的冒号,给许多人的印象都是:“一行可书写几句语句”。这么说是对的,但是有一种情况是不对的,那就是在条件语句中。这也是做一个VB项目升级的时候遇到,因为这个问题我查了好长时间程序,一直在找VB的…...
wordpress邀请奖励/网页优化包括什么
中文名称:辛德勒名单英文名称:Schindlers List资源类型:MP3!发行时间:1994年简介:专辑介绍:这部斯蒂芬.斯皮尔伯格的旷世杰作使我们对他的艺术创造力不能不刮目相看,而以《星球大战》电影配乐而…...
wordpress日记/视频外链平台
有时候我们重装了win8系统之后开始可以调节亮度,但是再重新安装了显卡驱动之后发现不能调节亮度了,解决办法就是添加一项注册表。 下载地址:http://7xnarc.com1.z0.glb.clouddn.com/W8_Brightness_Fix.reg...
网店怎么开电子发票/汕头seo
一、絮言几名昨晚有幸认识了一个地产朋友,斯文的外表一点也看不出强大的能量。吃饭、喝茶聊开了,认人佩服得不得了;也终于明白他为何地产做得那么成功。他学识很丰富,文学、美学、哲学信手拈来。倒不是因我学理,对此一…...