工作流 jbpm _Oozie基本原理
创始人
2024-12-09 16:03:29
0
工作流引擎JBPM和Oozie是用于管理和自动化工作流程的工具。JBPM侧重于业务流程管理,支持复杂的流程定义和执行。Oozie则专注于Hadoop生态系统内的工作流调度,协调多个数据处理任务。两者均通过定义、监控和优化工作流程来提高效率和可靠性。

jBPM 和 Oozie 工作流引擎的基本原理

工作流 jbpm _Oozie基本原理(图片来源网络,侵删)

jBPM 的基本概念与API设计

jBPM,全称是Java Business Process Management(业务流程管理),是一种开源的、灵活的、易扩展的可执行流程语言框架,它覆盖了业务流程管理、工作流管理、服务协作等领域,jBPM利用JPDL流程定义语言将现实生活中处理事务的业务流程进行抽象,形成一套业务流程规则。

jBPM4工作流引擎的核心是PVM(Process Virtual Machine),它主要依靠四组服务API来提供服务:

1、流程定义服务(Process Service)

2、流程执行服务(Execution Service)

3、流程管理服务(Management Service)

4、指令服务(Command Service)

工作流 jbpm _Oozie基本原理(图片来源网络,侵删)

这些服务使应用能够与PVM进行数据交互,并在支持事务的持久化模式下运行。

还有客户端API,它是核心工作流模型对象对外暴露的公共方法,可以直接用来执行一些流程操作,但不会进行任何持久化操作,只有通过调用相应服务的API后,操作的结果才会被持久化。

活动API用于实现流程活动在运行时的行为,所有的活动类型都要实现ActivityBehaviour接口,该接口提供了控制流程执行的方法,事件监听API用于自定义事件监听器,用来处理被监听到的流程事件,与活动API不同,事件监听器无法控制流程的执行。

jBPM 的运行环境设计

为了让流程可以在不同的事务环境中运行,例如在Java EE或Spring中,PVM定义了运行环境对象,它会根据配置的环境执行服务延迟加载与获取事务管理等操作,运行环境是EnvironmentFactory对象,它有两个实现:ProcessEngineImpl(默认的Java EE环境)和SpringProcessEngine(基于Spring框架的环境)。

Oozie 的基本概念与API设计

Oozie是一个用于 Hadoop 的任务调度和协调系统,它可以以任意顺序执行多个Hadoop作业,Oozie的主要组件包括:

工作流 jbpm _Oozie基本原理(图片来源网络,侵删)

1、工作流引擎

2、协调器

3、Bundler

Oozie的工作流定义了一种有向无环图(DAG),其中每个节点都是一个动作节点,代表一个Hadoop作业或其他类型的任务。

Oozie 的运行环境设计

Oozie的运行环境是基于Hadoop平台的,它通过Hadoop的API与HDFS、MapReduce等组件交互,Oozie使用自己的数据库来存储元数据和状态信息,常用的数据库包括Derby、MySQL和PostgreSQL。

相关问答FAQs

1. jBPM如何支持事务?

jBPM的服务API设计支持事务,所有的服务操作都在支持事务的持久化模式下运行,这意味着在进行流程操作时,可以通过服务的API来确保数据的一致性和完整性。ExecutionService.startProcessInstanceByKey发起流程实例就是一个事务性操作。

2. Oozie如何保证任务按顺序执行?

Oozie的工作流定义了一种有向无环图(DAG),通过控制动作节点的依赖关系来保证任务按照预定的顺序执行,每个动作节点都代表一个Hadoop作业或其他类型的任务,只有当前置任务完成后,后续任务才会被触发。


下面是一个简单的介绍,对比了JBPM和Oozie这两个工作流引擎的基本原理:

特性/组件 JBPM Oozie
定义 JBPM是Java Business Process Management的缩写,一个开源的业务流程管理框架。 Oozie是一个由Cloudera贡献给Apache的,基于Hadoop平台的工作流调度框架。
用途 用于定义、执行和管理业务流程。 用于调度和管理在Hadoop平台上的多个MapReduce作业和动作。
语言 使用JPDL(jBPM Process Definition Language)流程定义语言。 使用XML配置文件(如workflow.xml)来定义工作流。
架构 1. 嵌入式的工作流引擎
2. 可插拔的体系架构
3. 与Drools、Hibernate等集成
1. 由Oozie Client和Oozie Server组成
2. 运行在Java Servlet容器中
核心组件 流程定义
流程实例
任务
事件监听器
Workflow
Coordinator
Bundle Job
控制流节点与动作节点
工作流结构 支持定义顺序、分支、并行等流程结构。 以DAG(有向无环图)的形式表示工作流。
任务调度 提供任务分配和执行机制。 支持基于时间和数据触发的任务调度。
执行环境 可以独立运行,也可以集成在Java应用中。 主要针对Hadoop生态系统,如MapReduce、Hive、Pig等。
社区和支持 拥有活跃的社区和商业支持。 由Apache软件基金会支持,服务于Hadoop生态系统。

这个介绍展示了两个工作流引擎在基本原理上的共通点和差异,虽然它们都是用来管理和调度工作流的,但它们设计的初衷、使用的场景和提供的功能有所不同。

相关内容

热门资讯

大数据如何推动工业数字化发展 在全球工业4.0浪潮中,大数据技术作为核心驱动力,正深刻改变着传统工业的...
MocoInverse接口使用... MocoInverse通过Direct Collocation方式的轨迹优化解决了冗余执行器问题&#...
使用adb连接安卓手机 这里写自定义目录标题手机和电脑需连接在同一 WiFi 下; 保证 SDK 为最新版本&...
leetcode145. 二叉... leetcode145. 二叉树的后序遍历,递归法+迭代法给你一棵二叉树的根节...
查到实测辅助!wpk德州ai透... 自定义新版wpk德州系统规律,只需要输入自己想要的开挂功能,一键便可以生成出wpk德州专用辅助器,不...
Leetcode(经典题)da... 删除有序数组中的重复项|| 80. 删除有序数组中的重复项 II - 力扣(LeetC...
力扣Hot100-148排序链... 给你链表的头结点head,请将其按升序排列并返回排序后的链表。示例 1: 输入:head = [4,...
2024新版教程!wepoke... 2024新版教程!wepoke脚本透明挂必备!wepoke脚本辅助挂(2021已更新)(哔哩哔哩)是...
终于清楚!wpk ai透明挂测... 自定义新版wpk系统规律,只需要输入自己想要的开挂功能,一键便可以生成出wpk专用辅助器,不管你是想...
四分钟了解!微扑克网页版透明挂... 四分钟了解!微扑克网页版透明挂软件!微扑克网页版辅助插件(2023已更新)(哔哩哔哩)是一款可以让一...