五、高级特性：SQE 链接与作依赖

io_uring 支持 SQE 之间的依赖关系定义，这对于构建复杂的 IO 流水线至关重要。

5.1 IOSQE_IO_LINK：强顺序执行

设置 IOSQE_IO_LINK 标志的 SQE 会与其后的 SQE 形成链接链，下一个 SQE 必须等上一个完成后才开始执行。如果链中某个操作失败，后续所有操作都会被取消。

flags |= IOSQE_IO_LINK;

sqe = io_uring_get_sqe(&ring); // 第二步：读取
io_uring_prep_rw(IORING_OP_READ, data_fd, buf, len, offset);
sqe->flags |= IOSQE_IO_LINK;

sqe = io_uring_get_sqe(&ring); // 第三步：写入
io_uring_prep_rw(IORING_OP_WRITE, out_fd, buf, len, 0);
// 最后一步不需要 IOSQE_IO_LINK

5.2 IOSQE_IO_HARDLINK：硬链接

IOSQE_IO_HARDLINK 比 IO_LINK 更严格——如果前一个操作失败，当前操作也会被取消（普通 IO_LINK 下即使前一个失败，当前操作仍会尝试执行）。

5.3 IOSQE_ASYNC：强制异步化

即使底层操作本身可以快速完成（如缓存命中），IOSQE_ASYNC 标志强制内核将该操作通过 io-workqueue 异步执行。这保证了延迟的一致性，对构建基于 io_uring 的时间轮询非常重要。

六、io_uring 网络编程实战：构建高并发 TCP 服务器

以下展示基于原生 io_uring 的 TCP 回显服务器核心架构——从接受连接、读取数据到写回响应的完整异步链路。

#include <liburing.h>
#include <sys/socket.h>
#include <netinet/in.h>

#define QUEUE_DEPTH 4096
#define BUF_SIZE 1024
#define MAX_CONNECTIONS 4096

enum {
    OP_ACCEPT,
    OP_READ,
    OP_WRITE,
};

struct conn_info {
    int fd;
    unsigned int op;
    char buf[BUF_SIZE];
};

struct io_uring ring;

void submit_accept(struct sockaddr_in *addr, socklen_t *len) {
    struct io_uring_sqe *sqe = io_uring_get_sqe(&ring);
    conn_info *ci = malloc(sizeof(struct conn_info));
    ci->fd = listen_fd;
    ci->op = OP_ACCEPT;
    io_uring_prep_accept(sqe, listen_fd, (struct sockaddr*)addr, len, 0);
    sqe->flags |= IOSQE_FIXED_FILE;
    io_uring_sqe_set_data(sqe, ci);
}

void submit_read(int fd, struct conn_info *ci) {
    struct io_uring_sqe *sqe = io_uring_get_sqe(&ring);
    ci->fd = fd;
    ci->op = OP_READ;
    io_uring_prep_recv(sqe, fd, ci->buf, BUF_SIZE, 0);
    io_uring_sqe_set_data(sqe, ci);
}

void submit_write(struct conn_info *ci) {
    struct io_uring_sqe *sqe = io_uring_get_sqe(&ring);
    ci->op = OP_WRITE;
    io_uring_prep_send(sqe, ci->fd, ci->buf, strlen(ci->buf), 0);
    io_uring_sqe_set_data(sqe, ci);
}

