流程注册
之前有讲到要支持yml、properties、xml、json、接口的形式注册流程模型,为了体现职责单一原则,我们需要把一种格式解析的逻辑独立处理,为了体现对扩展开发,对修改关闭原则,我们先定义一组接口,然后通过工厂模式提供对应的实现逻辑;这里工厂是使用者,通过接口调用具体的实现,实现在这里是提供者,又是一组策略模式。
流程加载
流程加载我们需要知道其他的几个需求功能点:1、提供对外统一访问接口;2、提供执行记录和执行耗时;3、不同流程节点需要定义不同的解析器;4、通过工厂创建解析类型;5、流程节点按照顺序执行。
通过不同的节点类型执行不同的解析方式,显而易见这里需要用工厂模式去做解析类创建,而且需要做到对外扩展开发对修改关闭,新增节点不用动其他代码逻辑,只要在工厂函数里面添加一个节点解析器;同时我们这里定义一个Map集合用于在加载工厂函数的时候就把解析对象创建,而不用每次解析的时候再去创建解析器,减少不必要的内存
代码如下:
<code>public class NodeComponentFactory {<br><br> private final static Map<String,NodeParser> cacheParser = new HashMap<>();<br><br> static {<br> cacheParser.put(NodeParserEnum.method.name(),new MethodNodeComponent());<br> cacheParser.put(NodeParserEnum.bean.name(),new BeanNodeComponent());<br> cacheParser.put(NodeParserEnum.condition.name(),new ConditionNodeComponent());<br> cacheParser.put(NodeParserEnum.service.name(),new ServiceNodeComponent());<br> cacheParser.put(NodeParserEnum.subflow.name(),new SubFlowNodeComponent());<br> }<br><br> public static NodeParser getNodeInstance(String nodeName){<br> return cacheParser.get(nodeName);<br> }<br>}<br></code>
当我们发现每一种节点解析类型都需要去实现parser接口,而且每个节点都有类似的步骤,那我们这里就要考虑用抽象工厂,也符合一个依赖倒置的的设计原则,上层模块通过依赖接口访问,下次模块继承抽象类,同时也用到了策略模式做接口调用;在实现的逻辑过程我们会发现很多步骤是重复的,比如初始化入参、执行记录,所有我们把重复的内容放到抽象类,通过模板模式的方式,让流程节点只关注解析层面;
<code>public abstract class AbstractNodeComponent implements NodeParser{<br><br> public Map<String, Node> nodeMap;<br><br><br> /**<br> * 初始化参数<br> * @param inputUrl<br> * @param baseInput<br> * @return<br> */<br> public BaseInput initInput(String inputUrl, BaseInput baseInput){<br> BaseInput baseInputTarget = ClassUtil.newInstance(inputUrl, BaseInput.class);<br> BeanUtils.copyProperties(baseInput,baseInputTarget);<br> return baseInputTarget;<br> }<br><br><br> /**<br> * 解析节点信息<br> * @param node 节点信息<br> * @param baseInput 请求参数<br> * @param baseTemp 临时上下文<br> * @return<br> */<br> public BaseOutput parserNode(Node node, BaseInput baseInput, BaseTemp baseTemp){<br> baseTemp.setFlowRecord(baseTemp.getFlowRecord().append(FlowConstants.NODEKEY+FlowConstants.NODE+FlowConstants.COLON+node.getId()));<br> BaseOutput baseOutput = parser(node, baseInput, baseTemp);<br> return baseOutput;<br> };<br><br> @Override<br> public void setNodeMap(Map<String, Node> nodeMap) {<br> this.nodeMap = nodeMap;<br> }<br><br> @Override<br> public abstract BaseOutput parser(Node node, BaseInput baseInput, BaseTemp baseTemp);<br><br>}</code>
流程加载顺序
流程执行我们需要把组件分的很细,最好是独立实现一个功能的类划分成一个组件,体现职责单一原则,也只要把执行功能划分的很细,才能在流程执行的各个流程中灵活组合;在下面流程图中可以看到几个组件,第一个是流程统一执行的入口,这里会有两个地方会用到,第一个就是给外部调用的接口,第二个是子流程执行的入口;第二个组件是节点统一加载管理组件也就是上文提到的工厂类;第三个就是每个组件自己的解析器,用于实现不同类型节点的操作;在设计的过程中一定知道 流程 、管理、节点之间的边界,减少耦合,只有这样不同的组件才能灵活组成。
以上是java怎么实现一个流程编排框架的详细内容。更多信息请关注PHP中文网其他相关文章!

热AI工具

Undresser.AI Undress
人工智能驱动的应用程序,用于创建逼真的裸体照片

AI Clothes Remover
用于从照片中去除衣服的在线人工智能工具。

Undress AI Tool
免费脱衣服图片

Clothoff.io
AI脱衣机

AI Hentai Generator
免费生成ai无尽的。

热门文章

热工具

Dreamweaver Mac版
视觉化网页开发工具

记事本++7.3.1
好用且免费的代码编辑器

mPDF
mPDF是一个PHP库,可以从UTF-8编码的HTML生成PDF文件。原作者Ian Back编写mPDF以从他的网站上“即时”输出PDF文件,并处理不同的语言。与原始脚本如HTML2FPDF相比,它的速度较慢,并且在使用Unicode字体时生成的文件较大,但支持CSS样式等,并进行了大量增强。支持几乎所有语言,包括RTL(阿拉伯语和希伯来语)和CJK(中日韩)。支持嵌套的块级元素(如P、DIV),

安全考试浏览器
Safe Exam Browser是一个安全的浏览器环境,用于安全地进行在线考试。该软件将任何计算机变成一个安全的工作站。它控制对任何实用工具的访问,并防止学生使用未经授权的资源。

适用于 Eclipse 的 SAP NetWeaver 服务器适配器
将Eclipse与SAP NetWeaver应用服务器集成。