Spring Boot并行流中SpEL无法找到ContextHolder类的问题

核心原因 #

并行流依赖的ForkJoinPool工作线程，默认使用系统类加载器，而你的com.company.package.ContextHolder是由Spring应用专属的类加载器（比如RestartClassLoader）加载的。当SpEL表达式在并行流线程中执行时，无法找到自定义的ContextHolder类，因此抛出EL1005E错误。

可行解决方案 #

1. 手动切换线程上下文类加载器 #

在并行流的任务逻辑中，强制将线程的上下文类加载器替换为主线程的应用类加载器：

// 先获取主线程的应用类加载器
ClassLoader appClassLoader = Thread.currentThread().getContextClassLoader();

sheet.parallelStream().forEach(row -> {
    // 替换并行线程的类加载器
    Thread.currentThread().setContextClassLoader(appClassLoader);
    // 调用publishEvent方法
    yourMessagingGateway.publishEvent(...);
});

2. 提前获取租户ID，绕过SpEL解析 #

在主线程中先拿到租户ID，再将其作为参数传入并行流任务，直接传递给MessagingGateway，避免在并行线程中执行SpEL：

// 主线程中获取租户ID
String tenantId = com.company.package.ContextHolder.getTenantId();

sheet.parallelStream().forEach(row -> {
    // 直接传入tenantId，修改@GatewayHeader配置匹配参数
    yourMessagingGateway.publishEvent(tenantId, ...);
});

对应的Gateway配置示例：

@MessagingGateway
public interface YourGateway {
    @Gateway(requestHeaders = @GatewayHeader(name = "tenantId", expression = "#args[0]"))
    void publishEvent(String tenantId, ...);
}

3. 自定义ForkJoinPool指定类加载器 #

创建专属的ForkJoinPool，配置线程工厂让工作线程使用应用类加载器，再用这个池执行并行任务：

// 创建自定义ForkJoinPool
ForkJoinPool customPool = new ForkJoinPool(
    Runtime.getRuntime().availableProcessors(),
    pool -> {
        ForkJoinWorkerThread thread = ForkJoinPool.defaultForkJoinWorkerThreadFactory.newThread(pool);
        thread.setContextClassLoader(Thread.currentThread().getContextClassLoader());
        return thread;
    },
    null,
    false
);

// 提交并行任务
customPool.submit(() -> sheet.parallelStream().forEach(row -> {
    yourMessagingGateway.publishEvent(...);
})).join();

推荐方案 #

优先选择方案2，既不需要处理类加载器的复杂逻辑，也能避免线程上下文切换带来的潜在问题，代码更简洁可控。

内容的提问来源于stack exchange，提问作者Hasan Can Saral