Spring Batch中Reader->Processor->Writer数据流转原理及代码问题排查

数据流核心原理 #

Spring Batch 中 Reader→Processor→Writer 的数据流确实是通过 StepBuilder 完成绑定的：

• Step 初始化时，会将三者串联成一条执行链
• 执行时，Reader 每次读取一条（或一个 chunk 批量）数据，传递给 Processor 处理
• Processor 处理后的结果会被传递给 Writer 进行写入操作
• 如果 Reader 返回 null（表示无更多数据），Step 会终止执行，后续 Processor 和 Writer 不会再被调用

排查 Processor/Writer 未执行的关键步骤 #

1. 确认 Reader 是否读取到数据 #

这是最常见的原因：

• 在 Reader 的 read() 方法中添加日志输出，观察是否有数据返回，或者是否直接返回 null
• 检查 Reader 配置逻辑：比如 JDBC 类型 Reader 的 SQL 语句是否正确、是否存在符合条件的休眠账户数据；自定义 Reader 是否正确实现了数据读取逻辑
• 查看运行日志中的 readCount 指标，如果值为 0，说明 Reader 未读取到任何数据，后续环节自然不会执行

2. 检查 Step 配置是否完整 #

• 确保 StepBuilder 完整调用了 .reader()、.processor()、.writer() 三个方法，没有遗漏任何一个环节
• 示例正确的 Step 配置：

@Bean
public Step manageInactiveAccountsStep(ItemReader<Account> inactiveAccountReader,
                                       ItemProcessor<Account, Account> inactiveAccountProcessor,
                                       ItemWriter<Account> inactiveAccountWriter,
                                       JobRepository jobRepository,
                                       PlatformTransactionManager transactionManager) {
    return new StepBuilder("manageInactiveAccountsStep", jobRepository)
            .<Account, Account>chunk(10) // 批量处理大小，按需调整
            .reader(inactiveAccountReader)
            .processor(inactiveAccountProcessor)
            .writer(inactiveAccountWriter)
            .transactionManager(transactionManager)
            .build();
}

• 确认 Step 对应的 Bean 已被 Spring 容器正确扫描并注册

3. 验证 Job 与 Step 的关联 #

• 检查 Job 配置是否将目标 Step 加入执行流程，示例：

@Bean
public Job manageInactiveAccountsJob(Step manageInactiveAccountsStep, JobRepository jobRepository) {
    return new JobBuilder("manageInactiveAccountsJob", jobRepository)
            .start(manageInactiveAccountsStep)
            .build();
}

• 确认 Job 已被正确触发（比如通过 JobLauncher 手动启动、定时任务触发等）

4. 查看 Batch 元数据状态 #

Spring Batch 会将执行状态写入元数据表（默认是 H2 或配置的数据库），可通过以下表排查：

• BATCH_STEP_EXECUTION：查看 READ_COUNT、WRITE_COUNT、STATUS 字段，确认 Step 是否执行、是否有数据流转
• BATCH_JOB_EXECUTION：确认 Job 的整体执行状态是否正常

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