当前位置:首页 > 科技  > 软件

图文详解io_uring高性能异步IO架构(原理篇)

来源: 责编: 时间:2024-01-02 09:32:02 158观看
导读说到高性能网络编程,我们第一时间想到的是epoll机制,epoll很长一段时间统治着整个网络编程江湖,然而io_uring的出现,似乎在撼动epoll的统治地位,今天我们来揭开io_uring的神秘面纱。1.io_uring简介io_uring是一个Linux内核

说到高性能网络编程,我们第一时间想到的是epoll机制,epoll很长一段时间统治着整个网络编程江湖,然而io_uring的出现,似乎在撼动epoll的统治地位,今天我们来揭开io_uring的神秘面纱。HeQ28资讯网——每日最新资讯28at.com

1.io_uring简介

io_uring是一个Linux内核的异步I/O框架,它提供了高性能的异步I/O操作,io_uring的目标是通过减少系统调用和上下文切换的开销来提高I/O操作的性能。HeQ28资讯网——每日最新资讯28at.com

io_uring通过使用环形缓冲区和事件驱动的方式来实现高效的异步I/O操作。HeQ28资讯网——每日最新资讯28at.com

io_uring的设计使得应用程序可以同时处理大量的I/O操作,从而提高系统的吞吐量和响应速度。HeQ28资讯网——每日最新资讯28at.com

2.io_uring实现原理

io_uring整体架构如下:HeQ28资讯网——每日最新资讯28at.com

图片图片HeQ28资讯网——每日最新资讯28at.com

2.1基础概念

  • SQE:提交队列项,表示IO请求。
  • CQE:完成队列项,表示IO请求结果。
  • SQ:Submission Queue,提交队列,用于存储SQE的数组。
  • CQ:Completion Queue,完成队列,用于存储CQE的数组。
  • SQ Ring:SQ环形缓冲区,包含SQ,头部索引(head),尾部索引(tail),队列大小等信息。
  • CQ Ring:CQ环形缓冲区,包含SQ,头部索引(head),尾部索引(tail),队列大小等信息。
  • SQ线程:内核辅助线程,用于从SQ队列获取SQE,并提交给内核处理,并将IO请求结果生成CQE存储在CQ队列。

2.2 io_uring系统调用

  • io_uring_setup():用于初始化io_uring环境,创建io_uring实例。
  • io_uring_enter():用于提交和等待io_uring操作的系统调用,可以指定提交的操作数量和等待的超时时间。
  • io_uring_register():用于注册文件描述符或事件文件描述符到io_uring实例中,以便进行I/O操作。

2.3 liburing库

liburing是一个用于Linux的用户空间库,用于利用io_uring接口进行高性能的异步I/O操作,它提供了一组函数和数据结构,使开发者能够更方便地使用io_uring接口。HeQ28资讯网——每日最新资讯28at.com

  • io_uring_queue_init:初始化一个io_uring队列。
  • io_uring_register:将文件描述符注册到io_uring队列中。
  • io_uring_prep_read:准备一个读取操作。
  • io_uring_prep_write:准备一个写入操作。
  • io_uring_submit:提交一个或多个操作到io_uring队列中。
  • io_uring_wait_cqe:等待一个完成的操作。
  • io_uring_cqe_seen:标记一个完成的操作已经被处理。
  • io_uring_queue_exit:关闭并释放io_uring队列。

2.4 工作流程

  1. 创建io_uring对象:首先,需要创建一个io_uring对象,可以使用io_uring_setup()函数来完成。
  2. 准备I/O请求:在进行I/O操作之前,需要准备相关的I/O请求。可以使用io_uring_prep_XXX()系列函数来准备不同类型的I/O请求,例如io_uring_prep_read()用于读取数据,io_uring_prep_write()用于写入数据。
  3. 提交I/O请求:准备好I/O请求后,可以使用io_uring_submit()函数将请求提交给内核,内核会将这些请求放入一个队列中,等待执行。
  4. 等待IO请求完成:可以使用io_uring_wait_cqe()函数来等待I/O请求的完成,一旦请求完成,内核会将完成事件放入一个完成队列中。
  5. 获取IO请求结果:可以使用io_uring_peek_cqe()函数来获取完成队列中的完成事件。然后,可以通过事件的信息来处理完成的I/O请求,例如读取数据或者处理错误。
  6. 释放IO请求结果:获取完IO请求结果,使用io_uring_cqe_seen()函数来释放IO请求结果,以便内核可以继续使用。
  7. 重复执行:可以重复执行上述步骤,以处理更多的I/O请求。

