Spring Batch步骤间共享数据最优方式？附数据库配置复用场景

一、JobExecutionContext是不是最佳方式？ #

是的，JobExecutionContext是Spring Batch中跨Step共享作业级上下文数据的标准方案，完全适配你的场景：它的生命周期与JobExecution绑定，作业运行期间所有Step都能访问，且默认支持持久化（配合作业仓库配置），即使作业重启也能复用已加载的配置，彻底避免每条记录重复查询数据库的问题。

二、其他替代方案 #

• StepExecutionContext：如果配置仅在单个Step内使用，用这个更合适——它的作用域限定为单个Step，比JobExecutionContext粒度更细，避免不必要的跨Step数据共享。
• Spring单例Bean注入：若配置信息可在作业启动前确定（比如从配置文件、环境变量读取），可提前加载为Spring单例Bean，直接注入到Reader/Processor/Writer中。但如果配置需要在作业运行时动态查询（比如依赖作业参数动态获取），这种方式不适用。
• 自定义ThreadLocal：可在作业启动时加载配置并存入ThreadLocal，在Processor/Writer中读取。但要注意：Spring Batch多线程Step场景下ThreadLocal无法跨线程共享，且作业结束后需手动清理避免内存泄漏，安全性和可靠性远不如JobExecutionContext。

三、使用JobExecutionContext时：存JobParameter还是监听器？ #

不推荐存入JobParameter #

JobParameter的设计初衷是传递作业启动时的输入参数（比如CSV文件路径、作业运行日期），它会作为作业实例的唯一标识部分——相同参数会复用作业实例。如果把配置存入JobParameter，会带来以下问题：

1. 配置信息可能体积较大，不符合JobParameter轻量的设计定位；
2. 配置变化时，即使作业逻辑未变，也会生成新的作业实例，不符合预期；
3. JobParameter仅支持基本类型（String、Long、Date、Double），复杂配置对象需要手动序列化/反序列化，操作繁琐。

推荐通过监听器加载存入 #

最佳实践是在作业启动阶段，通过JobExecutionListener的beforeJob方法加载配置并存入JobExecutionContext：

@Component
public class ConfigLoadingListener implements JobExecutionListener {

    @Autowired
    private ConfigRepository configRepository;

    @Override
    public void beforeJob(JobExecution jobExecution) {
        // 仅查询一次配置
        BatchConfig config = configRepository.getRequiredConfig();
        jobExecution.getExecutionContext().put("batchGlobalConfig", config);
    }

    @Override
    public void afterJob(JobExecution jobExecution) {
        // 可选：清理资源
    }
}

之后在Reader/Processor/Writer中，通过StepExecution获取JobExecutionContext读取配置：

public class CsvItemProcessor implements ItemProcessor<CsvRecord, DbEntity> {

    @Override
    public DbEntity process(CsvRecord item) throws Exception {
        StepExecution stepExecution = StepSynchronizationManager.getContext().getStepExecution();
        JobExecutionContext jobContext = stepExecution.getJobExecution().getExecutionContext();
        BatchConfig config = (BatchConfig) jobContext.get("batchGlobalConfig");
        // 利用配置处理记录
        return new DbEntity(item.getField1(), item.getField2(), config.getRule());
    }
}

这种方式的优势：

• 配置加载逻辑与业务逻辑解耦，代码结构更清晰；
• 确保配置仅在作业启动时加载一次，彻底避免重复查询；
• 依托Spring Batch的生命周期管理，无需手动处理上下文的创建与销毁。

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