news 2026/10/8 19:39:58

LiteFlow 框架分析系列(三):插件扩展机制解密

作者头像

张小明

前端开发工程师

1.2k 24
文章封面图
LiteFlow 框架分析系列(三):插件扩展机制解密

LiteFlow 框架分析系列(三):插件扩展机制解密

请关注公众号【碳硅化合物AI】

摘要

LiteFlow 之所以强大,不仅在于其核心的编排能力,更在于其极强的扩展性。本篇将深入分析 LiteFlow 的插件扩展机制,看看它是如何“海纳百川”,支持 Groovy、Python、Lua 等多种脚本语言,以及 Nacos、Etcd 等多种配置中心的。

1. 架构概览

LiteFlow 采用了典型的微内核 + 插件架构。liteflow-core负责核心流程调度,而具体的规则解析(Parser)和脚本执行(Script Executor)则通过 SPI(Service Provider Interface)机制开放给插件实现。

这种设计的好处显而易见:

  1. 轻量:核心包不臃肿,用户按需引入插件依赖。
  2. 灵活:想支持新语言?写个插件就行,不用改核心代码。

2. 脚本插件机制 (Script Plugin)

LiteFlow 支持在流程中直接嵌入脚本代码,这使得业务逻辑极其灵活。这一能力的背后是ScriptExecutor接口。

2.1 核心接口:ScriptExecutor

所有的脚本执行器都必须实现com.yomahub.liteflow.script.ScriptExecutor抽象类:

publicabstractclassScriptExecutor{// 加载并编译脚本publicabstractvoidload(StringnodeId,Stringscript);// 执行脚本publicabstractObjectexecuteScript(ScriptExecuteWrapwrap)throwsException;// 清理缓存publicabstractvoidcleanCache();// 返回支持的脚本类型(如 GROOVY, PYTHON)publicabstractScriptTypeEnumscriptType();}

2.2 插件加载:ServiceLoader

LiteFlow 使用 Java 原生的ServiceLoader来发现插件。

在ScriptExecutorFactory中:

publicclassScriptExecutorFactory{publicScriptExecutorgetScriptExecutor(Stringlanguage){// ... 省略缓存查找 ...// 使用 ServiceLoader 加载实现类ServiceLoader<ScriptExecutor>loader=ServiceLoader.load(ScriptExecutor.class);for(ScriptExecutorexecutor:loader){// 匹配语言类型if(scriptType.equals(executor.scriptType())){scriptExecutorMap.put(language,executor);returnexecutor;}}}}

2.3 案例:Groovy 插件

以liteflow-script-groovy插件为例,它的src/main/resources/META-INF/services/com.yomahub.liteflow.script.ScriptExecutor文件内容为:

com.yomahub.liteflow.script.groovy.GroovyExecutor

这样,当你在规则里定义<node id="s1" type="script" language="groovy">...</node>时,工厂类就能自动找到GroovyExecutor来执行这段代码。

3. 规则源插件机制 (Rule Source Plugin)

LiteFlow 默认支持本地 XML/JSON/YAML 文件。但企业级开发中,规则通常存储在配置中心(如 Nacos, Apollo)或数据库中。

3.1 解析器抽象:FlowParser

所有的规则解析器都继承自FlowParser。

对于扩展插件(如 Nacos),通常会提供一个特定的 Parser 实现,例如NacosXmlELParser。这个 Parser 会:

  1. 拉取配置:使用 Nacos SDK 监听并拉取配置内容。
  2. 解析配置:调用父类的parse(content)方法将内容转化为 Chain 和 Node。
  3. 监听变更:注册监听器,当配置更新时,触发FlowBus.reloadChain进行热刷新。

3.2 自动装配

在FlowExecutor.init()启动时,会尝试加载ParserClassNameSpi:

// FlowExecutor.javaServiceLoader<ParserClassNameSpi>loader=ServiceLoader.load(ParserClassNameSpi.class);if(it.hasNext()){ParserClassNameSpiparserClassNameSpi=it.next();ruleSource="el_xml:"+parserClassNameSpi.getSpiClassName();// ...}

这意味着,如果你引入了liteflow-rule-nacos依赖,且在配置文件中没有显式指定路径,LiteFlow 甚至能自动发现并使用 Nacos 解析器(具体行为视配置而定,通常需要在配置文件中指定liteflow.rule-source为对应的适配器类路径或特定格式)。

4. 关键类图

5. 总结

LiteFlow 的插件机制非常简洁高效:

  1. 定义标准接口:ScriptExecutor和FlowParser。
  2. 利用 Java SPI:通过ServiceLoader实现解耦和自动发现。
  3. 按需加载:核心包不包含具体实现,开发者根据需要引入对应的 Maven 依赖即可。

这种设计使得 LiteFlow 既能保持核心的轻量级,又能拥有无限的扩展能力。下一篇,我们将看看 LiteFlow 是如何与 Spring Boot 这个“大管家”完美融合的。

版权声明: 本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若内容造成侵权/违法违规/事实不符,请联系邮箱:809451989@qq.com进行投诉反馈,一经查实,立即删除!
网站建设 2026/10/4 10:18:29

Dify平台双关语创作辅助功能实测

Dify平台双关语创作辅助功能实测 在内容创作日益追求“梗感”与传播力的今天&#xff0c;一句巧妙的双关语可能比千字长文更具穿透力。但创意并非随时可得——如何让AI既懂语言的多重含义&#xff0c;又能玩出幽默&#xff1f;这不仅考验模型能力&#xff0c;更依赖系统级的设计…

作者头像 李华
网站建设 2026/10/6 7:41:17

基于html5大文件分片上传插件的js实现与加密传输方案

武汉光谷XX软件公司大文件传输组件选型与自研方案 一、项目背景与需求分析 作为武汉光谷地区专注于软件研发的高新技术企业&#xff0c;我司长期服务于政府和企业客户&#xff0c;在政务信息化、企业数字化转型等领域积累了丰富的经验。当前&#xff0c;我司核心产品面临大文…

作者头像 李华
网站建设 2026/10/5 3:20:39

22、Git远程仓库开发与跟踪分支全解析

Git远程仓库开发与跟踪分支全解析 1. Git配置与基础概念 在Git开发中,配置选项能帮助我们建立一致的操作方式。可以根据需求将 branch.autosetupmerge 或 branch.autosetuprebase 配置为 true 、 false 或 always 。除了处理本地与远程分支间的行为,还有其他选项…

作者头像 李华