Spring Batch分区器：如何将Reader类作为Bean注入Step配置

你的核心需求是将Slave Step中通过pagingItemReader(null,null)手动调用的方式，改成和ItemProcessor、ItemWriter一致的依赖注入方式，具体修改方案如下：

1. 修改Slave Step的Bean定义，通过方法参数注入Reader #

由于pagingItemReader带有@StepScope注解，属于Step作用域的Bean，不能在单例的slaveStep Bean中直接调用方法实例化。需要通过方法参数注入的方式，让Spring容器自动处理StepScope的依赖初始化：

@Bean
public Step slaveStep(JdbcPagingItemReader<DailyTransactionByUserId> pagingItemReader) 
{
    try {
        return new StepBuilder("slaveStep", jobRepository)
                .<DailyTransactionByUserId, DailyTransactionByUserId>chunk(
                    feraDailyTransactionByUserIdBatchProperties.getDailyTransactionByUserIdBatchStep1ReaderPageSize(),
                    transactionManager
                )
                .taskExecutor(dailyTransactionByUserTaskExecutor())
                .reader(pagingItemReader) // 直接使用注入的Reader实例
                .processor(dialyTransactionByUserIdProcessor())
                .writer(dialyTransactionByUserIdItemWriter())
                .build();
    } catch (Exception ex) {
        throw new RuntimeException("Error creating slave step: " + ex.getMessage());
    }
}

2. 为什么不能直接调用pagingItemReader(null,null)？ #

• pagingItemReader标注了@StepScope，意味着这个Bean的实例是在Step执行阶段才会被创建，而非Spring容器启动时。手动调用方法相当于直接new对象，Spring无法自动注入@Value("#{stepExecutionContext['fromRow']}")这类Step上下文参数，会导致参数无法正确获取。
• 通过方法参数注入的方式，Spring会自动识别StepScope Bean的特性，在Step执行时完成Reader的初始化，并正确注入fromRow和toRow参数。

额外优化建议 #

你的ItemWriter和ItemProcessor的Bean定义可以简化，无需通过appContext.getBean()手动获取，直接依赖注入更符合Spring规范：

@Bean
public ItemWriter<DailyTransactionByUserId> dialyTransactionByUserIdItemWriter(DailyTransactionByUserWriter userWriter) {
    return userWriter;
}

@Bean
public ItemProcessor<DailyTransactionByUserId, DailyTransactionByUserId> dialyTransactionByUserIdProcessor(DailyTransactionByUserProcessor userProcessor) {
    return userProcessor;
}

内容的提问来源于stack exchange，提问作者Shreyas Holla P