当前位置:首页 > 文章列表 > 文章 > linux > Linux BPF ring buffer 怎样向用户态传递事件

Linux BPF ring buffer 怎样向用户态传递事件

来源:17golang原创 2026-10-09 14:23:15 0浏览 收藏

Linux BPF ring buffer 向用户态传递事件的基本做法是:创建一个 BPF_MAP_TYPE_RINGBUF map,BPF 程序把结构化记录写入其中,用户态用 libbpf 的 ring_buffer__new() 注册回调,再通过 ring_buffer__poll() 消费事件。内核侧可以选 bpf_ringbuf_output() 复制写入,也可以用 bpf_ringbuf_reserve() 直接预留记录,填写后调用 bpf_ringbuf_submit()。

高频、固定大小事件通常适合 reserve/submit;动态长度或从 perf buffer 迁移时,output 更直接。无论哪种方式,ring buffer 满时都不会阻塞等待,程序必须接受写入失败并记录丢事件。

我真正需要的不是“打印”,而是一条事件通道

刚开始写 BPF 观测程序时,我也习惯先用调试输出确认探针是否触发。但一旦要长期运行,用户态需要的是字段稳定、可批量消费、能统计丢失的事件通道,而不是一串难解析的文本。ring buffer 正好把这条边界拆开:BPF 程序负责采集和提交,用户态负责等待、解析和持久化。

官方内核文档给出的两个设计动机很实用:一个 ring buffer 可以跨 CPU 共享内存,提高利用率;多生产者共享同一缓冲区时,还能按预留顺序保留跨 CPU 事件的全局顺序。它以 BPF map 的形式存在,因此可继续使用 map 的内省和 libbpf 工具链。

先搭出最小的事件通道

map 不需要 key 和 value,max_entries 表示缓冲区大小,并且必须是 2 的幂。内核态和用户态还要共享同一份事件结构定义;实际项目通常把结构体放进共同头文件,避免两边字段尺寸漂移。

// common.h:内核态和用户态共享的事件布局。
struct event {
    __u32 pid;
    char comm[16];
};

// BPF 对象中的 ring buffer map;容量必须是 2 的幂。
struct {
    __uint(type, BPF_MAP_TYPE_RINGBUF);
    __uint(max_entries, 256 * 1024);
} events SEC(".maps");

这里的 256 KiB 只是便于理解的起点,不是通用最佳值。容量应结合事件大小、峰值事件率和用户态最坏处理延迟估算,并用丢事件指标调整。

BPF 程序、共享 ring buffer 和用户态轮询回调的静态结构关系图
图1:事件通道结构图——BPF 程序写入共享 ring buffer,用户态由 libbpf 轮询并把每条记录交给回调解析。

BPF 侧用 reserve/submit 写入固定大小事件

对固定大小事件,我更愿意用 reserve/submit。bpf_ringbuf_reserve() 成功后直接返回 ring buffer 数据区中的记录指针,BPF 程序原地填写,不需要先在栈上准备完整结构再复制一次。代价是预留大小必须让验证器在加载时确定。

SEC("tracepoint/syscalls/sys_enter_execve")
int handle_exec(struct trace_event_raw_sys_enter *ctx)
{
    struct event *e;

    // 空间不足时立即失败,不阻塞当前内核执行路径。
    e = bpf_ringbuf_reserve(&events, sizeof(*e), 0);
    if (!e) {
        // 生产代码可在单独的计数 map 中累加 dropped 指标。
        return 0;
    }

    // 只写用户态真正需要的稳定字段,降低单条记录大小。
    e->pid = bpf_get_current_pid_tgid() >> 32;
    bpf_get_current_comm(&e->comm, sizeof(e->comm));

    // submit 让记录对消费者可见;此后不能再访问 e。
    bpf_ringbuf_submit(e, 0);
    return 0;
}

成功 reserve 的记录必须在所有分支上以 bpf_ringbuf_submit() 或 bpf_ringbuf_discard() 结束。验证器会跟踪这类引用,遗漏释放路径通常会导致程序无法通过验证。discard 不会把内容交给消费者,适合预留后发现过滤条件不满足,或者需要放弃一组临时记录的情况。

用户态用 libbpf poll 并校验记录长度

用户态先通过 skeleton 取得 map 文件描述符,再创建 ring buffer manager。每当有记录可消费,libbpf 会调用回调。回调收到的是裸数据指针和长度,所以解析前应先检查 len,不要直接假定两边结构完全一致。

