Spring Batch场景下@PostConstruct注解的替代方案及问题求解

问题根本原因 #

你遇到的冲突本质是两个时机不匹配+依赖注入使用错误：

1. @PostConstruct 是Spring Bean初始化阶段就会执行的逻辑，远早于批处理任务的Step1运行，必然只会读到任务启动前的旧文件
2. 你在配置Step2时直接 new PublishSnsTopic() 手动实例化对象，Spring不会给手动new的对象注入ResourceLoader、FileProperties这些依赖，这才是你之前把逻辑移出@PostConstruct就报空指针的核心原因。

具体修复方案 #

1. 修正Step2的Tasklet注入方式

你已经给SNSTopicSender加了@Service注解，Spring容器已经托管了这个类的实例，直接注入使用即可，不要手动new：

// 首先在你的Job配置类中注入Spring托管的SNSTopicSender实例
@Autowired
SNSTopicSender snsTopicSender;

@Bean
Step step2() {
    return this.stepBuilderFactory
                .get("step2")
                .tasklet(snsTopicSender) // 直接用容器注入的实例，不要手动new
                .build()
}

2. 把文件读取、消息发送逻辑移到Tasklet的execute方法中

execute方法是Step2实际运行时才会触发的逻辑，此时Step1已经执行完毕，S3中的CSV是最新生成的版本，而且容器注入的所有依赖都已经初始化完成，不会出现空指针：

// 类上只保留@Service即可，@Configuration是配置类注解，不需要加在业务组件上
@Service
class SNSTopicSender implements Tasklet {

    @Autowired
    ResourceLoader resourceLoader;

    @Autowired
    FileProperties fileProperties;

    void publishTopic(SnsClient snsClient, String message, String arn) {
        // 原有发送SNS消息的逻辑
    }

    @Override
    RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) throws Exception {
        // Step2执行时才加载最新的CSV文件
        String badStudentCSVFileName = "s3://students/failedStudents.csv";
        Reader badStudentReader = new InputStreamReader(
                this.resourceLoader.getResource(badStudentCSVFileName).getInputStream()
        );
        // 此处补充创建消息体、调用publishTopic发送消息的逻辑
        return RepeatStatus.FINISHED;
    }
}

可选优化 #

如果你的批处理任务可能同时跑多个实例，可给SNSTopicSender加上@StepScope注解，保证每个Step运行时都拿到独立的实例，避免状态冲突。

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