Spring Batch双步骤作业中ReaderA被重复初始化的问题排查

这种情况我之前在配置Spring Batch作业时也碰到过，结合你描述的现象——readerA()方法执行两次，但stepA()和stepB()各执行一次，大概率是配置类中Bean的获取方式不当导致的，下面给你拆解原因和解决办法：

核心原因 #

在Spring配置类里，如果你定义stepA和stepB时，是直接调用readerA()方法来获取Reader实例，而不是通过Spring容器的依赖注入来获取，那么每次调用这个方法都会创建一个新的Reader对象。因为Spring对@Bean标注的方法，只有通过容器注入（比如方法参数注入、@Autowired注入）时，才会复用单例Bean；直接调用方法的话，会绕过Spring的Bean管理机制，每次调用都执行方法体创建新实例。

举个典型的错误写法示例：

@Configuration
public class BatchConfig {

    @Bean
    public ItemReader<String> readerA() {
        System.out.println("初始化readerA");
        return new FlatFileItemReader<>();
    }

    @Bean
    public Step stepA() {
        return stepBuilderFactory.get("stepA")
                .<String, String>chunk(10)
                .reader(readerA()) // 直接调用方法，会创建新实例
                .writer(writerA())
                .build();
    }

    @Bean
    public Step stepB() {
        return stepBuilderFactory.get("stepB")
                .<String, String>chunk(10)
                .reader(readerA()) // 再次调用，又创建一个新实例
                .writer(writerB())
                .build();
    }
}

这种写法就会导致readerA()被调用两次，对应两个独立的Reader实例。

解决办法 #

方法1：通过依赖注入复用单例Reader #

修改Step的配置方法，把需要的Reader作为方法参数传入，Spring会自动注入全局单例的Reader实例：

@Configuration
public class BatchConfig {

    @Bean
    public ItemReader<String> readerA() {
        System.out.println("初始化readerA");
        return new FlatFileItemReader<>();
    }

    // 将readerA作为参数注入stepA
    @Bean
    public Step stepA(ItemReader<String> readerA) {
        return stepBuilderFactory.get("stepA")
                .<String, String>chunk(10)
                .reader(readerA)
                .writer(writerA())
                .build();
    }

    // 同样注入readerA到stepB
    @Bean
    public Step stepB(ItemReader<String> readerA) {
        return stepBuilderFactory.get("stepB")
                .<String, String>chunk(10)
                .reader(readerA)
                .writer(writerB())
                .build();
    }
}

这样readerA()只会被Spring容器调用一次，创建单例Bean，两个Step共享同一个实例。

方法2：调整作用域（如果需要独立实例） #

如果你确实需要每个Step使用独立的Reader实例（比如Reader标记了@StepScope或@JobScope），那两次初始化是正常的；但如果这不是你的预期，只需去掉作用域注解，让Reader成为全局单例即可。

额外验证小技巧 #

你可以在readerA()方法里加日志或者断点，查看两次调用的调用栈：

• 如果是直接调用方法导致的，调用栈会显示是stepA()和stepB()方法分别触发了readerA()调用；
• 如果是作用域导致的，调用栈会包含Spring Batch的Scope代理相关类的调用逻辑。

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