实战项目：设计实现一个流程编排框架(实现)

喜欢ヅ旅行 2023-02-20 07:41 21阅读 0赞

上两篇文章主要讲了《\[实战项目：设计实现一个流程编排框架(分析)([https://mp.weixin.qq.com/s/veLQZJqYNKbYvuCi7Pf\_nA][https_mp.weixin.qq.com_s_veLQZJqYNKbYvuCi7Pf_nA])\]》《[实战项目：设计实现一个流程编排框架(设计][Link 1]》我们介绍了如何通过合理的分析，来实现需求的同时满足易用、易扩展、灵活、低延迟、高容错等非功能性需求。

针对编排框架的开发如何做高质量的代码实现。说的具体点就是，如何利用设计思想、原则、模式、编码规范、重构技巧等，写出易读、易扩展、易维护、灵活、简洁、可复用、易测试的代码。

# 流程注册 #

之前有讲到要支持yml、properties、xml、json、接口的形式注册流程模型，为了体现**职责单一原则**，我们需要把一种格式解析的逻辑独立处理，为了体现**对扩展开发，对修改关闭原则**，我们先定义一组接口，然后通过**工厂模**式提供对应的实现逻辑；这里工厂是使用者，通过接口调用具体的实现，实现在这里是提供者，又是一组**策略模式**。

![format_png][]

# 流程加载 #

流程加载我们需要知道其他的几个需求功能点：1、提供对外统一访问接口；2、提供执行记录和执行耗时；3、不同流程节点需要定义不同的解析器；4、通过工厂创建解析类型；5、流程节点按照顺序执行。

![format_png 1][]

通过不同的节点类型执行不同的解析方式，显而易见这里需要用**工厂模式**去做解析类创建，而且需要做到**对外扩展开发对修改关闭**，新增节点不用动其他代码逻辑，只要在工厂函数里面添加一个节点解析器；同时我们这里定义一个Map集合用于在加载工厂函数的时候就把解析对象创建，而不用每次解析的时候再去创建解析器，减少不必要的内存

代码如下：

public class NodeComponentFactory {
    
        private final static Map<String,NodeParser> cacheParser = new HashMap<>();
    
        static {
            cacheParser.put(NodeParserEnum.method.name(),new MethodNodeComponent());
            cacheParser.put(NodeParserEnum.bean.name(),new BeanNodeComponent());
            cacheParser.put(NodeParserEnum.condition.name(),new ConditionNodeComponent());
            cacheParser.put(NodeParserEnum.service.name(),new ServiceNodeComponent());
            cacheParser.put(NodeParserEnum.subflow.name(),new SubFlowNodeComponent());
        }
    
        public static NodeParser getNodeInstance(String nodeName){
            return cacheParser.get(nodeName);
        }
    }

当我们发现每一种节点解析类型都需要去实现parser接口，而且每个节点都有类似的步骤，那我们这里就要考虑用抽象工厂，也符合一个**依赖倒置**的的设计原则，上层模块通过依赖接口访问，下次模块继承抽象类，同时也用到了**策略模式**做接口调用；在实现的逻辑过程我们会发现很多步骤是重复的，比如初始化入参、执行记录，所有我们把重复的内容放到抽象类，通过**模板模式**的方式，让流程节点只关注解析层面；

public abstract class AbstractNodeComponent implements NodeParser{
    
        public Map<String, Node> nodeMap;
    
    
        /**
         * 初始化参数
         * @param inputUrl
         * @param baseInput
         * @return
         */
        public BaseInput initInput(String inputUrl, BaseInput baseInput){
            BaseInput baseInputTarget = ClassUtil.newInstance(inputUrl, BaseInput.class);
            BeanUtils.copyProperties(baseInput,baseInputTarget);
            return baseInputTarget;
        }
    
    
        /**
         * 解析节点信息
         * @param node 节点信息
         * @param baseInput 请求参数
         * @param baseTemp 临时上下文
         * @return
         */
        public BaseOutput parserNode(Node node, BaseInput baseInput, BaseTemp baseTemp){
            baseTemp.setFlowRecord(baseTemp.getFlowRecord().append(FlowConstants.NODEKEY+FlowConstants.NODE+FlowConstants.COLON+node.getId()));
            BaseOutput baseOutput = parser(node, baseInput, baseTemp);
            return baseOutput;
        };
    
        @Override
        public void setNodeMap(Map<String, Node> nodeMap) {
            this.nodeMap = nodeMap;
        }
    
        @Override
        public abstract BaseOutput parser(Node node, BaseInput baseInput, BaseTemp baseTemp);
    
    }

## 流程加载顺序 ##

流程执行我们需要把组件分的很细，最好是独立实现一个功能的类划分成一个组件，体现**职责单一原则**，也只要把执行功能划分的很细，才能在流程执行的各个流程中灵活组合；在下面流程图中可以看到几个组件，第一个是流程统一执行的入口，这里会有两个地方会用到，第一个就是给外部调用的接口，第二个是子流程执行的入口；第二个组件是节点统一加载管理组件也就是上文提到的工厂类；第三个就是每个组件自己的解析器，用于实现不同类型节点的操作；在设计的过程中一定知道 流程 、管理、节点之间的边界，减少耦合，只有这样不同的组件才能灵活组成。

![format_png 2][]

[https_mp.weixin.qq.com_s_veLQZJqYNKbYvuCi7Pf_nA]: https://mp.weixin.qq.com/s?__biz=MzI2MTQyOTgxMQ%3D%3D&idx=1&mid=2247484148&scene=21&sn=7d424d1812e66108b0ac00df266e750f#wechat_redirect
[Link 1]: https://blog.csdn.net/zhangchangbin123/article/details/106913068
[format_png]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X3BuZy9hTGxhZ2FTbjY0NXhHZUNENTNJaWFHWWpLTTA0VVJEM0ZYdkF6dk9kR2NObUFwb2pKbThxTU1UTGF0ZmdKeWpXWXZ4MWtCek1nWFRJZE5XY2NkVjR1SHcvNjQw?x-oss-process=image/format,png
[format_png 1]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X2pwZy9hTGxhZ2FTbjY0NXhHZUNENTNJaWFHWWpLTTA0VVJEM0ZzcEVDczY5WEF0V2liejZIUzYyQjNHSWI3WmpIcmlhT1JSMG80RHRJcnpRZ294b1RzeFdxSDM3US82NDA?x-oss-process=image/format,png
[format_png 2]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X3BuZy9hTGxhZ2FTbjY0NXhHZUNENTNJaWFHWWpLTTA0VVJEM0ZuOUhjMWV0RGFxZFJPWGZndE5lNmFYVWVIYnNodnJmM0g4ekJJYndpYlRXdXBycGpUTkdpY3VpYUEvNjQw?x-oss-process=image/format,png