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.mzph.cn/news/584958.shtml

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

相关文章

Glary Utilities Pro - 电脑系统优化全面指南:详尽使用教程

软件简介: Glary Utilities Pro 是一款全面的电脑优化工具,它旨在帮助用户提升计算机的性能和稳定性。这款软件提供了多种功能,包括系统清理、优化、修复以及保护。通过一键扫描,它可以识别并清除无用文件、临时数据、注册表错误等…

AI大模型时代下运维开发探索第二篇:基于大模型(LLM)的数据仓库

在SREWorks社区聚集了很多进行运维数仓建设的同学,大家都会遇到类似的挑战和问题: 数仓中存储大量数据消耗成本,但很多存储的数据却并没有消费。进数仓的ETL学习成本高、管理成本高,相关同学配合度低,以及上游结构改动…

element表格排序功能

官方展示 个人项目 可以分别对每一项数据进行筛选 注&#xff1a;筛选的数据不能是字符串类型必须是数字类型&#xff0c;否则筛选会乱排序 html <el-table :data"tableData" border height"600" style"width: 100%"><el-table-co…

K8s陈述式资源管理

命令行&#xff1a;kubectl命令行工具 优点&#xff1a;90%以上的场景都可以满足 对资源的增删改查比较方便&#xff0c;对改不是很友好。 缺点&#xff1a;命令比较冗长&#xff0c;复杂&#xff0c;难记 声明式&#xff1a; 看到声明式都是k8s当中的yml文件来实现资源管理…

什么是uniapp?用uniapp开发好不好用?

随着移动应用市场的持续发展&#xff0c;开发者们面临着不断增长的需求和多样化的平台选择。在这个背景下&#xff0c;UniApp 应运而生&#xff0c;成为一种跨平台开发框架&#xff0c;为开发者提供了一种高效、简便的方式来开发移动应用程序。利用 UniApp 开发应用程序可以节省…

天擎终端安全管理系统clientinfobymid存在SQL注入漏洞

产品简介 奇安信天擎终端安全管理系统是面向政企单位推出的一体化终端安全产品解决方案。该产品集防病毒、终端安全管控、终端准入、终端审计、外设管控、EDR等功能于一体&#xff0c;兼容不同操作系统和计算平台&#xff0c;帮助客户实现平台一体化、功能一体化、数据一体化的…

Django 文件上传(十二)

当 Django 处理文件上传时&#xff0c;文件数据最终会被放置在 request.FILES 。 查看文档&#xff1a;文件上传 | Django 文档 | Django Django工程如下&#xff1a; 创建本地存储目录 在static/应用目录下创建uploads目录用于存储接收上传的文件 在settings.py 配置静态目…

IDEA/VScode + Git Blame

IDEA IDEA中支持查看每行代码的commit信息&#xff0c;这是靠git blame命令来完成的。 鼠标悬置在上面&#xff0c;可以看到更多信息。 VScode vscode中有相应插件完成类似的工作。 找到一个Git Blame插件&#xff0c;就是专门用来完成这项工作的。 安装完成后&#xff0c;下…

每日一题——LeetCode942

方法一 个人方法&#xff1a; 找规律&#xff0c;碰到I优先放最小的数&#xff0c;碰到D优先放最大的数&#xff0c;将0-n按照从小到大的顺序放入数组保存&#xff0c;碰到I就从数组前面取值&#xff0c;碰到D就从数组后面取值 var diStringMatch function(s) {var arr[],pe…

python gui programming cook,python gui视频教程

大家好&#xff0c;给大家分享一下python gui programming cook&#xff0c;很多人还不知道这一点。下面详细解释一下。现在让我们来看看&#xff01; Source code download: 本文相关源码 前言 上一节我们实现了明细窗体GUI的搭建&#xff0c;并且设置了查看、修改、添加三种不…

C语言实例_stdlib.h库函数功能及其用法详解

一、前言 C语言作为一种高效、灵活的编程语言&#xff0c;标准库的使用对于开发人员来说是不可或缺的。其中&#xff0c;stdlib.h是C语言中一个重要的标准库头文件&#xff0c;提供了许多常用的函数和工具&#xff0c;以便开发人员能够更加便捷地进行内存管理、字符串处理、随…

