当从机完成时，如何在Spring Batch远程组块中停止作业？

Question

我使用这个示例作为spring batch应用程序的起点，使用远程分块：https://github.com/benas/spring-batch-remote-chunking-sample/blob/master/src/main/java/io/github/benas/masterconfiguration.java在这个示例中，我添加了自定义的读取器/写入器，但没有更改任何配置。这个例子工作很好，除了我不能停止工作后，所有的奴隶完成。

我尝试使用JobListner，在“after job”方法中停止作业，但没有结果。

public class MyJobExecutionListener implements JobExecutionListener {

@Override
public void beforeJob(JobExecution jobExecution) {
    // TODO Auto-generated method stub

}

@Override
public void afterJob(JobExecution jobExecution) {

    System.out.println("afterJob start~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~");
    System.out.println(jobExecution.getExitStatus().getExitCode());
    System.out.println(jobExecution.getExitStatus().getExitDescription());
    System.out.println(jobExecution.getStartTime());
    System.out.println(jobExecution.getEndTime());
    System.out.println(jobExecution.isRunning());
    System.out.println(jobExecution.isStopping());

    jobExecution.stop();

    System.out.println("!!!!!!!!!");
    System.out.println(jobExecution.isRunning());
    System.out.println(jobExecution.isStopping());
    System.out.println(jobExecution.getEndTime());


    System.out.println("afterJob end~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~");
}

}

@SpringBootApplication
@EnableAutoConfiguration(exclude={DataSourceAutoConfiguration.class})
public class AppStarter {

   public static void main(String[] args) {

      System.out.println("!!!!!!!!!!!!!!!!!!!!!!!!!!! start");
      SpringApplication.run(AppStarter.class, args);

   }
}

有没有办法在应用程序完成后停止？

Answer 1

您可以使用如下内容显式地停止主程序的应用程序上下文：

ConfigurableApplicationContext context = SpringApplication.run(YourMasterApp.class, args);
context.close();

这将确保主端已经完成作业的运行，然后关闭应用程序上下文。

不过有几个注意事项：

• 您可以在官方示例repo中找到相同的示例:https://github.com/spring-projects/spring-batch/tree/master/spring-batch-samples#remote-chunking-sample。您用作起始点的个人回购可能随时被删除
• 在监听器的afterjob方法中使用jobexecution.stop()没有意义，因为这个afterjob方法几乎是结束作业之前的最后一条语句。此外，这个jobexecution.stop()将在将来的版本中删除（请参见https://jira.spring.io/browse/batch-1987)

希望这能有所帮助。