3.内核实现

3.1 创建io_uring对象

图片图片HeQ28资讯网——每日最新资讯28at.com

用户程序通过io_uring_setup系统调用创建和初始化io_uring对象,io_uring对象对应于struct io_ring_ctx结构体对象。HeQ28资讯网——每日最新资讯28at.com

io_uring_setup主要工作:HeQ28资讯网——每日最新资讯28at.com

  • 创建struct io_ring_ctx对象并初始化。
  • 创建struct io_urings对象并初始化,注意此时已完成CQ和所有CQE创建。
  • 创建SQ和所有SQE并初始化。
  • 如果struct io_ring_ctx对象flags参数设置IORING_SETUP_SQPOLL,则创建SQ线程。

3.2 fd绑定io_uring对象

图片图片HeQ28资讯网——每日最新资讯28at.com

已创建的io_ring对象需要和fd进行绑定, 以便能够通过fd找到io_uring对象,创建一个新的file,file private_data成员指向io_ring对象,申请一个未使用的文件描述符fd,fd映射至file,并存储在进程已打开文件表中。HeQ28资讯网——每日最新资讯28at.com

注意:mmap内存映射需要用到该fd。HeQ28资讯网——每日最新资讯28at.com

3.3 io_uring对象内存映射

图片图片HeQ28资讯网——每日最新资讯28at.com

通过io_uring_setup系统调用创建完io_uring对象后,用户程序还不能直接访问io_uring对象,此时用户程序需要通过mmap函数将io_uring对象SQ,CQ以及head和tail等相关内存空间映射出来。HeQ28资讯网——每日最新资讯28at.com

完成mmap内存映射后,io_uring对象相关内存空间成为用户程序和内核共享内存空间,用户程序可以直接访问io_uring对象,不再需要通过执行系统调用访问,很大程度上提高了系统性能。HeQ28资讯网——每日最新资讯28at.com

3.4 提交IO请求HeQ28资讯网——每日最新资讯28at.com

图片图片HeQ28资讯网——每日最新资讯28at.com

SQ Ring中有两个成员head(头部索引)和tail(尾部索引),头部索引指向SQ队列第一个已提交IO请求,尾部索引指向SQ下一个空闲SQE。HeQ28资讯网——每日最新资讯28at.com

提交IO请求,只需要将tail指向的SQE填充IO请求信息,并让tail自增1,指向下一个空闲SQE。HeQ28资讯网——每日最新资讯28at.com

注意:head和tail不是直接指向SQ数组,而是需要通过head&mask和tail &mask操作指向SQ数组,mask数组为数组长度减1,因为数组有固定大小,所以需要通过&mask方式防止越界访问数组,这种方式可以让数组形成一个环形缓冲区。HeQ28资讯网——每日最新资讯28at.com

3.5 等待IO请求完成HeQ28资讯网——每日最新资讯28at.com

图片图片HeQ28资讯网——每日最新资讯28at.com

IO请求的处理有两种方式:HeQ28资讯网——每日最新资讯28at.com

  • 方式1:SQ线程从SQ队列中获取SQE(已提交IO请求),并发送给内核处理。
  • 方式2:用户程序通过io_uring_enter系统调用从SQ队列中获取SQE(已提交IO请求),并发送给内核处理。

从SQ队列获取SQE只需要获取SQ Ring head指向的SQE,并让head自增指向下一个SQE即可。HeQ28资讯网——每日最新资讯28at.com

图片图片HeQ28资讯网——每日最新资讯28at.com

内核处理完IO请求后,SQ线程会申请CQ Ring tail指向的CQE存储IO请求结果,tail自增1指向下一个空闲CQE。HeQ28资讯网——每日最新资讯28at.com

3.6 获取IO请求结果

图片图片HeQ28资讯网——每日最新资讯28at.com

用户程序通过判断CQ Ring head和tail之间的差值,可以检测到是否有已完成IO请求,如果有已完成IO请求(CQE),获取CQ Ring head指向CQE,获取IO请求结果。HeQ28资讯网——每日最新资讯28at.com

3.7 释放已完成IO请求

释放已完成IO请求只需要将CQ Ring head指针自增1指向下一个CQE即可,这样做的目的是防止重复获取IO请求结果。HeQ28资讯网——每日最新资讯28at.com

