异步CDI事件接收时如何保留@RequestScoped上下文？

当你使用event.fireAsync()替代同步fire()时，默认CDI不会传播原请求的上下文——因为异步任务运行在独立线程中，而请求上下文是线程绑定的。以下是几种无需手动传递租户信息的解决方案：

1. 使用MicroProfile Context Propagation（推荐，标准规范） #

MicroProfile Context Propagation是Java EE/Eclipse MicroProfile的标准规范，专门用于在异步、线程切换场景中传播上下文（包括请求上下文）。

步骤： #

• 添加MicroProfile Context Propagation依赖（以Maven为例）：

<dependency>
    <groupId>org.eclipse.microprofile.context-propagation</groupId>
    <artifactId>microprofile-context-propagation-api</artifactId>
    <version>1.3</version>
    <scope>provided</scope>
</dependency>

• 在触发异步事件时，使用ThreadContext捕获并传播原请求上下文：

@Inject
private ThreadContext threadContext;

@Inject
private Event<MyObject> event;

public void triggerAsyncEvent(MyObject myObject) {
    // 将事件触发逻辑包装在上下文传播的Runnable中
    Runnable contextualTask = threadContext.contextualRunnable(() -> event.fire(myObject));
    // 异步执行任务
    CompletableFuture.runAsync(contextualTask);

    // 或者直接给fireAsync传入上下文感知的执行器
    ExecutorService contextualExecutor = threadContext.contextualExecutor(Executors.newCachedThreadPool());
    event.fireAsync(myObject, contextualExecutor);
}

• 观察者方法无需修改，即可正常访问请求范围内的Bean：

public void handleAsyncEvent(@ObservesAsync MyObject myObject, @Inject TenantContext tenantContext) {
    // 这里可以直接获取原请求的租户信息，无需手动传递
    persistToDatabase(tenantContext.getTenantId(), myObject);
}

2. 利用Weld容器的内置上下文传播特性 #

如果你使用的是Weld（WildFly、JBoss等容器默认的CDI实现），Weld提供了内置的上下文传播支持，无需额外引入MicroProfile依赖：

配置方式： #

• 在beans.xml中添加Weld的上下文传播配置：

<beans xmlns="http://xmlns.jcp.org/xml/ns/javaee"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:weld="http://jboss.org/schema/weld/beans"
       xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee http://xmlns.jcp.org/xml/ns/javaee/beans_2_0.xsd
                           http://jboss.org/schema/weld/beans http://jboss.org/schema/weld/beans_1_1.xsd"
       version="2.0">
    <weld:context-propagation>
        <weld:include>request</weld:include>
    </weld:context-propagation>
</beans>

• 之后直接使用fireAsync()即可自动传播请求上下文，观察者方法无需修改。

3. 自定义CDI扩展（兜底方案） #

如果上述标准/容器方案不适用，可以自定义CDI扩展，手动捕获并恢复请求上下文：

扩展实现示例： #

public class RequestContextPropagationExtension implements Extension {

    public void interceptAsyncEvent(@Observes ProcessAsyncEvent<?> event) {
        RequestContext requestContext = CDI.current().select(RequestContext.class).get();
        if (requestContext.isActive()) {
            // 捕获当前请求上下文的关键信息（比如租户ID）
            TenantContext tenantCtx = CDI.current().select(TenantContext.class).get();
            String tenantId = tenantCtx.getTenantId();

            // 包装异步任务，执行前恢复请求上下文
            event.setAsyncTaskFactory(originalTask -> () -> {
                try {
                    // 激活请求上下文
                    requestContext.activate();
                    // 恢复租户信息到新的请求上下文Bean中
                    TenantContext newTenantCtx = CDI.current().select(TenantContext.class).get();
                    newTenantCtx.setTenantId(tenantId);

                    // 执行原事件逻辑
                    originalTask.run();
                } finally {
                    // 清理上下文
                    requestContext.invalidate();
                    requestContext.deactivate();
                }
            });
        }
    }
}

• 注册扩展：在META-INF/services/javax.enterprise.inject.spi.Extension文件中添加扩展类的全限定名。

注意事项： #

• 上下文传播会带来一定的性能开销，需根据实际场景评估。
• 如果异步任务涉及跨进程/节点执行，需确保上下文数据可序列化。

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