百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 技术流 > 正文

SpringBatch-基础开发之作业流Flow

citgpt 2024-06-27 19:59 15 浏览 0 评论

在开始作业流开发之前需要先了解SpringBatch中的BatchStatus和ExitStatus这两个状态的含义。

BatchStatus和ExitStatus含义

1.BatchStatus:批处理状态

SpringBatch-基础开发之作业流Flow

批处理状态是由批处理框架使用,用来记录Job、Step的执行情况。SpringBatch的重启即是利用了BatchStauts来实现。对应BATCH_JOB_INSTANCE和BATCH_STEP_EXECUTION表中的STATUS字段值。

  • JobExecution.getStatus()获取作业Job批处理状态;

  • StepExecution.getStatus()获取作业Step的批处理状态;

批处理状态属性:

状态说明
COMPLETED完成,所有Step都处理该状态,则JOB会处理该状态
STARTING表示作业正在启动,还没有启动完毕
STARTED表示作业启动完成
STOPING表示作业正在停止中
STOPED表示作业停止完成
FAILED表示作业执行失败
ABANDONED表示当前下次重启JOB时需要废弃的Step,即不会被再次执行
UNKOWN表示未知错误,该状态下重启Job会抛错

2.ExitStatus:退出状态

退出状态表示Step执行后或者Job执行后的状态,该值要以被修改,通常用于条件Flow中

  • 可以通过拦截器StepExecutionListener的afterStep方法来修改退出状态;

  • 对应BATCH_JOB_INSTANCE和BATCH_STEP_EXECUTION表中的EXIT_CODE字段值;

顺序Flow

顺序Flow的配置非常简单,通过next指向下一个步骤

示例:三个步骤,执行顺序:step1.hello->step2.clean->step3.copyData

顺序Flow

条件Flow

顾名思义,根据条件判断来决定流程走向。通过listener的afterStep方法来设置ExitStatus状态,XML中根据ExitStatus的值来决定流程走向。

示例:step1.hello运行结束后:

  • 当ExistCode=T_FAILD,则执行step2.clean步骤;

  • 当ExistCode为其它值时,则执行other步骤;

XML配置:

条件Flow

监听开发

监听非常重要,根据Step运行的结果来设置ExitStatus,next即是根据ExitStatus来判断流程走向

监听类

注:通过stepExecution可以获取Job的运行参数和Step的运行参数。

Launch启动器

启动器

运行结果

当flowDeciderType参数值=true时

运行结果

当flowDeciderType参数值=false时

运行结果

更多SpringBatch开发文档,移步到我的头条号。

如果本文对您有用,请顺手给个赞!

相关推荐

js中arguments详解

一、简介了解arguments这个对象之前先来认识一下javascript的一些功能:其实Javascript并没有重载函数的功能,但是Arguments对象能够模拟重载。Javascrip中每个函数...

firewall-cmd 常用命令

目录firewalldzone说明firewallzone内容说明firewall-cmd常用参数firewall-cmd常用命令常用命令 回到顶部firewalldzone...

epel-release 是什么

EPEL-release(ExtraPackagesforEnterpriseLinux)是一个软件仓库,它为企业级Linux发行版(如CentOS、RHEL等)提供额外的软件包。以下是关于E...

FullGC详解  什么是 JVM 的 GC
FullGC详解 什么是 JVM 的 GC

前言:背景:一、什么是JVM的GC?JVM(JavaVirtualMachine)。JVM是Java程序的虚拟机,是一种实现Java语言的解...

2024-10-26 08:50 citgpt

使用Spire.Doc组件利用模板导出Word文档
  • 使用Spire.Doc组件利用模板导出Word文档
  • 使用Spire.Doc组件利用模板导出Word文档
  • 使用Spire.Doc组件利用模板导出Word文档
  • 使用Spire.Doc组件利用模板导出Word文档
跨域(CrossOrigin)

1.介绍  1)跨域问题:跨域问题是在网络中,当一个网络的运行脚本(通常时JavaScript)试图访问另一个网络的资源时,如果这两个网络的端口、协议和域名不一致时就会出现跨域问题。    通俗讲...

微服务架构和分布式架构的区别

1、含义不同微服务架构:微服务架构风格是一种将一个单一应用程序开发为一组小型服务的方法,每个服务运行在自己的进程中,服务间通信采用轻量级通信机制(通常用HTTP资源API)。这些服务围绕业务能力构建并...

深入理解与应用CSS clip-path 属性
深入理解与应用CSS clip-path 属性

clip-pathclip-path是什么clip-path 是一个CSS属性,允许开发者创建一个剪切区域,从而决定元素的哪些部分可见,哪些部分会被隐...

2024-10-25 11:51 citgpt

HCNP Routing&Switching之OSPF LSA类型(二)
  • HCNP Routing&Switching之OSPF LSA类型(二)
  • HCNP Routing&Switching之OSPF LSA类型(二)
  • HCNP Routing&Switching之OSPF LSA类型(二)
  • HCNP Routing&Switching之OSPF LSA类型(二)
Redis和Memcached的区别详解
  • Redis和Memcached的区别详解
  • Redis和Memcached的区别详解
  • Redis和Memcached的区别详解
  • Redis和Memcached的区别详解
Request.ServerVariables 大全

Request.ServerVariables("Url")返回服务器地址Request.ServerVariables("Path_Info")客户端提供的路...

python操作Kafka

目录一、python操作kafka1.python使用kafka生产者2.python使用kafka消费者3.使用docker中的kafka二、python操作kafka细...

Runtime.getRuntime().exec详解

Runtime.getRuntime().exec详解概述Runtime.getRuntime().exec用于调用外部可执行程序或系统命令,并重定向外部程序的标准输入、标准输出和标准错误到缓冲池。...

promise.all详解 promise.all是干什么的
promise.all详解 promise.all是干什么的

promise.all详解promise.all中所有的请求成功了,走.then(),在.then()中能得到一个数组,数组中是每个请求resolve抛出的结果...

2024-10-24 16:21 citgpt

Content-Length和Transfer-Encoding详解
  • Content-Length和Transfer-Encoding详解
  • Content-Length和Transfer-Encoding详解
  • Content-Length和Transfer-Encoding详解
  • Content-Length和Transfer-Encoding详解

取消回复欢迎 发表评论: