批处理应用程序
当人们在 Spring Boot 应用程序中使用 Spring Batch 时,经常会遇到一些问题。 本节将解决这些问题。
指定批处理数据源
默认情况下,批处理应用程序需要一个 DataSource
来存储作业详情。
Spring Batch 默认期望使用单个 DataSource
。
要让它使用应用程序主 DataSource
以外的 DataSource
,请声明一个 DataSource
bean,并用 @BatchDataSource
注解其 @Bean
方法。
如果您这样做并想要两个数据源(例如通过保留主自动配置的 DataSource
),请将 @Bean
注解的 defaultCandidate
属性设置为 false
。
要获得更多控制,请在您的 @Configuration
类之一中添加 @EnableBatchProcessing
或扩展 DefaultBatchConfiguration
。
有关更多详细信息,请参阅 @EnableBatchProcessing
和 DefaultBatchConfiguration
的 API 文档。
有关 Spring Batch 的更多信息,请参阅 Spring Batch 项目页面。
指定批处理事务管理器
类似于 指定批处理数据源,您可以通过用 @BatchTransactionManager
注解其 @Bean
方法来定义用于批处理的 PlatformTransactionManager
。
如果您这样做并想要两个事务管理器(例如通过保留自动配置的 PlatformTransactionManager
),请将 @Bean
注解的 defaultCandidate
属性设置为 false
。
指定批处理任务执行器
类似于 指定批处理数据源,您可以通过用 @BatchTaskExecutor
注解其 @Bean
方法来定义用于批处理的 TaskExecutor
。
如果您这样做并想要两个任务执行器(例如通过保留自动配置的 TaskExecutor
),请将 @Bean
注解的 defaultCandidate
属性设置为 false
。
在启动时运行 Spring Batch 作业
通过将 spring-boot-starter-batch
添加到应用程序的类路径中,Spring Batch 自动配置就会被启用。
如果在应用程序上下文中找到单个 Job
bean,它将在启动时执行(有关详细信息,请参阅 JobLauncherApplicationRunner
)。
如果找到多个 Job
bean,必须使用 spring.batch.job.name
指定要执行的作业。
要禁用运行在应用程序上下文中找到的 Job
,请将 spring.batch.job.enabled
设置为 false
。
有关更多详细信息,请参阅 BatchAutoConfiguration
。
从命令行运行
Spring Boot 将任何以 --
开头的命令行参数转换为要添加到 Environment
的属性,请参阅 访问命令行属性。
这不应该用于向批处理作业传递参数。
要在命令行上指定批处理参数,请使用常规格式(即不带 --
),如下例所示:
$ java -jar myapp.jar someParameter=someValue anotherParameter=anotherValue
如果您在命令行上指定了 Environment
的属性,作业将忽略它。
考虑以下命令:
$ java -jar myapp.jar --server.port=7070 someParameter=someValue
这只向批处理作业提供了一个参数:someParameter=someValue
。
重启已停止或失败的作业
要重启失败的 Job
,必须在命令行上重新指定所有参数(标识性和非标识性)。
非标识性参数*不会*从先前的执行中复制。
这允许修改或删除它们。
注意:当您使用自定义 JobParametersIncrementer
时,您必须收集增量器管理的所有参数才能重启失败的执行。