Spring Batch (modular=true)创建两次作业配置bean


@Configuration
@EnableBatchProcessing(modular=true)
public class ModularJobConfiguration {
    @Bean
    public ApplicationContextFactory job() {
        return new GenericApplicationContextFactory(FlatfileToDbJobConfiguration.class);
    }
    @Bean
    public ApplicationContextFactory anotherJob() {
        return new GenericApplicationContextFactory(FlatfileToDbJobAnotherConfiguration.class);
    }
}

例如只显示一个配置,另一个像这样。

@Configuration
public class FlatfileToDbJobConfiguration {
        @Autowired
        private JobBuilderFactory jobBuilders;
        @Autowired
        private StepBuilderFactory stepBuilders;
        @Bean
        public Job flatfileToDbJob(){
            return jobBuilders.get("flatfileToDbJob")
                    .listener(protocolListener())
                    .start(step())
                    .build();
        }
        @Bean
        public Step step(){
            return stepBuilders.get("step")
                    .<Partner,Partner>chunk(1)
                    .reader(reader())
                    .processor(processor())
                    .writer(writer())
                    .build();
        }
        // ...
        // rest part of code
        // ...
}

所有工作正常,但配置文件中的所有bean方法调用两次。我认为,首先是在公共环境中,其次是在个人环境中。这正常吗?我不能用post construct,因为它会调用两次。如何有模块化=真,只有一个bean初始化?谢谢!

我找到答案了。我需要@Lazy初始化。然后config将初始化创建的单个上下文。

@Configuration
@Lazy
public class FlatfileToDbJobConfiguration {
        @Autowired
        private JobBuilderFactory jobBuilders;
        @Autowired
        private StepBuilderFactory stepBuilders;
        @Bean
        public Job flatfileToDbJob(){
            return jobBuilders.get("flatfileToDbJob")
                    .listener(protocolListener())
                    .start(step())
                    .build();
        }
        @Bean
        public Step step(){
            return stepBuilders.get("step")
                    .<Partner,Partner>chunk(1)
                    .reader(reader())
                    .processor(processor())
                    .writer(writer())
                    .build();
        }
        // ...
        // rest part of code
        // ...
}

最新更新