如何覆盖默认的JobLauncher？Spring批处理批注

Question

有没有纯注解为Spring留档？我看到的90%的文档都是为xml实现编写的。

我正在尝试覆盖默认的JobLauncher以能够传递JobParameters，但我添加到下面代码中的任何JobLauncher函数都被忽略，而是运行默认的SimpleJobLauncher。

我想用4个不同的作业参数启动同一作业的4个并发实例。这些参数应该告诉读取器从哪个目录读取。

我可以使用@Value注释为目录传递值，但这似乎只允许我设置一个默认值，在运行之间不会更改。

创建作业时无法配置作业（“World”被完全忽略）

@EnableBatchProcessing
@Configuration
public class BatchConfiguration{
    private static final Logger log = LoggerFactory.getLogger(BatchConfiguration.class);

    @Resource
    public JobLauncher jobLauncher;

    @Resource
    public JobBuilderFactory jobBuilderFactory;

    @Resource
    public StepBuilderFactory stepBuilderFactory;

    @Bean
    @StepScope
    ItemReader<Record> reader(@Value("") String directory) {
        return new ExcelReader(directory);
    }

    @Bean
    public ItemProcessor processor() {
        return new ItemProcessor();
    }

    @Bean
    public JobCompletionNotificationListener listener(){
        return new JobCompletionNotificationListener();
    }

    @Bean
    public Writer writer() {
        Writer writer = new Writer();
        return writer;
    }

    //Job Definition
    @Bean
    public Job job(JobCompletionNotificationListener listener) {
        return jobBuilderFactory.get("job")
                .listener(listener)
                .flow(step1("World"))
                .end()
                .build();
    }

    @Bean
    public Step step1(String directory) {
        return stepBuilderFactory.get("step1")
                .<Record, Record> chunk(10)
                .reader(reader(directory))
                .processor(processor())
                .writer(writer())
                .build();
    }
}

我正在使用启动应用程序

    SpringApplication.run(Application.class, args);

是否有更好的方法启动应用程序？？

Answer 1

如果希望持久化sb元数据（推荐），可以更新transactionManager bean。

@Bean
    public ResourcelessTransactionManager transactionManager() {
        return new ResourcelessTransactionManager();
    }

    @Bean
    public MapJobRepositoryFactoryBean mapJobRepositoryFactory(ResourcelessTransactionManager txManager)
            throws Exception {
        MapJobRepositoryFactoryBean factory = new MapJobRepositoryFactoryBean(txManager);
        factory.afterPropertiesSet();
        return factory;
    }

    @Bean
    public JobRepository jobRepository(MapJobRepositoryFactoryBean factory) throws Exception {
        return factory.getObject();
    }

    @Bean
    public JobExplorer jobExplorer(MapJobRepositoryFactoryBean factory) {
        return new SimpleJobExplorer(factory.getJobInstanceDao(), factory.getJobExecutionDao(),
                factory.getStepExecutionDao(), factory.getExecutionContextDao());
    }

    @Bean
    public SimpleJobLauncher jobLauncher(JobRepository jobRepository) {
        SimpleJobLauncher launcher = new SimpleJobLauncher();
        launcher.setJobRepository(jobRepository);
        return launcher;
    }

Answer 2

没有关于注释文档的消息，但我找到了传递参数的答案。因为我们不使用xml，所以可以使用AnnotationConfigApplicationContext，并指定最上面的包。然后，我们使用此上下文获取默认作业启动器，并在启动作业时传递参数。

    ApplicationContext context = new AnnotationConfigApplicationContext("package.names.*");
    JobLauncher jobLauncher = (JobLauncher) context.getBean("jobLauncher");
    Job job = (Job) context.getBean("testJob");


    Map<String, JobParameter> params = new HashMap<String, JobParameter>();
    JobExecution execution = null;
    JobParameters jp = null;
    try {
        params.put("directory", new JobParameter("testfolder"));
        jp = new JobParameters(params);
        execution = jobLauncher.run(job, jp);

    } catch (Exception e) {
        e.printStackTrace();
    }