色哟哟视频在线观看-色哟哟视频在线-色哟哟欧美15最新在线-色哟哟免费在线观看-国产l精品国产亚洲区在线观看-国产l精品国产亚洲区久久

0
  • 聊天消息
  • 系統消息
  • 評論與回復
登錄后你可以
  • 下載海量資料
  • 學習在線課程
  • 觀看技術視頻
  • 寫文章/發帖/加入社區
會員中心
創作中心

完善資料讓更多小伙伴認識你,還能領取20積分哦,立即完善>

3天內不再提示

異步IO框架iouring介紹

科技綠洲 ? 來源:Linux開發架構之路 ? 作者:Linux開發架構之路 ? 2023-11-09 09:30 ? 次閱讀

前言

Linux內核5.1支持了新的異步IO框架iouring,由Block IO大神也即Fio作者Jens Axboe開發,意在提供一套公用的網絡和磁盤異步IO,不過io_uring目前在磁盤方面要比網絡方面更加成熟。

目錄

  • 背景簡介
  • io_uring
  • 系統API
  • liburing
  • 高級特性
  • 編程示例
  • 性能對比
  • 模式對比
  • 線上應用

背景簡介

熟悉Linux系統編程的同學都清楚,Linux并沒有提供完善的異步IO(網絡IO、磁盤IO)機制。

在網絡編程中,我們通常使用epoll IO多路復用來處理網絡IO,然而epoll也并不是異步網絡IO,僅僅是內核提供了IO復用機制,epoll回調通知的是數據可以讀取或者寫入了,具體的讀寫操作仍然需要用戶去做,而不是內核代替完成。

在存儲IO棧中,做存儲的同學大都使用過libaio,然而那是一個巨難用啊Linux AIO這個奇葩。首先只能在DIO下使用,用不了pagecache;其次用戶的數據地址空間起始地址和大小必須頁大小對齊;然后在submit_io時仍然可能因為文件系統、pagecache、sync發生阻塞,除此之外,我們在使用libaio的時候會設置io_depth的大小,還可能因為內核的/sys/block/sda/queue/nr_requests(128)設置的過小而發生阻塞;而且libaio提供的sync命令關鍵還不起作用,想要sync數據還得依賴fsync/fdatasync,真的是心塞塞,libaio想說愛你不容易啊。

所以Linux迫切需要一個完善的異步機制。同時在Linux平臺上跑的大多數程序都是專用程序,并不需要內核的大多數功能,而且這幾年也流行kernel bypass,intel也發起的用戶態IO DPDK、SPDK。但是這些用戶態IO API不統一,使用成本過高,所以內核便推出了io_uring來統一網絡和磁盤的異步IO,提供一套統一完善的異步API,也支持異步、輪詢、無鎖、zero copy。真的是姍姍來遲啊,不過也算是在高性能IO方面也算是是扳回了一城。

io_uring

io_uring的設計目標是提供一個統一、易用、可擴展、功能豐富、高效的網絡和磁盤系統接口。其高性能依賴于以下幾個方面:

  1. 用戶態和內核態共享提交隊列(submission queue)和完成隊列(completion queue)。
  2. 用戶態支持Polling模式,不依賴硬件的中斷,通過調用IORING_ENTER_GETEVENTS不斷輪詢收割完成事件。
  3. 內核態支持Polling模式,IO 提交和收割可以 offload 給 Kernel,且提交和完成不需要經過系統調用(system call)。
  4. 在DirectIO下可以提前注冊用戶態內存地址,減小地址映射的開銷。

系統API

io_uring提供了3個系統調用API,雖然只有3個,但是直接使用起來還是蠻復雜的。

  • io_uring_setup
int io_uring_setup(unsigned entries, struct io_uring_params *params);

entries:queue depth,表示隊列深度。

io_uring_params:初始化時候的參數

在io_uring_setup返回的時候就已經初始化好了 SQ 和 CQ,此外,還有內核還提供了一個 Submission Queue Entries(SQEs)數組。

圖片

之所以額外采用了一個數組保存 SQEs,是為了方便通過 RingBuffer 提交內存上不連續的請求。SQ 和 CQ 中每個節點保存的都是 SQEs 數組的偏移量,而不是實際的請求,實際的請求只保存在 SQEs 數組中。這樣在提交請求時,就可以批量提交一組 SQEs 上不連續的請求。但由于 SQ,CQ,SQEs 是在內核中分配的,所以用戶態程序并不能直接訪問。io_setup 的返回值是一個 fd,應用程序使用這個 fd 進行 mmap,和 kernel 共享一塊內存。這塊內存共分為三個區域,分別是 SQ,CQ,SQEs。kernel 返回的 io_sqring_offset 和 io_cqring_offset 分別描述了 SQ 和 CQ 的指針在 mmap 中的 offset。而 SQEs 則直接對應了 mmap 中的 SQEs 區域。mmap 的時候需要傳入 MAP_POPULATE 參數,以防止內存被 page fault。

  • io_uring_enter