大创项目推荐 深度学习中文汉字识别

文章目录 0 前言1 数据集合2 网络构建3 模型训练4 模型性能评估5 文字预测6 最后 0 前言 &#x1f525; 优质竞赛项目系列&#xff0c;今天要分享的是 &#x1f6a9; 深度学习中文汉字识别 该项目较为新颖&#xff0c;适合作为竞赛课题方向&#xff0c;学长非常推荐&#xf…

OCP NVME SSD规范解读-4.NVMe IO命令-1

针对NVMe-IO-1到NVMe-IO-14的解读如下&#xff1a; NVMe-IO-1&#xff1a; 设备应支持所有必需的NVMe I/O命令。这是设备能够进行基本数据读写操作的基础要求。NVMe I/O命令包括读、写、删除、擦除等操作&#xff0c;这些是存储设备的核心功能。 NVMe-IO-2&#xff1a; 设备应…

JavaOOP篇----第二十五篇

系列文章目录 文章目录 系列文章目录前言一、一个”.java”源文件中是否可以包含多个类(不是内部类)?有什么限制?二、AnonymousInnerClass(匿名内部类)是否可以继承其它类?是否可以实现接口?三、内部类可以引用它的包含类(外部类)的成员吗?有没有什么限制?四、Java 中…

[计算机提升] Windows系统软件:管理类

3.6 系统软件&#xff1a;管理类 3.6.1 运行 通过运行程序&#xff0c;在打开输入框中输入名称&#xff0c;按下回车后可以打开相应的程序、文件夹、文档或Internet资源&#xff1a; 3.6.2 命令提示符&#xff1a;cmd 在Windows系统中&#xff0c;cmd是指"命令提示符…

nacos入门篇001-安装与启动

1、下载zip包 我这里下载的是版本2.2.0 Nacos 快速开始 2、修改配置文件 2.1集群模式修改成单例模式 vi startup.sh 2.2 修改数据库配置信息 3、初始化数据库 3.1 创建db名称&#xff1a;db_nacos 3.2 执行mysql-schema.sql 3.3 执行完截图&#xff1a; 4、运行脚本启动 …

听GPT 讲Rust源代码--src/tools(34)

File: rust/src/tools/clippy/clippy_lints/src/collection_is_never_read.rs 文件"collection_is_never_read.rs"位于Rust源代码中的clippy_lints工具中&#xff0c;其作用是检查在集合类型&#xff08;如Vec、HashMap等&#xff09;的实例上执行的操作是否被忽略了…

LT8612UX-HDMI2.0 to HDMI2.0 and VGA Converter with Audio,支持三通道视频DAC

HDMI2.0 to HDMI2.0 and VGA Converter with Audio 1. 描述 LT8612UX是一个HDMI到HDMI和vga转换器&#xff0c;它将HDMI2.0数据流转换为HDMI2.0信号和模拟RGB信号。 它还输出8通道I2S和SPDIF信号&#xff0c;使高质量的7.1通道音频。 LT8612UX支持符合HDMI2.0/ 1.4规范的…

ubuntu python播放MP3,wav音频和录音

目录 一.利用pygame&#xff08;略显麻烦&#xff0c;有时候播放不太正常&#xff09;1.安装依赖库2.代码 二.利用mpg123&#xff08;简洁方便&#xff0c;但仅争对mp3&#xff09;1.安装依赖库2.代码 三.利用sox&#xff08;简单方便&#xff0c;支持的文件格式多&#xff09;…

亚信安慧AntDB数据并行加载工具的实现(一)

1.概述 数据加载速度是评判数据库性能的重要指标&#xff0c;能否提高数据加载速度&#xff0c;对文件数据进行并行解析&#xff0c;直接影响数据库运维管理效率。基于此&#xff0c;AntDB分布式数据库提供了两种数据加载方式&#xff1a; 一是类似于PostgreSQL的Copy命令&am…