在工作线程使用@RequestScoped类时的请求日志同步问题求助

针对你遇到的异步线程无法共享@RequestScoped日志对象的问题，提供以下几种可行的解决方案：

方案一：直接传递Logs实例到异步任务 #

最简单直接的方式是将请求作用域的Logs对象作为参数传递给异步执行的方法，绕过上下文依赖：

修改异步代码的调用逻辑：

@Inject
Logs logs;

// 启动异步任务时传入Logs实例
Uni.createFrom().item(myItem)
    .emitOn(Infrastructure.getDefaultWorkerPool())
    .subscribe().with(item -> myFunc(item, logs));

对应的异步方法调整参数：

private void myFunc(MyItem item, Logs logs) {
    // 直接使用传入的Logs实例添加日志
    logs.add(new Log(...));
}

这种方式不需要依赖上下文传播，适用于简单的异步场景，确保所有日志都存入同一个请求对应的Logs实例。

方案二：利用Reactive上下文传播（Quarkus环境） #

如果你的项目基于Quarkus，它原生支持Reactive Context Propagation，可以让@RequestScoped上下文自动跟随Uni的链式调用传递到异步线程中：

1. 确保添加了依赖（如果使用Maven）：

<dependency>
    <groupId>io.quarkus</groupId>
    <artifactId>quarkus-reactive-context-propagation</artifactId>
</dependency>

2. 修改异步代码的调用方式，使用invoke代替直接subscribe（或确保上下文被正确捕获）：

Uni.createFrom().item(myItem)
    .emitOn(Infrastructure.getDefaultWorkerPool())
    .invoke(this::myFunc) // invoke会自动传播请求上下文
    .subscribeAsCompletionStage();

此时在myFunc中注入的Logs实例会和原请求上下文保持一致，日志会正确存入对应的集合中。

方案三：改用请求ID关联，即时打印日志 #

如果接受逐条即时记录日志，可以通过请求ID来聚合同一请求的所有日志，无需统一收集：

1. 创建请求作用域的Bean存储请求ID：

@RequestScoped
class RequestContext {
    private final String requestId = UUID.randomUUID().toString();

    public String getRequestId() {
        return requestId;
    }
}

2. 在同步/异步方法中，打印日志时带上该ID：

@Inject
RequestContext requestContext;
@Inject
Logger logger;

// 同步方法
private void syncFunc() {
    logger.info("[%s] 同步操作日志", requestContext.getRequestId());
}

// 异步方法（同样传递RequestContext或通过上下文获取）
private void myFunc(MyItem item, RequestContext requestContext) {
    logger.info("[%s] 异步操作日志", requestContext.getRequestId());
}

后续可以通过日志系统（如ELK、Splunk）根据requestId字段聚合同一请求的所有日志，达到和统一输出相同的效果。

方案四：手动管理ThreadLocal（不推荐） #

如果无法使用上下文传播，也可以手动将Logs实例存入ThreadLocal，但这种方式在Reactive线程池复用场景下容易引发上下文污染和内存泄漏，仅作为兜底方案：

// 在请求线程中设置ThreadLocal
private ThreadLocal<Logs> logThreadLocal = new ThreadLocal<>();

// 启动异步任务前设置
logThreadLocal.set(logs);

Uni.createFrom().item(myItem)
    .emitOn(Infrastructure.getDefaultWorkerPool())
    .subscribe().with(item -> {
        try {
            Logs currentLogs = logThreadLocal.get();
            currentLogs.add(new Log(...));
        } finally {
            // 必须清理ThreadLocal，避免污染其他请求
            logThreadLocal.remove();
        }
    });

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