int io_uring_enter(unsigned int fd, u32 to_submit, u32 min_complete, u32 flags);

io_uring_enter即可以提交io,也可以來收割完成的IO,一般IO完成時內核會自動將SQE 的索引放入到CQ中,用戶可以遍歷CQ來處理完成的IO。

IO 提交的做法是找到一個空閑的 SQE,根據請求設置 SQE,并將這個 SQE 的索引放到 SQ 中。SQ 是一個典型的 RingBuffer,有 head,tail 兩個成員,如果 head == tail,意味著隊列為空。SQE 設置完成后,需要修改 SQ 的 tail,以表示向 RingBuffer 中插入一個請求。

io_uring_enter 被調用后會陷入到內核,內核將 SQ 中的請求提交給 Block 層。to_submit 表示一次提交多少個 IO。

如果 flags 設置了 IORING_ENTER_GETEVENTS,并且 min_complete > 0,那么這個系統調用會同時處理 IO 收割。這個系統調用會一直 block,直到 min_complete 個 IO 已經完成。

這個流程貌似和 libaio 沒有什么區別,IO 提交的過程中依然會產生系統調用。

但 io_uring 的精髓在于,提供了 submission offload 模式,使得提交過程完全不需要進行系統調用。

如果在調用 io_uring_setup 時設置了 IORING_SETUP_SQPOLL 的 flag,內核會額外啟動一個內核線程,我們稱作 SQ 線程。這個內核線程可以運行在某個指定的 core 上(通過 sq_thread_cpu 配置)。這個內核線程會不停的 Poll SQ,除非在一段時間內沒有 Poll 到任何請求(通過 sq_thread_idle 配置),才會被掛起。

圖片

當程序在用戶態設置完 SQE,并通過修改 SQ 的 tail 完成一次插入時,如果此時 SQ 線程處于喚醒狀態,那么可以立刻捕獲到這次提交,這樣就避免了用戶程序調用 io_uring_enter 這個系統調用。如果 SQ 線程處于休眠狀態,則需要通過調用 io_uring_enter,并使用 IORING_SQ_NEED_WAKEUP 參數,來喚醒 SQ 線程。用戶態可以通過 sqring 的 flags 變量獲取 SQ 線程的狀態。

https://github.com/axboe/liburing/blob/master/src/queue.c#L22

if (IO_URING_READ_ONCE(*ring->sq.kflags) & IORING_SQ_NEED_WAKEUP) {
*flags |= IORING_ENTER_SQ_WAKEUP;
return true;
}

  • io_uring_register

主要包含IORING_REGISTER_FILES、IORING_REGISTER_BUFFERS,在高級特性章節會描述。

int io_uring_register(unsigned int fd, unsigned int opcode, void *arg, unsigned int nr_args)

liburing

我們知道io_uring雖然僅僅提供了3個系統API,但是想要用好還是有一定難度的,所提fio大神本人封裝了一個Liburing,簡化了io_uring的使用,通過使用liburing,我們很容易寫出異步IO程序。

代碼位置:github.com/axboe/liburi,在使用的時候目前仍然需要拉取代碼,自己編譯,估計之后將會融入內核,在用戶程序中需要包含#include "liburing.h"。

列舉一些比較常用的封裝的API:github.com/axboe/liburi

// 非系統調用,初始化io_uring,entries:隊列深度 queue depth
extern int io_uring_queue_init(unsigned entries, struct io_uring *ring, unsigned flags);

// 非系統調用,清理io_uring
extern void io_uring_queue_exit(struct io_uring *ring);

// 非系統調用,獲取一個可用的 submit_queue_entry,用來提交IO
extern struct io_uring_sqe *io_uring_get_sqe(struct io_uring *ring);

// 非系統調用,準備階段,和libaio封裝的io_prep_writev一樣
static inline void io_uring_prep_writev(struct io_uring_sqe *sqe, int fd,const struct iovec *iovecs, unsigned nr_vecs, off_t offset)

// 非系統調用,準備階段,和libaio封裝的io_prep_readv一樣
static inline void io_uring_prep_readv(struct io_uring_sqe *sqe, int fd, const struct iovec *iovecs, unsigned nr_vecs, off_t offset)

