工作流之三：依赖mq设计工作流引擎

Dear 丶 2022-10-07 11:48 179阅读 0赞

**目录**

workflow-engine

需求：

设计：

workflow-starter-sdk：

用途：

工作原理：

功能点：

--------------------

>   对我来说，你只是一个普通的小男孩，和其他千千万万个小男孩没有区别；对你来说，我只是一只普通的狐狸，和其他千千万万只狐狸没有区别。但是如果你驯服了我，我们就会需要彼此。对我而言，你就是这个世上的唯一，对你而言，我也是这个世上的唯一。

--------------------

**背景：**入职后第一要搞工具是工作流，所以呢也借此机会系统学习下相关的工作流引擎，便于以后。。。；由于现工作流工作方式是基于表定义和表状态翻转，没有用市场工作流引擎

--------------------

Flowable6.3中文教程：https://tkjohn.github.io/flowable-userguide/\#\_introduction

1：首先经过两天的琢磨，自己画了工作流引擎的设计（消息可靠性还需再综合设计补偿机制，太依赖mq了）

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMyNDQ3MzIx_size_16_color_FFFFFF_t_70][]

## workflow-engine ##

###         需求： ###

>                 在固定的节点前提下，受理任务根据业务条件（是否产品类型，涉费逻辑，任务类型）选择在节点间流转

###          设计： ###

仔细分析后会发现：主要技术点其实就是在“**业务条件**”与选择**下一个节点**的层面，所以，把业务条件设置为**可配置逻辑表达式 **是利用java scriptEngine进行动态eval； “条件” 就根据业务实体规则进行获取，最后得出nextNode进行派发

## workflow-starter-sdk： ##

###         用途： ###

>                 接收workflow-engine消息解析并分发出去

###         工作原理：  ###

> **                封装start，对外以jar形式开放，业务系统引入依赖后，自定义handler实现类 implement handle内置接口，必须用@workflow（“handlerName”）进行注册，start随系统启动扫描包路径下的此注解，进行newInstance，创建实例后进行Map缓存注册进行handler的消息dispath**

###         功能点： ###

功能1：各节点继承基础handler接口，各自进行业务实现，服务启动注册handler-impl类，以tag为key缓存到本地Map<Tag,List<handlerService>；用于dispatch分发消息到具体handlerService进行业务条件处理，采用spi机制进行本地服务注册调用起实例；

> TODO：可扩展 根据个handerService处理结果进行发消息进行流程回转，或异常消息补偿，枚举多个处理状态（end,pausding,sendmq,couitue）

功能2：server启动就sub订阅来自工作流的流转消息，解析tag并从Map中获取List<handlerService>调用起实例handlerservice

--------------------

0825补充：

技术范围：mq, scrpit engine,spi，starter-sdk, 自定义注解，反射 newInstance, 后面写一篇spi与spring applicationContext.getBeanNamesForType区别；

此处考虑因为是sdk，所以进行基于jdk开发而不强依赖任何第三方框架内容，所以不适用getBeanNamesForType

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMyNDQ3MzIx_size_16_color_FFFFFF_t_70]: /images/20221005/0cbced8864234ae6b1c5d26ab3bac295.png