当前位置：首页 > news >正文

LiteFlow 框架分析系列（三）：插件扩展机制解密

news 2026/6/13 4:17:23

LiteFlow 框架分析系列（三）：插件扩展机制解密

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

摘要

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

1. 架构概览

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

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

轻量：核心包不臃肿，用户按需引入插件依赖。
灵活：想支持新语言？写个插件就行，不用改核心代码。

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 会：

拉取配置：使用 Nacos SDK 监听并拉取配置内容。
解析配置：调用父类的parse(content)方法将内容转化为 Chain 和 Node。
监听变更：注册监听器，当配置更新时，触发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();// ...}