今天小编给大家分享一下java怎么实现一个流程编排框架的相关知识点，内容详细，逻辑清晰，相信大部分人都还太了解这方面的知识，所以分享这篇文章给大家参考一下，希望大家阅读完这篇文章后有所收获，下面我们一起来了解一下吧。
之前有讲到要支持yml、properties、xml、json、接口的形式注册流程模型，为了体现职责单一原则，我们需要把一种格式解析的逻辑独立处理，为了体现对扩展开发，对修改关闭原则，我们先定义一组接口，然后通过工厂模式提供对应的实现逻辑；这里工厂是使用者，通过接口调用具体的实现，实现在这里是提供者，又是一组策略模式。
流程加载我们需要知道其他的几个需求功能点：1、提供对外统一访问接口；2、提供执行记录和执行耗时；3、不同流程节点需要定义不同的解析器；4、通过工厂创建解析类型；5、流程节点按照顺序执行。
通过不同的节点类型执行不同的解析方式，显而易见这里需要用工厂模式去做解析类创建，而且需要做到对外扩展开发对修改关闭，新增节点不用动其他代码逻辑，只要在工厂函数里面添加一个节点解析器；同时我们这里定义一个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);}流程执行我们需要把组件分的很细，最好是独立实现一个功能的类划分成一个组件，体现职责单一原则，也只要把执行功能划分的很细，才能在流程执行的各个流程中灵活组合；在下面流程图中可以看到几个组件，第一个是流程统一执行的入口，这里会有两个地方会用到，第一个就是给外部调用的接口，第二个是子流程执行的入口；第二个组件是节点统一加载管理组件也就是上文提到的工厂类；第三个就是每个组件自己的解析器，用于实现不同类型节点的操作；在设计的过程中一定知道 流程 、管理、节点之间的边界，减少耦合，只有这样不同的组件才能灵活组成。
以上就是“java怎么实现一个流程编排框架”这篇文章的所有内容，感谢各位的阅读！相信大家阅读完这篇文章都有很大的收获，小编每天都会为大家更新不同的知识，如果还想学习更多的知识，请关注亿速云行业资讯频道。
亿速云「云服务器」，即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘，价格低至29元/月。点击查看>>
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
原文链接：https://my.oschina.net/u/3956965/blog/4417706
