Spring批处理：如何启动作业但不执行，而是在其他java实例中执行

Question

我计划使用Spring Batch。我们喜欢在响应前端请求的POD中启动新作业执行。

伪代码:

@PostMapping(path = "/request-report/{id}")
public void requestReport(String id){
  this.jobOperator.start("reportJob", new Properties("1"));
}

但我们不希望作业在前端pod中执行。为此，我们希望构建一个单独的微服务吊舱。

我看到了以下解决方案:

>

从前端pod到sping-batpod执行一个rest调用并在那里开始工作。我可以这样做，但如果可能的话，我想跳过该步骤并将其集成到sping-batdb上。

在前端pod中，我创建了具有大小为零的SimpleAsyncTaskExecutor的JobLauncher。所以它永远不会执行作业。

https://docs.spring.io/spring-batch/docs/current/reference/html/job.html#configuringJobLauncher

@Bean
public JobLauncher jobLauncher() {
    SimpleJobLauncher jobLauncher = new SimpleJobLauncher();
    jobLauncher.setJobRepository(jobRepository());
    jobLauncher.setTaskExecutor(new SimpleAsyncTaskExecutor());
    jobLauncher.afterPropertiesSet();
    return jobLauncher;
}

我想我还必须编写一些软件来扫描作业表并检查是否存在未启动的作业，并且start再次出现在sping-batch-pod中。

谢谢你的帮助！

Answer 1

如果您使用SimpleAsyncTaskExector配置作业启动器，它将在同一JVM中的不同线程中启动作业（因此在同一容器和pod中）。

因此，除非您提供一个自定义的TaskExecutor来在单独的JVM/container/pod中启动作业，否则您需要更改您的体系结构以使用作业队列。通过参考文档中的消息启动批处理作业一节显示了如何设置这种模式。