// 非系統調用,把準備階段準備的data放進 submit_queue_entry
static inline void io_uring_sqe_set_data(struct io_uring_sqe *sqe, void *data)

// 非系統調用,設置submit_queue_entry的flag
static inline void io_uring_sqe_set_flags(struct io_uring_sqe *sqe, unsigned flags)

// 非系統調用,提交sq的entry,不會阻塞等到其完成,內核在其完成后會自動將sqe的偏移信息加入到cq,在提交時需要加鎖
extern int io_uring_submit(struct io_uring *ring);

// 非系統調用,提交sq的entry,阻塞等到其完成,在提交時需要加鎖。
extern int io_uring_submit_and_wait(struct io_uring *ring, unsigned wait_nr);

// 非系統調用 宏定義,會遍歷cq從head到tail,來處理完成的IO
#define io_uring_for_each_cqe(ring, head, cqe)

// 非系統調用 遍歷時,可以獲取cqe的data
static inline void *io_uring_cqe_get_data(const struct io_uring_cqe *cqe)

// 非系統調用 遍歷完成時,需要調整head往后移nr
static inline void io_uring_cq_advance(struct io_uring *ring, unsigned nr)

高級特性

io_uring里面提供了polling機制:IORING_SETUP_IOPOLL可以讓內核采用 Polling 的模式收割 Block 層的請求;IORING_SETUP_SQPOLL可以讓內核新起線程輪詢提交sq的entry。

IORING_REGISTER_FILES

這個的用途是避免每次 IO 對文件做 fget/fput 操作,當批量 IO 的時候,這組原子操作可以避免掉。

IORING_REGISTER_BUFFERS

如果應用提交到內核的虛擬內存地址是固定的,那么可以提前完成虛擬地址到物理 pages 的映射,避免在 IO 路徑上進行轉換,從而優化性能。用法是,在 setup io_uring 之后,調用 io_uring_register,傳遞 IORING_REGISTER_BUFFERS 作為 opcode,參數是一個指向 iovec 的數組,表示這些地址需要 map 到內核。在做 IO 的時候,使用帶 FIXED 版本的opcode(IORING_OP_READ_FIXED /IORING_OP_WRITE_FIXED)來操作 IO 即可。

內核在處理 IORING_REGISTER_BUFFERS 時,提前使用 get_user_pages 來獲得 userspace 虛擬地址對應的物理 pages。在做 IO 的時候,如果提交的虛擬地址曾經被注冊過,那么就免去了虛擬地址到 pages 的轉換。

IORING_SETUP_IOPOLL

這個功能讓內核采用 Polling 的模式收割 Block 層的請求。當沒有使用 SQ 線程時,io_uring_enter 函數會主動的 Poll,以檢查提交給 Block 層的請求是否已經完成,而不是掛起,并等待 Block 層完成后再被喚醒。使用 SQ 線程時也是同理。

編程示例

通過liburing使用起來還是比較方便的,不用操心內核的一些事情,簡直爽歪歪啊。具體可參考ceph:github.com/ceph/ceph/bl

  1. io_uring_queue_init 來初始化 io_uring。IORING_SETUP_IOPOLL / IORING_SETUP_SQPOLL。
  2. io_uring_submit 來提交 IO,在這個函數里面會判斷是否需要調用系統調用io_uring_enter。設置了IORING_SETUP_SQPOLL則不需要調用,沒有設置則需要用戶調用。
  3. io_uring_for_each_cqe 來收割完成的IO,這是一個for循環宏定義,后面直接跟 {} 就可以。

性能對比

intel團隊測試結果

可以看出來intel自己測試的結果表明延遲方面spdk比io_uring要低60%。使用了自己帶的perf的測試工具測的。

圖片

fio作者測試結果

4k randread,3D Xpoint 盤:

io_uring vs libaio,在非 polling 模式下,io_uring 性能提升不到 10%,好像并沒有什么了不起的地方。

然而 io_uring 提供了 polling 模式。在 polling 模式下,io_uring 和 SPDK 的性能非常接近,特別是高 QueueDepth 下,io_uring 有趕超的架勢,同時完爆 libaio。

圖片

模式對比

項目io_uringspdk
驅動程序內核態驅動程序有鎖用戶態驅動程序、無鎖、輪詢、線程綁定
run_to_completion非rtc模型,可能會有上下文切換?rtc模型,單線程擼到底
內存管理mmu、4k2MB大頁
提交任務有無鎖無鎖無鎖
系統調用可有可無無系統調用
用戶內核態切換輕量級的無內核切換
poll模型可選polling

線上應用

目前發現已經有幾個項目在做嘗試性的應用:rocksdb、ceph、spdk、第三方適配(nginx、redis、echo_server)

