Linux网络编程学习心得.4

1.epoll工作模式

水平触发  LT

边沿触发  ET

因为设置为水平触发,只要缓存区有数据epoll_wait就会被触发,epoll_wait是一个系统调用,尽量少调用

所以尽量使用边沿触发,边沿出触发数据来一次只触发一次,这个时候要求一次性将数据读完,所以while循环读,读到最后read默认带阻塞,不能让read阻塞,因为不能再去监听,

设置cfd为非阻塞,read读到最后一次返回值为-1.判断errno的值为EAGAIN,代表数据读干净

工作中  边沿触发   + 非阻塞 = 高速模式

创建lfd,监听,创建树epfd,写epoll_event事件,事件是结构体,ev.data.fd,ev.events(EPOLLIN 或者EPOLLOUT),epoll_ctl对文件描述符对上树(EPOLL_CTL_ADD)或者下树(EPOLL_CTL_DEV),epoll_wait监听,返回值是变化的数量,先判断lfd变化的操作,是创建新的cfd,然后再将其上树,注意设置非阻塞,再判断cfd变化的操作,要设置一个标志位,一次性读完数据,别忘记关闭文件描述符和下树。

2.epoll反应堆,reactor模式

文件描述符   事件   回调函数  封装在一起

结构体来封装

反应堆复杂版代码

 反应堆多了回调函数,是结构体,将文件描述符,事件,回调函数封装一起,指针的形式

 3.线程池

线程池,事先创建几个线程,,不停取任务,如果没有任务休眠,省去了不停的创建线程销毁销毁线程的事件和资源

注意: 线程池 处理的任务,所需要处理的时间必须很短

一个锁

两个条件变量

循环队列

3.UDP和TCP 

TCP: 传输控制协议   安全可靠  丢包重传   面向连接(电话模型) 

UDP: 用户数据报协议  不安全不可靠 丢包不重传  快 不面向连接(邮件模型)

tcp通信流程:

 服务器: 创建流式套接字 绑定 监听 提取 读写 关闭

客户端: 创建流式套接字 连接 读写 关闭

收发数据:

read recv

ssize_t recv(int sockfd, void *buf, size_t len, int flags);//flags==MSG_PEEK 读数据不会删除缓冲区的数据

write  send

ssize_t send(int sockfd, const void *buf, size_t len, int flags);//flags=1 紧急数据

udp通信流程

服务器: 创建报式套接字 绑定 读写 关闭

客户端:   创建报式套接字 读写  关闭

发数据:

ssize_t sendto(int sockfd, const void *buf, size_t len, int flags,

                      const struct sockaddr *dest_addr, socklen_t addrlen);

dest_addr: 目的地的地址信息

addrlen: 结构体大小

收数据:

  ssize_t recvfrom(int sockfd, void *buf, size_t len, int flags,

                        struct sockaddr *src_addr, socklen_t *addrlen);

src_addr: 对方的地址信息

addrlen: 结构体大小的地

 4.创建报式套接字

socket

int socket(int domain, int type, int protocol);

参数:

    domain : AF_INET

    type :SOCK_DGRAM

    protocol :0

 5.创建本地套接字

unix domain   socket

本地套接字通信

全双工

套接字用文件来标识,这个文件在绑定之前是不能存在

创建本地套接字

绑定

监听

提取

读写

关闭

6.创建本地套接字用于tcp通信

int socket(int domain, int type, int protocol);

参数:

    domain : AF_UNIX

    type :SOCK_STREAM

    protocol : 0

绑定

int bind(int sockfd, const struct sockaddr *addr,

                socklen_t addrlen);

sockfd: 本地套接字

addr:  本地套接字结构体地址

struct sockaddr_un {

               sa_family_t sun_family;               /* AF_UNIX */

               char        sun_path[108];            /* pathname *///文件的路径名

           };

addrlen: sockaddr_un大小

提取

int accept(int sockfd, struct sockaddr *addr, socklen_t *addrlen);

addr: struct sockaddr_un 结构体地址

需要注意的点:

客户端可以隐式绑定,但是服务器不可以

绑定指定文件时m,这个文件必须不存在,如果存在绑定失败

 7. libevent和安装

网络的事件库

跨平台,支持多种多路io复用

核心: 以事件驱动(触发),回调

安装libevent

解压:

tar -xzvf libevent-2.0.22-stable.tar.gz  -C ./install

执行configure ,检测环境生成makefile

./configure

编译

sudo make

安装

sudo make install

库的路径: /usr/local/lib

头文件目录: /usr/local/include'

编译时需要指定库名  -levent

8.libevent的使用 

创建event_base根节点

struct event_base *event_base_new(void);

返回值值就是event_base根节点地址

释放根节点

void event_base_free(struct event_base *);

循环监听

int event_base_dispatch(struct event_base *base);

相当于 while(1){epoll_wait}循环监听

退出循环监听

int event_base_loopexit(struct event_base *base, const struct timeval *tv); //等待固定时间之后退出

    int event_base_loopbreak(struct event_base *base);//立即退出

9.libevent时间触发流程 

 10.libevent流程以及各个函数

