什么是流程编排?
使用各种“能力”进行编排来完成某一业务,各个“能力”被有序的编织起来,聚合成一条特定的执行链。
为什么要流程编排?
为了解决各个BU对流程差异化的诉求,我们需要提供一种工具,可以根据能力自由组合,快速解决新的业务场景诉求,甚至可以让业务自己创建流程。
比如电商场景里的交易流程:
1、因为交易多种多样,比如买彩票,跟普通商品的交易流程不大一样,买彩票不需要物流。(虚拟商品交易)
2、比如预付款交易,下单后先支付预付款,后续再支付尾款。
3、组合商品交易跟普通单个商品交易的差别
4、...
目标
- 流程定义可配置
- 阶段支持并行或者串行
- 流程定义加载支持可扩展(支持从xml、注解、数据库等等地方加载流程定义)
概要模型
- Pipeline:一个流程(Pipeline)包含多个阶段(Phase),一个阶段可以拥有多个步骤(Step)
- Phase:Phase支持并行(parallel)或者串行(serial)执行,如果Phase是串行的,那么Step根据order顺序执行
- Step:可执行的最小逻辑单元,最细粒度。eg:电商下单里,业务的参数校验、交易中心的创建订单、商品中心的创建商品、库存中心的减库存等等
执行流程模型
整个执行链是个Pipeline
电商下单流程示例:
解决方案模型
整体模型
定义加载模型
执行域-定义创建工厂
组件介绍
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。