io_uring为什么高效?HeQ28资讯网——每日最新资讯28at.com

核心原因:io_uring通过mmap内存映射大大减少了系统调用,在高并发场景下,系统调用非常损耗系统性能。HeQ28资讯网——每日最新资讯28at.com

其他原因:HeQ28资讯网——每日最新资讯28at.com

  • 减少拷贝:io_uring通过共享内存减少用户程序和内核数据拷贝。
  • 批量操作:io_uring支持批量操作,一次性可以提交多个I/O请求,减少系统调用的次数,提高系统效率。
  • 无锁环形队列:io_uring采用无锁队列实现用户程序与内核对共享内存的高效访问。

本文链接:http://www.28at.com/showinfo-26-55364-0.html图文详解io_uring高性能异步IO架构(原理篇)

声明:本网页内容旨在传播知识,若有侵权等问题请及时与本网联系,我们将在第一时间删除处理。邮件:2376512515@qq.com

上一篇: 图文详解io_uring高性能异步IO架构(原理篇)

下一篇: 用分布式系统思考团队管理

标签:
  • 热门焦点
  • Find N3入网:最高支持16+1TB

    Find N3入网:最高支持16+1TB

    OPPO将于近期登场的Find N3折叠屏目前已经正式入网,型号为PHN110。本次Find N3在外观方面相比前两代有很大的变化,不再是小号的横向折叠屏,而是跟别的厂商一样采用了较为常见的
  • 2023年Q2用户偏好榜:12+256G版本成新主流

    2023年Q2用户偏好榜:12+256G版本成新主流

    3月份的性能榜、性价比榜和好评榜之后,就要轮到2023年的第二季度偏好榜了,上半年的新机潮已经过去,最明显的肯定就是大内存和存储的机型了,另外部分中端机也取消了屏幕塑料支架
  • Rust中的高吞吐量流处理

    Rust中的高吞吐量流处理

    作者 | Noz编译 | 王瑞平本篇文章主要介绍了Rust中流处理的概念、方法和优化。作者不仅介绍了流处理的基本概念以及Rust中常用的流处理库,还使用这些库实现了一个流处理程序
  • 服务存储设计模式:Cache-Aside模式

    服务存储设计模式:Cache-Aside模式

    Cache-Aside模式一种常用的缓存方式,通常是把数据从主存储加载到KV缓存中,加速后续的访问。在存在重复度的场景,Cache-Aside可以提升服务性能,降低底层存储的压力,缺点是缓存和底
  • Java NIO内存映射文件:提高文件读写效率的优秀实践!

    Java NIO内存映射文件:提高文件读写效率的优秀实践!

    Java的NIO库提供了内存映射文件的支持,它可以将文件映射到内存中,从而可以更快地读取和写入文件数据。本文将对Java内存映射文件进行详细的介绍和演示。内存映射文件概述内存
  • 2天涨粉255万,又一赛道在抖音爆火

    2天涨粉255万,又一赛道在抖音爆火

    来源:运营研究社作者 | 张知白编辑 | 杨佩汶设计 | 晏谈梦洁这个暑期,旅游赛道彻底火了:有的「地方」火了——贵州村超旅游收入 1 个月超过 12 亿;有的「博主」火了&m
  • 得物宠物生意「狂飙」,发力“它经济”

    得物宠物生意「狂飙」,发力“它经济”

    作者|花花小萌主近日,得物宣布正式上线宠物鉴别,通过得物App内的“在线鉴别”,可找到鉴别宠物的选项。通过上传自家宠物的部位细节,就能收获拥有专业资质认证的得物鉴
  • 支持aptX Lossless无损传输 iQOO TWS 1赛道版发布限时优惠价369元

    支持aptX Lossless无损传输 iQOO TWS 1赛道版发布限时优惠价369元

    2023年7月4日,“无损音质,声动人心”iQOO TWS 1正式发布,支持aptX Lossless无损传输,限时优惠价369元。iQOO TWS 1耳机率先支持端到端aptX Lossless无
  • 到手价3099元起!iQOO Neo8 Pro今日首销:安卓性能最强旗舰

    到手价3099元起!iQOO Neo8 Pro今日首销:安卓性能最强旗舰

    5月23日,iQOO如期举行了新品发布会,全新的iQOO Neo8系列也正式与大家见面,包含iQOO Neo8和iQOO Neo8 Pro两个版本,其中标准版搭载高通骁龙8+,而Pro版更
Top