rocksdb

rocksdb官方實現了PosixRandomAccessFile::MultiRead()使用io_uring。

圖片

除此之外,tikv擴展了一些實現:openinx.github.io/ppt/i

  1. wal和sstbale的寫入使用io_uring,但是測完之后性能提升不明顯。
  2. compaction file write的時間降低了一半。
  3. 可用io_uring優化的點:參考 Conclusion & Future work 章節。

spdk

SPDK與io_uring新異步IO機制,在其抽象的通用塊層加入了io_uring的支持。

圖片

圖片

ceph

ceph的io_uring主要使用在block_device,抽象出了統一的塊設備,直接操作裸設備,對上層提供統一的讀寫方法。

bluefs僅僅需要提供append only的寫入即可,不需要提供隨機寫,大大簡化了bluefs的實現。

圖片

第三方適配(nginx、redis、echo_server)

第三方io_uring適配(nginx、redis、echo_server)性能測試結果:

redis:

以下是 redis 在 event poll 和 io_uring 下的 qps 對比:

  1. 高負載情況下,io_uring 相比 event poll,吞吐提升 8%~11%。
  2. 開啟 sqpoll 時,吞吐提升 24%~32%。這里讀者可能會有個疑問,開啟 sqpoll 額外使用了一個 CPU,性能為什么才提升 30% 左右?那是因為 redis 運行時同步讀寫就消耗了 70% 以上的 CPU,而 sq_thread 只能使用一個 CPU 的能力,把讀寫工作交給 sq_thread 之后,理論上 QPS 最多能提升 40% 左右(1/0.7 - 1 = 0.42),再加上 sq_thread 還需要處理中斷以及本身的開銷,因此只能有 30% 左右的提升。

nginx:

  1. 單 worker 場景,當連接數超過 500 時,QPS提升 20% 以上。
  2. connection 固定 1000,worker 數目在 8 以下時,QPS 有 20% 左右的提升。隨著 worker 數目增大,收益逐漸降低。
  3. 短連接場景,io uring 相對于 event poll 非但沒有提升,甚至在某些場景下有 5%~10% 的性能下降。究其原因,除了 io uring 框架本身帶來的開銷以外,還可能跟 io uring 編程模式下請求批量下發帶來的延遲有關。
聲明:本文內容及配圖由入駐作者撰寫或者入駐合作網站授權轉載。文章觀點僅代表作者本人,不代表電子發燒友網立場。文章及其配圖僅供工程師學習之用,如有內容侵權或者其他違規問題,請聯系本站處理。 舉報投訴
  • IO
    IO
    +關注

    關注

    0

    文章

    448

    瀏覽量

    39132
  • Linux系統
    +關注

    關注

    4

    文章

    593

    瀏覽量

    27392
  • 磁盤
    +關注

    關注

    1

    文章

    375

    瀏覽量

    25201
  • 程序
    +關注

    關注

    117

    文章

    3785

    瀏覽量

    81004
