Spring Batch远程分区Worker步骤执行上下文与数据库不一致问题

看起来你遇到了Spring Batch远程分区里很常见的StepExecution同步问题——Worker已经把执行结果正确写入数据库了，但Manager端内存里的JobExecution对象是缓存的初始版本，没有同步数据库的最新变化，这就是为啥你看到数据库里BATCH_STEP_EXECUTION的记录符合预期，但Java代码里拿到的上下文为空、计数为0，甚至步骤状态显示STARTING的原因。下面是针对你的问题的具体分析和解决方案：

核心原因拆解 #

在远程分区模式下，Worker节点独立执行步骤后，会把StepExecution的状态、读写计数等信息更新到共享的JobRepository（也就是你的MySQL数据库）。但Manager端一开始加载的JobExecution对象是缓存的，不会自动感知数据库里的更新，所以内存里的对象还是初始的STARTING状态，计数也都是0。

具体解决方案 #

1. 从JobRepository重新加载最新的StepExecution #

别直接用jobExecution.stepExecutions()返回的缓存对象，而是通过JobRepository主动从数据库拉取Worker步骤的最新执行记录，这是最直接有效的解决办法。

示例代码（Manager端的Tasklet实现）：

@Bean
public Tasklet summaryTasklet(JobRepository jobRepository) {
    return (contribution, chunkContext) -> {
        JobExecution jobExecution = chunkContext.getStepContext().getJobExecution();
        // 从JobRepository重新加载Worker步骤的StepExecution
        StepExecution workerStepExecution = jobRepository.getStepExecution(jobExecution, STEP_NAME_MAIN_WORKER);
        
        if (workerStepExecution != null) {
            // 现在能拿到正确的读写计数和状态了
            int readCount = workerStepExecution.getReadCount();
            int writeCount = workerStepExecution.getWriteCount();
            String actualStatus = workerStepExecution.getStatus().name();
            
            // 这里处理你的业务逻辑，比如打印或存储计数
            System.out.printf("Worker步骤读取计数：%d，写入计数：%d，实际状态：%s%n", readCount, writeCount, actualStatus);
        }
        return RepeatStatus.FINISHED;
    };
}

2. 确保Worker端正确同步自定义指标到ExecutionContext #

如果你需要把自定义的业务指标（不是Spring Batch自动维护的read/write count）写入StepExecutionContext，要保证在Worker的StepExecutionListener里正确设置，并且Worker执行完后这些数据能被提交到数据库。

比如你的partitionImportSummaryListener可以这么写：

@Component
public class PartitionImportSummaryListener implements StepExecutionListener {

    @Override
    public void beforeStep(StepExecution stepExecution) {
        // 初始化逻辑（如果需要）
    }

    @Override
    public ExitStatus afterStep(StepExecution stepExecution) {
        // 假设你有自定义的导入成功记录数
        int successImportCount = ...; // 从你的业务逻辑中获取
        // 将自定义指标写入ExecutionContext
        stepExecution.getExecutionContext().putInt("successImportCount", successImportCount);
        
        // Spring Batch远程分区会自动提交StepExecution到JobRepository，不需要手动调用
        return ExitStatus.COMPLETED;
    }
}

之后在Manager端重新加载StepExecution后，就能通过workerStepExecution.getExecutionContext().getInt("successImportCount")拿到自定义指标了。

3. 验证远程分区的基础配置 #

• 确认Manager和Worker使用同一个JobRepository（指向同一个MySQL数据库），不然Worker的更新根本传不到Manager这边。
• 检查远程分区的通道配置（requests()和outboundRequests()）是否正确，确保Worker能正常接收任务，并且执行结果能同步回数据库。

额外说明 #

Spring Batch远程分区里，Worker执行完步骤后会自动更新数据库的BATCH_STEP_EXECUTION记录，但Manager端不会主动刷新内存里的JobExecution对象，所以主动从JobRepository加载是获取最新执行状态和计数的可靠方式。

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