Spring Batch多线程步报No context holder available for job scope怎么解决

你遇到的Scope 'job' is not active for the current thread报错，核心原因是：Spring Batch默认只会把StepContext传播到多线程步骤的子线程中，不会传播JobContext，你的SoftLayerDataItemQueue使用了job scope，子线程访问时找不到对应的JobContext上下文就会抛出该异常。

要解决当前报错，只需要给多线程步骤使用的线程池添加上下文传播逻辑即可，示例配置如下：

import org.springframework.batch.core.scope.JobSynchronizationManager;
import org.springframework.context.annotation.Bean;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import java.util.concurrent.Executor;

@Bean
public Executor jobContextPropagationExecutor() {
    ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
    executor.setCorePoolSize(8);
    executor.setMaxPoolSize(16);
    executor.setQueueCapacity(100);
    // 核心逻辑：线程装饰器传播JobContext
    executor.setTaskDecorator(runnable -> {
        // 父线程获取当前JobExecution
        var currentJobExecution = JobSynchronizationManager.getContext().getJobExecution();
        return () -> {
            try {
                // 子线程注册JobExecution
                JobSynchronizationManager.register(currentJobExecution);
                runnable.run();
            } finally {
                // 执行完清理上下文，避免内存泄漏
                JobSynchronizationManager.release();
            }
        };
    });
    executor.initialize();
    return executor;
}

将上述线程池配置到你的writeToDatabaseStep的多线程配置中即可解决scope报错问题。

另外你当前的SoftLayerDataItemQueue实现存在两个隐患：

• 类成员queueMap使用了非线程安全的HashMap，多job并发执行时会出现并发问题，建议替换为ConcurrentHashMap
• 读写Queue时没有做并发控制，多线程读写同一个队列可能出现数据异常，建议使用ConcurrentLinkedQueue实现队列

你不想用自定义队列的话，Spring Batch生态下最推荐两种方案，天然支持并行处理、有事务保障：

1. 临时表中转方案（最推荐） #

• 步骤1读取Excel后，直接写入一张临时中间表，表中增加job_instance_id字段做不同作业实例的数据隔离
• 步骤2配置为分区步骤，按范围或者分片规则读取临时表数据，多线程并行写入目标表
• 作业执行完成后，清理当前job_instance_id对应的临时表数据即可
  该方案不存在内存溢出风险，支持超大数据量传输，也符合Spring Batch的设计规范。

2. 临时文件中转方案 #

• 步骤1读取Excel后，将数据序列化为CSV/JSON格式写入本地临时文件，文件名携带jobInstanceId做隔离
• 步骤2使用Spring Batch自带的多线程分区文件读取能力，并行读取临时文件内容写入数据库
• 作业执行完成后删除临时文件即可
  该方案适合数据量较大、不想额外占用数据库存储的场景。

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