使用CompletableFuture异步调用报ScopeNotActiveException问题求助

你这段代码里用CompletableFuture.supplyAsync()默认使用JDK的ForkJoinPool.commonPool()线程池执行异步任务，但这个线程池里的线程没有绑定Spring的request请求上下文。而someClass.someMethod()内部依赖了request作用域的bean（scopedTarget.clientContextProcessor），导致异步线程尝试访问该bean时，抛出请求作用域未激活的异常。

1. 传递请求上下文到异步线程 #

如果必须在异步任务中使用request上下文，可以在主线程先获取上下文，再在异步任务中设置：

// 主线程获取当前请求上下文
RequestAttributes requestAttrs = RequestContextHolder.getRequestAttributes();

CompletableFuture[] futures = stringList.stream().map(stringListRef -> CompletableFuture.supplyAsync(() -> {
        // 异步线程中设置上下文
        RequestContextHolder.setRequestAttributes(requestAttrs);
        try {
            String[] stringArray = stringListRef.split("-");
            return someClass.someMethod(stringArray[0], stringArray[1], string1, "", string2);
        } finally {
            // 任务结束后清理上下文，避免线程复用导致的上下文污染
            RequestContextHolder.resetRequestAttributes();
        }
    }).thenAccept(response -> responseMap.put(stringListRef, response))).toArray(CompletableFuture[]::new);
CompletableFuture.allOf(futures).join();

注意：这种方式仅适用于异步任务在原request生命周期内完成的场景，如果异步任务耗时较长，原request对象可能已被销毁，会引发其他问题。

2. 给request作用域bean配置代理 #

修改clientContextProcessor的配置，添加scoped proxy，让Spring生成代理对象来处理跨线程的作用域问题：

注解方式 #

@Component
@Scope(value = WebApplicationContext.SCOPE_REQUEST, proxyMode = ScopedProxyMode.TARGET_CLASS)
public class ClientContextProcessor {
    // bean的实现代码
}

XML配置方式 #

<bean id="clientContextProcessor" class="com.yourpackage.ClientContextProcessor" scope="request">
    <aop:scoped-proxy/>
</bean>

这种方式的局限性：如果异步线程完全没有request上下文，bean的方法调用仍可能报错，需要确保bean的实现能处理无request的情况。

3. 重构代码，避免异步线程依赖request上下文 #

最稳妥的方案是提前在主线程（原request线程）获取someMethod需要的request相关参数，直接传递给方法，不再让方法依赖request作用域的bean：

// 主线程中获取request相关参数
String requiredRequestParam = (String) RequestContextHolder.getRequestAttributes().getAttribute("paramName", RequestAttributes.SCOPE_REQUEST);

CompletableFuture[] futures = stringList.stream().map(stringListRef -> CompletableFuture.supplyAsync(() -> {
        String[] stringArray = stringListRef.split("-");
        // 将提前获取的参数传入方法，不再依赖request作用域bean
        return someClass.someMethod(stringArray[0], stringArray[1], string1, "", string2, requiredRequestParam);
    }).thenAccept(response -> responseMap.put(stringListRef, response))).toArray(CompletableFuture[]::new);
CompletableFuture.allOf(futures).join();

这种方式从根源上避免了跨线程的作用域依赖，是推荐的最佳实践。

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