配置 JobLauncher

Javaspring-doc.cn
XMLspring-doc.cn

当您使用时，将为您提供 a。本节介绍如何配置您自己的@EnableBatchProcessingJobRegistryspring-doc.cn

该接口最基本的实现是 . 它唯一需要的依赖项是 a （需要获取执行）。JobLauncherTaskExecutorJobLauncherJobRepositoryspring-doc.cn

Javaspring-doc.cn
XMLspring-doc.cn

以下示例显示了 Java 中的一个：TaskExecutorJobLauncherspring-doc.cn

Java 配置

...
@Bean
public JobLauncher jobLauncher() throws Exception {
	TaskExecutorJobLauncher jobLauncher = new TaskExecutorJobLauncher();
	jobLauncher.setJobRepository(jobRepository);
	jobLauncher.afterPropertiesSet();
	return jobLauncher;
}
...

以下示例显示了 XML 格式：TaskExecutorJobLauncherspring-doc.cn

XML 配置

<bean id="jobLauncher"
      class="org.springframework.batch.core.launch.support.TaskExecutorJobLauncher">
    <property name="jobRepository" ref="jobRepository" />
</bean>

获取 JobExecution 后，它会传递给 execute 方法，最终将返回给调用者，作为下图显示了：JobJobExecutionspring-doc.cn

图 1.Job Launcher 序列

该序列简单明了，从计划程序启动时效果很好。然而尝试从 HTTP 请求启动时出现问题。在这种情况下，启动需要异步完成，以便立即返回到其访客。这是因为让 HTTP 请求保持打开状态并不是一个好的做法长时间运行的进程（如批处理作业）所需的时间。下图显示了示例序列：TaskExecutorJobLauncherspring-doc.cn

图 2.异步 Job Launcher 序列

您可以通过配置来配置以允许此方案。TaskExecutorJobLauncherTaskExecutorspring-doc.cn

Javaspring-doc.cn
XMLspring-doc.cn

下面的 Java 示例将 a 配置为立即返回：TaskExecutorJobLauncherspring-doc.cn

Java 配置

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

下面的 XML 示例将 a 配置为立即返回：TaskExecutorJobLauncherspring-doc.cn

XML 配置

<bean id="jobLauncher"
      class="org.springframework.batch.core.launch.support.TaskExecutorJobLauncher">
    <property name="jobRepository" ref="jobRepository" />
    <property name="taskExecutor">
        <bean class="org.springframework.core.task.SimpleAsyncTaskExecutor" />
    </property>
</bean>

你可以使用 spring 接口的任何实现来控制 Job 的异步方式执行。TaskExecutorspring-doc.cn