Spring Cloud Task传递Spring Batch作业退出状态的配置咨询

我来帮你梳理下实现这个需求的关键配置和细节，都是实际项目里验证过的：

核心配置必做项 #

• 关联Batch与Task的状态和元数据：一定要开启 spring.cloud.task.batch.failOnJobFailure=true，这个配置是核心开关——它会让Spring Cloud Task感知到Spring Batch作业的执行状态，当Batch作业失败时，Task也会同步标记为失败，同时把Batch作业的元数据（比如执行时间、参数、状态）关联到Task的TASK_表记录里，实现两者元数据的打通。
• 让Task返回正确的退出状态码：Spring Cloud Data Flow是通过Task的退出码来判断执行结果的，所以得确保Task能根据Batch作业的结果返回对应码：
  • 省心版：开启failOnJobFailure后，Task会自动处理——Batch成功返回0，失败返回非0的退出码，不用额外写代码。
  • 自定义版：如果需要更灵活的状态映射（比如不同失败场景返回不同码），可以实现JobExecutionListener来手动控制退出码，示例代码如下：

    @Component
    public class CustomJobStatusListener implements JobExecutionListener {
        @Override
        public void afterJob(JobExecution jobExecution) {
            if (BatchStatus.FAILED.equals(jobExecution.getStatus())) {
                System.exit(1); // 失败返回1
            } else if (BatchStatus.COMPLETED.equals(jobExecution.getStatus())) {
                System.exit(0); // 成功返回0
            }
            // 还可以处理其他状态比如STOPPED等
        }
    }
    

• 统一数据源配置：Batch的BATCH_表和Task的TASK_表必须用同一个数据源，否则元数据无法关联。这里给你个application.yml的配置示例：

  spring:
    datasource:
      url: jdbc:mysql://localhost:3306/batch_task_center
      username: your_db_user
      password: your_db_pwd
      driver-class-name: com.mysql.cj.jdbc.Driver
    batch:
      jdbc:
        initialize-schema: always # 首次启动初始化Batch表结构
    cloud:
      task:
        batch:
          failOnJobFailure: true
  

部署到Spring Cloud Data Flow的小提示 #

• 先把你的Spring Batch+Task应用打包成可执行jar，然后注册到Data Flow服务器，注册时要指定应用类型为task。
• 在Data Flow中创建Task定义时，可以直接把Batch作业需要的参数传递进去，Task执行时会把这些参数带到Batch作业里，同时所有元数据都会自动记录到对应的数据库表中。

内容的提问来源于stack exchange，提问作者anat0lius