0

0

java怎么实现一个流程编排框架

王林

王林

发布时间:2023-05-01 21:49:05

|

3598人浏览过

|

来源于亿速云

转载

流程注册

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

java怎么实现一个流程编排框架

流程加载

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

java怎么实现一个流程编排框架

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

立即学习Java免费学习笔记(深入)”;

sematic
sematic

一个开源的机器学习平台

下载

代码如下:

public class NodeComponentFactory {

private final static Map 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 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 nodeMap) {
this.nodeMap = nodeMap;
}

@Override
public abstract BaseOutput parser(Node node, BaseInput baseInput, BaseTemp baseTemp);

}

流程加载顺序

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

java怎么实现一个流程编排框架

相关文章

java速学教程(入门到精通)
java速学教程(入门到精通)

java怎么学习?java怎么入门?java在哪学?java怎么学才快?不用担心,这里为大家提供了java速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!

下载

相关标签:

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

相关专题

更多
vlookup函数使用大全
vlookup函数使用大全

本专题整合了vlookup函数相关 教程,阅读专题下面的文章了解更多详细内容。

26

2025.12.30

金山文档相关教程
金山文档相关教程

本专题整合了金山文档相关教程,阅读专题下面的文章了解更多详细操作。

28

2025.12.30

PS反选快捷键
PS反选快捷键

本专题整合了ps反选快捷键介绍,阅读下面的文章找到答案。

25

2025.12.30

表格中一行两行的方法
表格中一行两行的方法

本专题整合了表格中一行两行的相关教程,阅读专题下面的文章了解更多详细内容。

3

2025.12.30

cpu温度过高解决方法大全
cpu温度过高解决方法大全

本专题整合了cpu温度过高相关教程,阅读专题下面的文章了解更多详细内容。

5

2025.12.30

ASCII码介绍
ASCII码介绍

本专题整合了ASCII码相关内容,阅读专题下面的文章了解更多详细内容。

31

2025.12.30

GPS是什么
GPS是什么

本专题整合了GPS相关内容,阅读专题下面的文章了解更多详细内容。

3

2025.12.30

wifi拒绝接入
wifi拒绝接入

本专题整合了wifi拒绝接入相关教程,阅读下面的文章了解更多详细方法。

9

2025.12.30

丰网速运介绍
丰网速运介绍

本专题整合了丰网速运查询入口以及相关内容,阅读专题下面的文章了解更多内容。

3

2025.12.30

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Kotlin 教程
Kotlin 教程

共23课时 | 2.1万人学习

C# 教程
C# 教程

共94课时 | 5.6万人学习

Java 教程
Java 教程

共578课时 | 39.3万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号