收藏 人收藏

    評論

    相關推薦

    Linux驅動學習筆記:異步IO

    前幾篇介紹了幾種IO模型,今天介紹另一種IO模型——異步IO
    發表于 06-12 16:24 ?684次閱讀

    異步IO是什么

    python 異步ioAsync IO is a concurrent programming design that has received dedicated support
    發表于 09-06 07:26

    異步的功能介紹

    promises-based flow-control abstraction utility. 這是一個由多個部分組成的博客系列文章,重點介紹異步的功能, 異步是一種基于Promise的流控制抽象...
    發表于 09-06 09:23

    HarmonyOS多媒體框架介紹

    ,致力于為開發者提供更好、更高效的使用體驗。接下來讓我們一起學習了解下HarmonyOS中的多媒體框架的相關知識吧! 多媒體框架介紹結構: 相機(Camera) 播放(Player) 音頻(Audio) 一
    發表于 01-03 16:36

    網絡編程框架netty io介紹

    深入理解網絡編程框架netty io歡迎大家下載學習
    發表于 09-28 07:36

    android框架與應用開發介紹

    android框架與應用開發介紹
    發表于 10-24 09:35 ?7次下載
    android<b class='flag-5'>框架</b>與應用開發<b class='flag-5'>介紹</b>

    《Linux設備驅動開發詳解》第9章、Linux設備驅動中的異步通知與異步IO

    《Linux設備驅動開發詳解》第9章、Linux設備驅動中的異步通知與異步IO
    發表于 10-27 11:33 ?0次下載
    《Linux設備驅動開發詳解》第9章、Linux設備驅動中的<b class='flag-5'>異步</b>通知與<b class='flag-5'>異步</b><b class='flag-5'>IO</b>

    異步傳輸和同步傳輸的區別介紹

    本文開始對異步傳輸進行了介紹,其中包括了異步傳輸工作原理和異步傳輸模式,其次介紹了同步傳輸的定義和特點,最后詳細
    發表于 03-02 14:09 ?1w次閱讀
    <b class='flag-5'>異步</b>傳輸和同步傳輸的區別<b class='flag-5'>介紹</b>

    一文詳細了解五種IO模型

    五種IO模型包括:阻塞IO、非阻塞IOIO多路復用、信號驅動IO異步
    的頭像 發表于 02-14 14:38 ?5899次閱讀
    一文詳細了解五種<b class='flag-5'>IO</b>模型

    詳解Netty高性能異步事件驅動的網絡框架

    大家好,今天我們來聊聊Netty的那些事兒,我們都知道Netty是一個高性能異步事件驅動的網絡框架
    的頭像 發表于 03-16 10:57 ?1842次閱讀

    簡單實用的框架,可用于快速增加或修改IO配置

    因為一旦有某一個 IO 配置錯誤,或者原來的配置沒有修改正確(比如一個 IO 在原來的硬件適配中是輸入,之后的硬件需要修改成輸出),那么你很難查出來這是什么問題,因為這個時候不僅硬件修改了,軟件也修改了,你需要先定位到底是軟件問題還是硬件問題,所以一個好用的
    的頭像 發表于 05-17 09:54 ?1015次閱讀

    一個高性能異步計算框架介紹

    這個庫是 Asynchronix 的一個分支,它持續努力地構建用于系統仿真的高性能異步計算框架。 這是一個簡潔的異步通道,以快速著稱,但也不會在正確性和質量方面取巧。它的性能主要來自于對 MPSC 用例的關注和一些精心的優化,包
    的頭像 發表于 10-25 09:50 ?799次閱讀

    多路IO復用模型和異步IO模型介紹

    多路 IO 復用模型 多路 IO 復用,有時也稱為事件驅動 IO。它的基本原理就是有個函數會不斷地輪詢所負責的所有 socket ,當某個 socket有數據到達了,就通知用戶進程。IO
    的頭像 發表于 10-08 17:21 ?778次閱讀
    多路<b class='flag-5'>IO</b>復用模型和<b class='flag-5'>異步</b><b class='flag-5'>IO</b>模型<b class='flag-5'>介紹</b>

    信號驅動IO異步IO的區別

    一. 談信號驅動IO (對比異步IO來看) 信號驅動IO 對比 異步 IO進行理解 信號驅動
    的頭像 發表于 11-08 15:32 ?1053次閱讀
    信號驅動<b class='flag-5'>IO</b>與<b class='flag-5'>異步</b><b class='flag-5'>IO</b>的區別

    linux異步io框架iouring應用

    Linux內核5.1支持了新的異步IO框架iouring,由Block IO大神也即Fio作者Jens Axboe開發,意在提供一套公用的網
    的頭像 發表于 11-08 15:39 ?672次閱讀
    linux<b class='flag-5'>異步</b><b class='flag-5'>io</b><b class='flag-5'>框架</b><b class='flag-5'>iouring</b>應用
    主站蜘蛛池模板: 亚洲国产精品嫩草影院| 亚洲国产在线综合018| 亚洲福利区| 97人妻碰视频在线观看| 国产成人无码精品久久久影院| 国产精品九九久久精品视| 快播电影网站大全| 天堂岛www天堂资源在线| 中文字幕网站在线观看| 国产99久久| 美丽的姑娘BD在线观看| 我的漂亮朋友在线观看全集免费| 中文人妻熟妇精品乱又伧| 国产成人v视频在线观看| 久久无码av三级| 午夜免费福利片| AAA级精品无码久久久国片| 国产亚洲视频中文字幕| 青柠高清在线观看完整版| 亚洲欧美一区二区三区导航| jizzhd中国| 久久精品热线免费| 微拍秒拍99福利精品小视频| 80岁色老头69av| 黄色大片aa| 少妇被阴内射XXXB少妇BB| 70岁妇女牲交色牲片| 海角国精产品一区一区三区糖心| 欧洲兽交另类AVXXX| 战狼4在线观看完免费完整版| 国产精品九九久久| 日本无码专区亚洲麻豆 | 成人女人A级毛片免费软件| 红尘影院在线观看| 受喷汁红肿抽搐磨NP双性| 99精品国产电影| 精品无人区一区二区三区| 甜宠溺H宝贝嗯撞PLAY啊| xiah俊秀| 暖暖日本免费播放| 中文字幕在线观看|