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

男娘i 2023-01-19 09:57 90阅读 0赞

# 什么是流程编排？ #

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

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d3ZDA1MDE_size_16_color_FFFFFF_t_70][]

# 为什么要流程编排？ #

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

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

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

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

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

4、...

# 目标 #

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

# 概要模型 #

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

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d3ZDA1MDE_size_16_color_FFFFFF_t_70 1][]

# 执行流程模型 #

整个执行链是个Pipeline

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d3ZDA1MDE_size_16_color_FFFFFF_t_70 2][]

决策流程示意图.png

电商下单流程示例：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d3ZDA1MDE_size_16_color_FFFFFF_t_70 3][]

# 解决方案模型 #

## 整体模型 ##

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d3ZDA1MDE_size_16_color_FFFFFF_t_70 4][]

## 定义加载模型 ##

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d3ZDA1MDE_size_16_color_FFFFFF_t_70 5][]

## 执行域-定义创建工厂 ##

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d3ZDA1MDE_size_16_color_FFFFFF_t_70 6][]

**组件介绍**

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执行时序图 #

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d3ZDA1MDE_size_16_color_FFFFFF_t_70 7][]

# 总结 #

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

# 参考 #

[https://segmentfault.com/a/1190000019977997][https_segmentfault.com_a_1190000019977997]

文章来源：[https://www.jianshu.com/p/25131a9e7d0f][https_www.jianshu.com_p_25131a9e7d0f]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d3ZDA1MDE_size_16_color_FFFFFF_t_70]: /images/20221021/3bd271722cde49f8929e00ac493aba63.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d3ZDA1MDE_size_16_color_FFFFFF_t_70 1]: /images/20221021/4af1179abf714ab3a1f8b0915f872ccf.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d3ZDA1MDE_size_16_color_FFFFFF_t_70 2]: /images/20221021/fd388cdc7dfd4fc384842597038b88fb.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d3ZDA1MDE_size_16_color_FFFFFF_t_70 3]: /images/20221021/73ccb0a09e12466c9a0fc1482aa617d2.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d3ZDA1MDE_size_16_color_FFFFFF_t_70 4]: /images/20221021/a4b5982d79c343f8b165d71e55737d7c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d3ZDA1MDE_size_16_color_FFFFFF_t_70 5]: /images/20221021/4c1047a1df144f4fac76001dcfdc955a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d3ZDA1MDE_size_16_color_FFFFFF_t_70 6]: /images/20221021/840777b252e244adb7a4fdea4f07e6e1.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d3ZDA1MDE_size_16_color_FFFFFF_t_70 7]: /images/20221021/c6b4755f11b740b2a500600bdbe4e31f.png
[https_segmentfault.com_a_1190000019977997]: https://links.jianshu.com/go?to=https%3A%2F%2Fsegmentfault.com%2Fa%2F1190000019977997
[https_www.jianshu.com_p_25131a9e7d0f]: https://www.jianshu.com/p/25131a9e7d0f