当奴隶完成时，如何在 Spring Batch 远程分块中停止作业？

Question

我使用这个示例作为 spring 批处理应用程序的起点，使用远程分块： https://github.com/benas/spring-batch-remote-chunking-sample/blob/master/src/main/java/io/github/benas/MasterConfiguration.java 在这个例子中，我添加了我的自定义读取器/写入器，但我没有更改任何配置。该示例工作正常，除了在所有从属设备完成后我无法停止工作。

我尝试使用 JobListner 来在 'afterJob' 方法中停止作业，但没有结果。

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~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~");
}

}

jobExecution.getExitStatus().getExitCode() 已完成 jobExecution.isStopping() 为 true，但应用仍在运行。

为了运行应用程序，我使用的是 SpringBoot（而不是将其作为单元测试运行，就像在示例中一样）

@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();

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

不过有几点注意事项：

• 您可以在此处的官方示例存储库中找到相同的示例：https://github.com/spring-projects/spring-batch/tree/master/spring-batch-samples#remote-chunking-sample。您作为起点的个人回购可能随时被删除
• 在侦听器的afterJob 方法中使用jobExecution.stop() 毫无意义，因为这个afterJob 方法几乎就是在结束工作之前的last statement。此外，这个jobExecution.stop() 将在未来的版本中被删除（参见https://jira.spring.io/browse/BATCH-1987）

希望这会有所帮助。