#include 
#include 
#include 

static int on_event(void *ctx, void *data, size_t len)
{
    const struct event *e = data;

    // 长度不足说明用户态布局与记录不匹配,跳过本条避免越界读取。
    if (len pid, e->comm);
    return 0;
}

static int consume_events(struct demo_bpf *skel)
{
    struct ring_buffer *rb;
    int err = 0;

    // 由 skeleton 中的 ring buffer map 创建用户态消费者。
    rb = ring_buffer__new(
        bpf_map__fd(skel->maps.events),
        on_event,
        NULL,
        NULL
    );
    if (!rb)
        return -1;

    while (!stop) {
        // 100 毫秒超时让循环能定期检查退出标志。
        err = ring_buffer__poll(rb, 100);
        if (err == -EINTR)
            break;
        if (err 

上面的 demo_bpf 和 stop 代表项目自己的 skeleton 类型与退出标志。完整程序还需要负责 open、load、attach、信号处理和 skeleton 销毁;这里刻意只保留事件消费边界。

output 与 reserve/submit 怎么选

bpf_ringbuf_output() 接收一块已经准备好的数据并复制到 ring buffer。它多一次复制,但允许记录长度在运行时决定,也更接近 bpf_perf_event_output() 的调用方式,迁移旧程序时往往更省改动。

bpf_ringbuf_reserve() 直接提供 ring buffer 内存,省掉复制,也绕开 BPF 栈空间偏小带来的临时存储问题。不过预留大小必须是验证器可知的常量,而且成功预留后必须严谨收尾。我的选择通常是:固定结构、高频事件用 reserve;长度不固定或先求迁移简单时用 output。

bpf_ringbuf_output 与 reserve submit discard 生命周期边界的静态对照图
图2:写入 API 边界图——output 复制已有事件,reserve 直接取得记录空间,但必须由 submit 或 discard 完成生命周期。
维度bpf_ringbuf_outputreserve/submit
数据准备先在其他位置准备直接填写 ring buffer 记录
额外复制有避免一次复制
记录长度可在运行时确定预留大小需可由验证器确定
生命周期单次调用reserve 后必须 submit/discard
适合场景迁移、可变长度事件固定结构、高频采集

生产环境里最容易忽略的三个坑

ring buffer 满了不会等待

官方语义是空间不足时预留失败,不会阻塞内核执行路径。只有检查返回值还不够,最好用单独的 per-CPU 计数 map 记录 dropped 次数,否则用户态看到的“事件减少”无法区分业务真的变少还是缓冲区溢出。

poll 更快不等于回调可以做重活

用户态回调如果同步写慢磁盘、发网络请求或做复杂格式化,消费者位置推进会变慢,最终反过来增加丢事件。更稳妥的做法是让回调只完成长度校验、轻量复制和入队,再由普通工作线程处理重任务。

共享 ring buffer 有顺序优势,也有争用代价

单个 ring buffer 是多生产者、单消费者结构,可以保留跨 CPU 的预留顺序,也共享内存。但极高写入压力下,所有生产者共享同一资源可能产生争用。内核文档说明 ring buffer 还能与 map-in-map 组合,按 CPU、进程组或其他键分片;是否分片应由顺序要求和压力指标决定,而不是默认照搬。

完整落地清单

  • 用共同头文件固定事件布局,新增字段时考虑兼容和长度检查。
  • 让 max_entries 保持为 2 的幂,并根据峰值速率与消费延迟估算容量。
  • 所有 reserve 成功路径最终都调用 submit 或 discard。
  • 预留失败时增加 dropped 指标,不在 BPF 程序里阻塞重试。
  • 用户态回调先验证 len,再访问字段,并保持处理轻量。
  • 退出时中断 poll、释放 ring buffer manager,再销毁 skeleton。

相关问题

BPF ring buffer 能保证所有事件都不丢吗?

不能。缓冲区空间不足、NMI 上下文预留锁竞争或用户态消费过慢都可能导致预留失败。可靠做法是监控丢失计数,并根据业务决定扩容、降采样或减少事件字段。

一定要用 ring_buffer__poll 吗?

不一定。官方设计支持 epoll 通知,也允许为极低延迟做忙轮询。大多数常驻观测程序用带超时的 poll 更容易兼顾延迟、CPU 占用和优雅退出。

ring buffer 与 perf buffer 的主要差别是什么?

perf buffer 通常按 CPU 分配,而 BPF ring buffer 可以让多个 CPU 共享同一缓冲区,从而改善内存利用率,并更自然地保存跨 CPU 的事件顺序。是否迁移仍要结合现有用户态库、顺序要求和性能数据判断。

把 BPF 事件送到用户态,核心不是记住几个 helper 名称,而是守住三条边界:事件结构两端一致、每次预留都有结束动作、空间不足有可观察的丢失指标。做到这三点,ring buffer 才能从演示代码变成可长期运行的观测通道。

参考资料:Linux 内核文档:BPF ring buffer。

版本声明
本文转载于:17golang原创 如有侵犯,请联系study_golang@163.com删除
Python dataclasses.replace 遇到 InitVar 时怎样传递参数Python dataclasses.replace 遇到 InitVar 时怎样传递参数
上一篇
Python dataclasses.replace 遇到 InitVar 时怎样传递参数
slices.Delete 后旧元素为何仍可能占用内存
下一篇
slices.Delete 后旧元素为何仍可能占用内存
查看更多
最新文章
查看更多
课程推荐
  • 前端进阶之JavaScript设计模式
    前端进阶之JavaScript设计模式
    设计模式是开发人员在软件开发过程中面临一般问题时的解决方案,代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景,打造一站式知识长龙服务,适合有JS基础的同学学习。
    543次学习
  • GO语言核心编程课程
    GO语言核心编程课程
    本课程采用真实案例,全面具体可落地,从理论到实践,一步一步将GO核心编程技术、编程思想、底层实现融会贯通,使学习者贴近时代脉搏,做IT互联网时代的弄潮儿。
    516次学习
  • 简单聊聊mysql8与网络通信
    简单聊聊mysql8与网络通信
    如有问题加微信:Le-studyg;在课程中,我们将首先介绍MySQL8的新特性,包括性能优化、安全增强、新数据类型等,帮助学生快速熟悉MySQL8的最新功能。接着,我们将深入解析MySQL的网络通信机制,包括协议、连接管理、数据传输等,让
    500次学习
  • JavaScript正则表达式基础与实战
    JavaScript正则表达式基础与实战
    在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
    487次学习
  • 从零制作响应式网站—Grid布局
    从零制作响应式网站—Grid布局
    本系列教程将展示从零制作一个假想的网络科技公司官网,分为导航,轮播,关于我们,成功案例,服务流程,团队介绍,数据部分,公司动态,底部信息等内容区块。网站整体采用CSSGrid布局,支持响应式,有流畅过渡和展现动画。
    485次学习
查看更多
AI推荐
  • PubMedQA数据集详解:生物医学问答基准、功能与应用指南
    PubMedQA
    深入了解PubMedQA生物医学问答数据集,涵盖其核心功能、使用方法及在临床决策、药物研发等场景的应用,助力提升NLP模型性能。
    388次使用
  • H2O EvalGPT:开源LLM大模型评估与排行榜工具
    H2O EvalGPT
    H2O EvalGPT是H2O.ai推出的开源LLM评估平台,提供详细的大模型性能排行榜、行业特定基准测试及A/B测试功能,助您快速选择最适合项目的高性能大语言模型。
    469次使用
  • LMArena是什么?伯克利AI模型评估平台使用指南与功能解析
    LMArena
    LMArena是加州大学伯克利分校推出的AI模型匿名评测平台。通过盲测投票机制,用户可对比不同大模型回答并生成实时排行榜,助力开发者优化模型及用户选择最佳AI工具。
    476次使用
  • 斯坦福HELM:大语言模型Holistic Evaluation整体评估框架详解
    HELM
    深入了解斯坦福推出的HELM(Holistic Evaluation of Language Models)大模型评测体系。本文解析其核心功能、安装配置步骤及应用场景,涵盖准确性、公平性、鲁棒性等多维度指标,助力开发者全面优化语言模型性能。
    420次使用
  • MMBench详解:多模态大模型基准测试、功能特点与使用指南
    MMBench
    MMBench是由上海人工智能实验室等机构联合推出的多模态基准测试平台,提供细粒度能力评估、大规模数据集及VLMEvalKit工具。本文详细介绍其核心功能、安装使用方法及应用场景,助力开发者全面评估多模态模型性能。
    244次使用
微信登录更方便
  • 密码登录
  • 注册账号
登录即同意 用户协议 和 隐私政策
返回登录
  • 重置密码