4.3 多 shot 接受 (Multishot Accept)

Linux 6.0+ 引入 IORING_RECV_MULTISHOT。一次提交 accept 请求，内核在完成一次 accept 后自动重新提交，持续产出新连接。减少高频 accept 的系统调用开销。

4.4 零拷贝网络 (Zero-Copy TX)

通过 IORING_SEND_ZC flag，数据包从用户缓冲区直接 DMA 到网卡，内核仅传递元数据。实测 TX 吞吐量可提升 40%-60%。

五、Rust + tokio-uring 实战开发

5.1 tokio-uring 简介

tokio-uring 是 Tokio 团队推出的实验性运行时，将 io_uring 作为底层 I/O 引擎。与传统 epoll-based tokio 相比，它在高并发 I/O 场景下有显著优势。

// Cargo.toml
[dependencies]
tokio-uring = "0.4"

// 创建运行时
fn main() {
    tokio_uring::builder().start(async {
        let file = tokio_uring::fs::File::open("data.bin").await.unwrap();
        let buf = vec![0u8; 4096];
        let (res, buf) = file.read_at(buf, 0).await;
        let n = res.unwrap();
        println!("Read {} bytes", n);
    });
}

5.2 构建 async TCP echo server

use tokio_uring::net::{TcpListener, TcpStream};

async fn handle_client(stream: TcpStream) -> std::io::Result<()> {
    let mut buf = vec![0u8; 8192];
    loop {
        let (read_res, read_buf) = stream.read(buf).await;
        let n = read_res?;
        if n == 0 { break; }
        let (write_res, _) = stream.write(read_buf).await;
        write_res?;
        buf = read_buf;  // buffer 回收
    }
    Ok(())
}

fn main() {
    tokio_uring::builder().start(async {
        let listener = TcpListener::bind("0.0.0.0:8080".parse().unwrap()).unwrap();
        loop {
            let (stream, _) = listener.accept().await.unwrap();
            tokio_uring::spawn(handle_client(stream));
        }
    });
}

5.3 io_uring-based 简易 KV 引擎

基于 io_uring 直接操作文件，绕过页面缓存（O_DIRECT），实现用户态 KV 引擎。每 4KB 一记录，CRC32 校验。

pub struct UringKV {
    file: tokio_uring::fs::File,
    path: PathBuf,
}

impl UringKV {
    pub async fn put(&self, key: &str, value: &[u8]) -> io::Result<()> {
        let offset = self.key_to_offset(key);
        let mut record = vec![0u8; 4096];
        record[0..8].copy_from_slice(&(key.len() as u64).to_le_bytes());
        record[8..8+key.len()].copy_from_slice(key.as_bytes());
        // CRC32 校验 + 双缓冲恢复（略）
        let (res, _) = self.file.write_at(record, offset).await;
        res.map(|_| ())
    }
}

六、性能基准测试

测试环境：AMD EPYC 7543, Samsung PM9A3 NVMe, Linux 6.1, queue_depth=256

七、生产实践与陷阱规避

7.1 队列深度调优

过大的 CQ 会浪费内存且增加延迟。建议规则：queue_depth = active_connections × 1.5（若使用固定 buffer 可降至 ×1.2）。

7.2 SQPOLL 饥饿问题

SQPOLL 内核线程运行在普通优先级，可能在高 CPU 负载下被抢占导致 I/O 停滞。建议：

• 设置 sched_setscheduler 为 SCHED_FIFO 或设置 nice -15
• 使用 IORING_SETUP_ATTACH_WQ 绑定到已有的 worker pool
• 监控 SQPOLL thread CPU 使用率

7.3 内存序注意

SQ 和 CQ 的 head/tail 是共享变量，用户态和内核态之间无锁通信依赖正确的 memory barrier。liburing 封装层已处理，但若直接操作 mmap 区域需注意 smp_store_release 和 smp_load_acquire。

7.4 版本兼容性

八、总结

io_uring 不只是"更快的 AIO"，它是 Linux I/O 范式的一次根本性重构。从 block layer 到 network stack，从 storage 到 crypto，越来越多的子系统开始原生集成 io_uring。对于追求极致性能的高并发服务、KV 存储引擎、网络代理而言，掌握 io_uring 已不再是加分项，而是必备能力。

建议学习路线：先通过 liburing C API 理解底层机制 → tokio-uring 实战开发 → 阅读内核源码 io_uring/io_uring.c 深入调度细节。