初始化上树节点

struct event *event_new(struct event_base *base, evutil_socket_t fd, short events, event_callback_fn cb, void *arg);

参数:

base: event_base根节点

fd: 上树的文件描述符

events: 监听的事件

   #define  EV_TIMEOUT         0x01   //超时事件

#define  EV_READ                  0x02 //读事件

#define  EV_WRITE                0x04  //写事件

#define  EV_SIGNAL              0x08     //信号事件

#define  EV_PERSIST              0x10   //周期性触发

        #define  EV_ET      

cb: 回调函数

typedef void (*event_callback_fn)(evutil_socket_t fd, short events, void *arg);

arg: 传给回调函数的参数

返回值: 初始化好的节点的地址

节点上树

int event_add(struct event *ev, const struct timeval *timeout);

ev: 上树节点的地址

timeout: NULL  永久监听  固定时间 限时等待

下树

int event_del(struct event *ev);

ev: 下树节点的地址

释放节点

void event_free(struct event *ev);

总结:

 epoll工作模式:水平触发,边沿触发,水平触发在读缓冲区,只要有数据就触发,边沿触发,在读缓冲区,来一次数据触发一次(一次性读完数据),写缓冲区,水平触发只要可写就触发,边沿触发有数据变化就触发,创建lfd,监听,创建树epfd,写epoll_event事件,事件是结构体,ev.data.fd,ev.events(EPOLLIN 或者EPOLLOUT),epoll_ctl对文件描述符对上树(EPOLL_CTL_ADD)或者下树(EPOLL_CTL_DEV),epoll_wait监听,返回值是变化的数量,先判断lfd变化的操作,是创建新的cfd,然后再将其上树,注意设置非阻塞,再判断cfd变化的操作,要设置一个标志位,一次性读完数据,别忘记关闭文件描述符和下树。

epollreactor模式使用的是结构体,有事件,文件描述符,回调函数,指针形式

tcp传输控制协议,安全可靠,丢包重传,面向连接,udp用户数据报协议,与tcp相反,tcp是流式套接字,udp是报式套接字,要注意两者客户端服务端的区别,

创建udp套接字,注意是SOCK_DGRAM,

创建本地套接字,就是与tcp相比缺少了连接步骤,

本地套接字需要自定一个路径,生成文件,最后执行文件,如果之前存在文件,需要删除在运行

libevent网路事件库,支持多路io复用,以事件驱动触发事件回调,

libevent使用,event_base_new创建新节点,event_base_free释放节点,event_base_dispatch循环监听

libevent流程event_new新建节点,节点上树event_add监听,event_del下树,event_free节点释放

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

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

HarmonyOS应用程序包快速修复

快速修复概述 快速修复是HarmonyOS系统提供给开发者的一种技术手段,支持开发者以远快于应用升级的方式对应用程序包进行缺陷修复。和全量应用升级软件版本相比,快速修复的主要优势在小、快和用户体验好。在较短的时间内不中断正在运行的应用的情况下&am…

【数据结构】第2章线性表(头歌习题)【合集】

文章目录 第1关:实现顺序表各种基本运算的算法任务描述编程要求完整代码 第2关:实现单链表各种基本运算的算法任务描述编程要求完整代码 第3关:移除顺序表中所有值等于x的元素任务描述编程要求完整代码 第4关:逆置顺序表任务描述编…

windows go环境安装 swag

windows 下载依赖包 go get github.com/swaggo/swag/cmd/swag编译swag cd $GOPATH\pkg\mod\github.com\swaggo\swagv1.16.2\cmd\swagps: go env 获取 GOPATH位置 go installps: 此时 $GOPATH\bin下出现了 swag.exe 项目根目录下执行swag 初始化 swag init生成结果

vue中使用echarts实现省市地图绘制,根据数据显示省市天气图标及温度信息

一、实现效果 使用echarts实现省市地图绘制根据数据显示省下市的天气图标根据数据显示省下市的温度信息 二、实现方法 1、安装echarts插件 npm install echarts --save2、获取省市json数据 https://datav.aliyun.com/portal/school/atlas/area_selector 通过 阿里旗下的高…

如何用Python批量计算Word中的算式

一、问题的提出 到了期末,大家都在忙着写总结、改试卷、算工作量,写总结可以借助于ChatGPT,改试卷可以用星火的自动批阅功能,算工作量就是一项比较棘手的问题,因为它涉及很多算式,有时需要老师用计算器算来…

10TB海量JSON数据从OSS迁移至MaxCompute