int main() {
    struct io_uring_params params = {0};
    params.flags = IORING_SETUP_SQPOLL;
    params.sq_thread_idle = 2000;
    
    io_uring_queue_init_params(QUEUE_DEPTH, &ring, &params);
    
    // 设置 listen socket...
    int listen_fd = setup_listener(8080);
    
    // 注册文件描述符和缓冲区
    int fds[MAX_CONNECTIONS] = {[0 ... MAX_CONNECTIONS-1] = -1};
    io_uring_register_files(&ring, fds, MAX_CONNECTIONS);
    
    struct sockaddr_in client_addr;
    socklen_t client_len = sizeof(client_addr);
    submit_accept(&client_addr, &client_len);
    
    while (1) {
        struct io_uring_cqe *cqe;
        io_uring_submit(&ring);
        io_uring_wait_cqe(&ring, &cqe);
        
        struct conn_info *ci = io_uring_cqe_get_data(cqe);
        int ret = cqe->res;
        io_uring_cqe_seen(&ring, cqe);
        
        if (ret < 0) continue;
        
        switch (ci->op) {
        case OP_ACCEPT:
            int new_fd = ret;
            submit_read(new_fd, ci);
            submit_accept(&client_addr, &client_len);
            break;
        case OP_READ:
            submit_write(ci);
            break;
        case OP_WRITE:
            submit_read(ci->fd, ci);
            break;
        }
    }
    return 0;
}

上述代码展示了基于 SQPOLL 模式的异步 accept-read-write 循环。关键点在于：submit_accept 同时提交新连接接受和下一轮接受的 SQE，OP_READ完成后触发OP_WRITE，OP_WRITE完成后复用OP_READ，形成无限事件循环。每个连接的生命周期完全由 SQE/CQE 驱动，无需线程池。

七、性能调优：让 io_uring 全力飞奔的关键参数

7.1 环形队列深度选择

SQ 深度不一味求大。过深会导致延迟增加（排队时间过长）、内存占用膨胀。建议根据负载特征选择：

• 低延迟块设备（NVMe）：256-512
• 通用文件服务器：1K-4K
• KCDN/对象存储：8K-16K
• 网络代理：4K-8K

7.2 批量提交与收割

批量填充 SQ 后一次性调用 io_uring_submit()，可以减少状态切换次数。每次收割多个 CQE 也有助于摊平处理开销。

// 批量提交模式
int batch_count = 0;
for (int i = 0; i < MAX_BATCH; i++) {
    struct io_uring_sqe *sqe = io_uring_get_sqe(&ring);
    if (!sqe) break;
    // 填充 SQE...
    batch_count++;
}
io_uring_submit(&ring); // 一次性提交 batch_count 个 SQE

7.3 并发 SQE 与 linked SQE 的权衡

无依赖的 SQE 可以被并行执行（多个 io-worker 线程）。但 linked SQE 强制顺序，若链中某个环节阻塞（如读取远端数据），后端操作全部等待。设计流水线时应审慎使用链接。

7.4 SQPOLL 模式下避免虚假唤醒

当 SQ 变空时，SQPOLL 内核线程会进入空闲状态（sq_thread_idle 后暂停），再次有新 SQE 时需要 CPU 唤醒线程。对于高吞吐场景，可以考虑将 sq_thread_idle 调整为 0（永不睡眠），代价是固定占用一个 CPU 核。

7.5 IORING_SETUP_ATTACH_WQ 跨进程共享

多进程负载均衡场景下，可通过 IORING_SETUP_ATTACH_WQ 将多个 io_uring 实例关联到同一组 io-worker 线程池，避免某个进程空闲而其他进程排队。

八、liburing 用户态封装：简化开发的利器

Linux 内核原始 API（syscall(__NR_io_uring_setup...)）艰涩难用。Jens Axboe 开发的 liburing 库提供了简洁的 C 接口封装，已成为事实上的用户态标准。

8.1 核心 API 映射

8.2 Rust tokio-uring

对于 Rust 生态，tokio-uring 项目实现了 io_uring 的异步适配器，使得基于 tokio 生态的框架可以直接使用 io_uring 作为底层 IO 引擎。它将 CQE 转换为 Rust 的 Future，并与 tokio 的调度器深度集成。

8.3 Go.lang 的 gouringo 与 sysION

Go 的 syscall 开销较大且与 netpoll 模型冲突，社区尝试了多种桥接方案。gouringo 提供了基于 golang.org/x/sys/unix 的低层封装，Ayush Tara 的 io_uring-go 库进一步封装为面向 channel 的 channel-based API。