如何用Rust的tracing-subscriber构建多写入器全局过滤器订阅器

正确实现代码 #

你需要将顶层目标过滤器应用到整个Registry订阅器上，同时为每个写入层添加独立的级别过滤器。这里是调整后的代码：

use tracing::{Level, metadata::LevelFilter};
use tracing_appender::{
    non_blocking::WorkerGuard,
    rolling::{RollingFileAppender, Rotation},
};
use tracing_subscriber::{
    fmt, filter::EnvFilter, prelude::*, Registry,
};

fn main() {
    // 保存WorkerGuard以确保日志被flush
    let mut guards = Vec::new();

    // 层1：文件写入器，仅记录INFO及以上级别
    let rolling_log = RollingFileAppender::new(Rotation::NEVER, "hey", "cool.log");
    let (non_blocking, guard) = tracing_appender::non_blocking(rolling_log);
    guards.push(guard);
    let file_layer = fmt::Layer::default()
        .with_writer(non_blocking)
        .with_filter(LevelFilter::from(Level::INFO));

    // 层2：标准输出写入器，仅记录ERROR及以上级别
    let (non_blocking, guard) = tracing_appender::non_blocking(std::io::stdout());
    guards.push(guard);
    let stdout_layer = fmt::Layer::default()
        .with_writer(non_blocking)
        .with_filter(LevelFilter::from(Level::ERROR));

    // 顶层目标过滤器：module_a=info, module_b=error
    let top_filter = EnvFilter::new("module_a=info,module_b=error");

    // 组合订阅器：Registry + 顶层过滤器 + 两个写入层
    Registry::default()
        .with(top_filter)
        .with(file_layer)
        .with(stdout_layer)
        .init();

    // 测试日志
    tracing::info!(target: "module_a", "这是module_a的info日志");
    tracing::error!(target: "module_a", "这是module_a的error日志");
    tracing::info!(target: "module_b", "这是module_b的info日志（不会被记录）");
    tracing::error!(target: "module_b", "这是module_b的error日志");
}

关键逻辑解释 #

• 过滤器优先级：顶层EnvFilter先过滤所有日志事件，只有通过顶层过滤的事件才会传递给各个Layer；每个Layer的LevelFilter会再次筛选，比如文件层只保留INFO及以上级别，stdout层只保留ERROR及以上级别。
• WorkerGuard的必要性：必须保存non_blocking返回的WorkerGuard，否则日志后台线程会提前退出，导致部分日志丢失。
• Registry的作用：Registry是tracing-subscriber提供的标准订阅器实现，负责管理span和事件的上下文，同时支持通过with()方法组合多个Layer和全局过滤器。

tracing组件协作逻辑 #

tracing核心组件分工明确：

• Subscriber：事件的接收者，Registry是最常用的实现，负责追踪span生命周期和存储上下文数据。
• Layer：事件的处理器，每个Layer可以独立定义输出格式、写入目标和过滤规则，多个Layer可叠加，同一事件会被所有符合条件的Layer处理。
• Filter：用于筛选事件，既可以全局应用到Subscriber（顶层过滤），也可以单独应用到某个Layer（层内过滤）。

流程总结：事件产生后，先经过Subscriber的全局过滤器，再依次传递给每个Layer，每个Layer用自身过滤器二次筛选，最后输出到目标位置。

学习资源推荐 #

• 官方文档：tracing和tracing-subscriber的crates.io文档包含详细组件说明和示例。
• 社区教程：Rust官方博客、Rust Lang论坛中有不少开发者分享的tracing实战配置案例，可搜索“tracing rust 多写入器”“tracing rust 过滤器配置”获取相关内容。

内容的提问来源于stack exchange，提问作者twitu