需先调用io_uring_queue_init_params初始化环形缓冲区并设置IOPOLL/SQPOLL标志,再预注册fd以加速I/O,接着通过user_data绑定读请求与上下文,批量提交后无锁收割CQE,最后确保所有CQE处理完毕且上下文释放后再调用io_uring_queue_exit。

一、封装io_uring实例并初始化环形缓冲区
io_uring需要在用户空间预先分配并注册一个内核可直接访问的环形缓冲区,该缓冲区包含提交队列(SQ)、完成队列(CQ)及其关联的共享内存页。封装的第一步是调用io_uring_queue_init_params配置参数并完成初始化,确保支持IORING_SETUP_IOPOLL与IORING_SETUP_SQPOLL等高性能模式。
1、声明struct io_uring ring变量,并调用io_uring_queue_init_params传入所需队列深度(如4096)及参数结构体。
2、设置params.flags |= IORING_SETUP_IOPOLL以启用轮询模式,减少中断开销;若支持且需更高吞吐,额外设置params.flags |= IORING_SETUP_SQPOLL启用内核线程提交。
3、检查io_uring_queue_init_params返回值,若为负数则表示初始化失败,必须检查errno并打印具体错误码(如-ENOSYS表示内核不支持io_uring)。
二、注册文件描述符以加速后续操作
对频繁读写的文件描述符进行预注册,可避免每次提交请求时重复执行fd校验与引用计数操作,显著降低每次I/O请求的CPU开销。注册后所有对该fd的操作均可使用注册索引替代原始fd值。
1、打开目标文件获取原始fd,例如通过open("/path/to/file", O_RDWR | O_DIRECT)获得Direct I/O兼容句柄。
2、构造struct io_uring_sqe *sqe = io_uring_get_sqe(&ring),调用io_uring_prep_register_files(sqe, &fd, 1)准备注册单个fd。
3、调用io_uring_submit_and_wait(&ring, 1),等待注册完成;注册失败将导致后续使用file_index触发-EBADF错误。
三、构建异步读请求并绑定完成回调上下文
io_uring本身不提供回调函数机制,需在用户空间维护请求与上下文的映射关系。典型做法是将自定义结构体指针通过user_data字段嵌入sqe,并在CQE中原样返回,从而实现上下文关联。
1、定义struct read_context { int fd_idx; void* buffer; size_t len; off_t offset; std::function
2、调用io_uring_get_sqe(&ring)获取sqe,使用io_uring_prep_read(sqe, fd_idx, buffer, len, offset)填充读操作;
3、设置sqe->user_data = reinterpret_cast
四、批量提交与无锁收割完成事件
为最大化吞吐,应避免每次单个请求都调用io_uring_submit,而采用批处理方式积累多个sqe后统一提交;同时收割CQE时应使用io_uring_peek_batch_cqe配合io_uring_cqe_seen,避免加锁竞争。
1、在提交前循环调用io_uring_get_sqe(&ring)填充多个sqe,累计达阈值(如32个)或需立即响应时调用io_uring_submit(&ring)。
2、调用io_uring_peek_batch_cqe(&ring, cqe_array, max_count)一次性获取最多max_count个已完成CQE指针数组。
3、对每个非空cqe,提取cqe->user_data还原上下文对象,根据cqe->res值判断结果,cqe->res为负数时表示系统错误码(如-EIO),需按绝对值转为errno处理。
五、安全释放资源与防止内存泄漏
io_uring实例销毁前必须确保所有已提交但未完成的请求已被收割,且所有通过user_data挂载的堆内存已正确析构。未收割的CQE会导致user_data悬空,引发UAF漏洞。
1、循环调用io_uring_peek_cqe(&ring, &cqe)直至返回-EAGAIN,确保全部CQE已被处理并调用io_uring_cqe_seen(&ring, cqe)标记。
2、遍历所有曾分配的read_context或write_context对象,显式调用delete释放;禁止依赖析构函数自动清理——因CQE可能延迟到达,对象可能已被提前销毁。
3、调用io_uring_queue_exit(&ring),该函数会自动取消未完成请求并释放环形缓冲区内存;必须在所有上下文对象释放完毕后调用,否则可能触发use-after-free。
C++免费学习笔记(深入):立即使用
在学习笔记中,你将探索 C++ 的入门与实战技巧!