前提条件 开通MaxCompute。 在DataWorks上完成创建业务流程,本例使用DataWorks简单模式。详情请参见创建业务流程。 将JSON文件重命名为后缀为.txt的文件,并上传至OSS。本文中OSS Bucket地域为华东2(上海)。示例文件如下。 {&qu…

每日一练(编程题-C/C++)

目录 CSDN每日一练1. 2023/2/27- 一维数组的最大子数组和(类型:数组 难度:中等)2. 2023/4/7 - 小艺照镜子(类型:字符串 难度:困难)3. 2023/4/14 - 最近的回文数(难度:中等)4. 2023/2/1-蛇形矩阵(难度:困难)…

算法基础之最短编辑距离

最短编辑距离 核心思想 : 线性dp 集合定义 : f[i][j]为操作方式的最小值 集合计算 : 三种操作 取最小 ① 删除 : 将a[i]删掉 使ab相同 –> f[i-1][j] 1 f[i][j]② 增添 : 在a[i]后加上一个数 使ab相同 –> f[i][j-1] 1 f[i][j]③ 替换 : 将a[…

基于ssm的航空票务推荐系统的设计与实现论文

摘 要 传统信息的管理大部分依赖于管理人员的手工登记与管理,然而,随着近些年信息技术的迅猛发展,让许多比较老套的信息管理模式进行了更新迭代,航班信息因为其管理内容繁杂,管理数量繁多导致手工进行处理不能满足广大…

基于Python的新闻爬取和推荐系统实践

基于Python的新闻爬取和推荐系统实践 项目概述数据集来源技术栈功能特点普通用户功能管理员功能需求 创新点 项目概述 在这个全功能的新闻爬取和推荐系统项目中,我们致力于构建一个高效、智能的平台,为用户提供个性化的新闻阅读体验。采用了Python语言&…

oracle执行不了update

oracle数据库select等其他语句执行正常,update语句执行后一直执行不完,原因是产生了记录锁。 (1)查询锁 SELECT a.sid, a.serial#,a.USERNAME,ao.OBJECT_NAME FROM v$locked_object lo, dba_objects ao, v$session a WHERE ao.o…

C语言易错知识点十(指针(the final))

❀❀❀ 文章由不准备秃的大伟原创 ❀❀❀ ♪♪♪ 若有转载,请联系博主哦~ ♪♪♪ ❤❤❤ 致力学好编程的宝藏博主,代码兴国!❤❤❤ 许久不见,甚是想念,真的是时间时间,你慢些吧,不能再让头发变秃…

电子邮件地址填写指南:格式与常见问题解答

一个专业的电子邮件地址是一个你只用于工作目的的通信帐户。当你给收件人发送电子邮件时,这是他们最先看到的细节之一。无论你的职位或行业如何,拥有一个专业的电子邮件地址都可以提高你和所在公司的可信度。 在本文中我们解释了专业的电子邮件地址是什么…

PAT 乙级 1033 旧键盘打字

旧键盘上坏了几个键,于是在敲一段文字的时候,对应的字符就不会出现。现在给出应该输入的一段文字、以及坏掉的那些键,打出的结果文字会是怎样? 输入格式: 输入在 2 行中分别给出坏掉的那些键、以及应该输入的文字。其…

使用Vue3开发学生管理系统模板1

环境搭建 通过解压之前《Vue3开发后台管理系统模板》的代码&#xff0c;我们能够得到用户增删改查的页面&#xff0c;我们基于用户增删改查的页面做进一步的优化。 创建学生增删改查页面 第一步&#xff1a;复制用户增删改查页面&#xff0c;重命名为StudentCRUD.vue <…

java图书管理系统

主要模块&#xff1a; 为用户开通借书服务增加图书信息登记图书借出信息 技术栈&#xff1a; JSPServletTomcat9.0IDEAMysql 前台登录验证使用框架 数据库脚本包括登录用户名和密码已经写在了数据库脚本.sql 中 解压“需要的jar包”添加到项目的dependency中 运行效果&a…

构建基于小红书笔记详情API的内容生态

随着互联网的发展&#xff0c;内容生态的构建已经成为了许多企业和个人的重要任务。小红书作为一家以内容分享为主的社交平台&#xff0c;其API的开放为开发者提供了一种全新的方式来获取用户生成内容&#xff08;UGC&#xff09;。本文将介绍如何从无到有地构建基于小红书笔记…

告别HTTP,拥抱HTTPS!免费SSL证书领取指南

为什么选择HTTPS&#xff1f; HTTP和HTTPS之间的主要区别在于安全性。HTTP是一种不安全的协议&#xff0c;数据在传输过程中是明文的&#xff0c;容易受到中间人攻击。而HTTPS通过SSL&#xff08;Secure Sockets Layer&#xff09;或TLS&#xff08;Transport Layer Security&…

zabbix通过自动发现-配置监控项、触发器(小白教程)

自动发现配置参考链接&#xff08;不小白&#xff0c;不友好&#xff09; zabbix-get介绍 1配置 zabbix server&#xff1a;版本7&#xff08;不影响&#xff09;,IP地址&#xff1a;192.168.0.60zabbix agent&#xff1a;版本agent1&#xff08;不影响&#xff09;&#xff…

【Graylog】通过Pipelines在Graylog生成IP地理位置信息

序 在当今数字化时代&#xff0c;随着网络攻击的不断增加和全球化的用户活动&#xff0c;了解IP地址的地理位置信息变得越来越重要。对于网络安全和营销策略来说&#xff0c;掌握IP地址的地理信息可以带来许多好处。 接下里将介绍如何通过Graylog的Pipelines功能&#xff0c;…