如何在Web容器中使用Spring批处理获取@Postconstruct？

Question

目前，我正在尝试使用文档中的 spring-batch-boot 基本 Web 容器指南，让我的脚本在 tomcat 服务器上运行 https://docs.spring.io/spring-batch/reference/html/配置作业.html 在修改主类之前，该脚本作为 jar 文件可以正常工作，但是当我尝试将其转换为 servlet 时，我的

@PostConstruct

仅在服务器启动时出现问题。此代码将 application.properties 设置为

spring.batch.job.enabled=false

并拥有一个控制器

@Controller
public class JobLauncherController {
   @Autowired
   JobLauncher jobLauncher;

   @Autowired
   Job job;

   @RequestMapping("/jobLauncher.html")
   public void handle() throws Exception{
      jobLauncher.run(job, new JobParameters());
}

使用主应用程序启动 tomcat 的 servlet

@SpringBootApplication
@EnableBatchProcessing
public class BatchApplication extends SpringBootServletInitializer{

@Override
protected SpringApplicationBuilder configure(SpringApplicationBuilder application) {
    return application.sources(BatchApplication.class);
}

public static void main(String[] args) {

    SpringApplication.run(BatchApplication.class, args);

}

问题是我的工作使用自定义项目读取器和写入器，在使用

@PostConstruct

运行之前对其进行初始化。它在服务器启动时运行@PostConstruct，这有助于初始化用于写入的bean。 我的项目读者/作者看起来像这样

public class CustomReader extends ItemStreamSupport implements ItemReader<Acct>, ResourceAwareItemReaderItemStream<Acct> {
    //basic autowiring
    private int nextAcctIndex;
    private List<Acct> acctsList = new ArrayList();

    @PostConstruct
    private void initialize() throws IOException {
        //logic to parse files
        acctsList = Collections.unmodifiableList(acctsList);
        nextAcctIndex = 0;
    }

    @Override
    public Acct read() throws Exception, UnexpectedInputException, ParseException, NonTransientResourceException {
        // System.out.println("Start Read");

        Acct nextAcct = null;
        if (nextAcctIndex < acctsList.size()) {
            nextAcct = acctsList.get(nextAcctIndex);
            nextAcctIndex++;
            //System.out.println(nextAcct);
        }

BatchConfiguration 像大多数示例一样调用所有内容

@Bean public
 IteamReader<Acct> CustomReader(){ return new CustomReader();}

我的问题是我是否以错误的方式处理这个问题，或者是否有办法做到这一点，以便仅当控制器请求时才能调用

@PostConstruct

？

Answer 1

你需要使用

@BeforeStep
public void beforeStep(StepExecution stepExecution) {
    init();
}

@PostConstruct

用于在

applicationContext

加载后初始化一次。 在您的情况下，您希望每次作业运行时都运行此初始化（您不希望数据在不同作业之间泄漏，对吧？）