轻量级流程编排引擎-模型&设计

什么是流程编排? 使用各种“能力”进行编排来完成某一业务,各个“能力”被有序的编织起来,聚合成一条特定的执行链…

什么是流程编排?

使用各种“能力”进行编排来完成某一业务,各个“能力”被有序的编织起来,聚合成一条特定的执行链。

为什么要流程编排?

为了解决各个BU对流程差异化的诉求,我们需要提供一种工具,可以根据能力自由组合,快速解决新的业务场景诉求,甚至可以让业务自己创建流程。

比如电商场景里的交易流程:

1、因为交易多种多样,比如买彩票,跟普通商品的交易流程不大一样,买彩票不需要物流。(虚拟商品交易)

2、比如预付款交易,下单后先支付预付款,后续再支付尾款。

3、组合商品交易跟普通单个商品交易的差别

4、…

目标

  • 流程定义可配置
  • 阶段支持并行或者串行
  • 流程定义加载支持可扩展(支持从xml、注解、数据库等等地方加载流程定义)

概要模型

  • Pipeline:一个流程(Pipeline)包含多个阶段(Phase),一个阶段可以拥有多个步骤(Step)
  • Phase:Phase支持并行(parallel)或者串行(serial)执行,如果Phase是串行的,那么Step根据order顺序执行
  • Step:可执行的最小逻辑单元,最细粒度。eg:电商下单里,业务的参数校验、交易中心的创建订单、商品中心的创建商品、库存中心的减库存等等

执行流程模型

整个执行链是个Pipeline

决策流程示意图.png

电商下单流程示例:

解决方案模型

整体模型

定义加载模型

执行域-定义创建工厂

组件介绍

PipelineResolver:根据业务请求,决定一个Pipeline

DefinitionLoader:定义加载器,用来加载Pipeline流程定义、Phase阶段定义、Step步骤定义,可以自己实现流程定义的加载,可扩展

Pipeline:执行域“流程定义”

Phase:执行域“阶段定义”

Step:执行域“步骤定义”(能力)

PipelineDefinition:表示一个流程定义,初始化时会转成Pipeline

PhaseDefinition:表示一个阶段定义,初始化时会转成Phase

StepDefinition:表示一个步骤定义,初始化时会转成Step

PipelineManager:流程定义执行对象缓存管理器

PhaseManager:阶段执行对象缓存管理器

StepManager:步骤执行对象缓存管理器

我们注意到没有,BasePipeline对象并没有直接关联Phase对象,BasePhase对象也没有直接关联Step对象,都只保存了各自的name,而将实际的对象都放到了PhaseManager和StepManager里,为什么这么处理呢?这里卖个关子!~留给有兴趣的同学思考下吧!

Pipeline执行时序图

总结

虽然是轻量级的,但落地还是有点复杂,大部分场景还是不大会用的上,目前我所在的团队属于电商开放平台,有使用场景,所以才需要。其他业务视情况而定,在实际需要的时候,再考虑使用这种灵活的流程编排模型,简单的可以考虑直接在代码里写死Pipeline、Phase以及Step。

参考

https://segmentfault.com/a/1190000019977997

文章来源:https://www.jianshu.com/p/25131a9e7d0f

本文来自网络,不代表软粉网立场,转载请注明出处:https://www.rfff.net/p/8304.html

作者: HUI

发表评论

您的电子邮箱地址不会被公开。

返回顶部