作业/步骤/读取器/写入器都应该是bean吗？

Question

@Bean
public Job footballJob() {
    return this.jobBuilderFactory.get("footballJob")
                     .listener(sampleListener())
                     ...
                     .build();
}

@Bean
public Step sampleStep(PlatformTransactionManager transactionManager) {
    return this.stepBuilderFactory.get("sampleStep")
                .transactionManager(transactionManager)
                .<String, String>chunk(10)
                .reader(itemReader())
                .writer(itemWriter())
                .build();
}

我有一个场景，服务器端将接收请求并并发运行作业（不同的作业名或相同的作业名具有不同的jobparameters）。它的用法是在并发线程中新建一个作业对象（包括steps/reader/writer)，所以我不打算每次将作业方法声明为@bean并新建一个作业。

实际上，在如何将参数传输到像Reader这样的对象上存在差异。如果使用@bean，必须将参数放入例如JobParameters中，以便使用@stepscope将其后期绑定到object，如下所示：

@StepScope
@Bean
public FlatFileItemReader flatFileItemReader(@Value(
"#{jobParameters['input.file.name']}") String name) {
return new FlatFileItemReaderBuilder<Foo>()
.name("flatFileItemReader")
.resource(new FileSystemResource(name))
}

如果不使用@bean，我可以直接传输parameter，而不需要将数据放入JobParameter中，如下所示

public FlatFileItemReader flatFileItemReader(String name) {
return new FlatFileItemReaderBuilder<Foo>()
.name("flatFileItemReader")
.resource(new FileSystemResource(name))
}

如果不是强制的，当我新建一个像reader这样的对象时，我需要手动调用afterPropertiesSet（）吗？

谢了！

Answer 1

1.是否强制在作业/步骤/读取器/写入器中使用@bean？

不，将批量人工制品声明为bean并不是强制性的。但是您至少需要将作业声明为bean，以便从Spring的依赖项注入中受益（比如将作业存储库引用注入到作业中，等等），并且能够执行以下操作：

ApplicationContext context = new AnnotationConfigApplicationContext(MyJobConfig.class);
Job job = context.getBean(Job.class);
JobLauncher jobLauncher = context.getBean(JobLauncher.class);
jobLauncher.run(job, new JobParameters());

如果不是强制的，当我新建一个像reader这样的对象时，我需要手动调用afterPropertiesSet（）吗？

import org.springframework.beans.factory.InitializingBean;
import org.springframework.context.ApplicationContext;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class TestAfterPropertiesSet {

    @Bean
    public MyBean myBean() {
        return new MyBean();
    }

    public static void main(String[] args) throws Exception {
        ApplicationContext context = new AnnotationConfigApplicationContext(TestAfterPropertiesSet.class);
        MyBean myBean = context.getBean(MyBean.class);
        myBean.sayHello();
    }

    static class MyBean implements InitializingBean {
        @Override
        public void afterPropertiesSet() throws Exception {
            System.out.println("MyBean.afterPropertiesSet");
        }

        public void sayHello() {
            System.out.println("Hello");
        }
    }

}

MyBean.afterPropertiesSet
Hello