news 2026/1/18 8:36:46

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

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

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

Dify平台品牌故事撰写辅助工具实现

Dify平台赋能品牌故事智能生成的实践路径 在内容为王的时代&#xff0c;一个打动人心的品牌故事往往是企业与用户建立情感连接的第一步。然而&#xff0c;传统的内容创作流程高度依赖资深文案人员的经验和灵感&#xff0c;不仅耗时费力&#xff0c;还难以保证风格统一与事实准…

作者头像 李华
网站建设 2026/1/17 8:41:38

21、《svnserve 程序的运行方式及相关配置详解》

《svnserve 程序的运行方式及相关配置详解》 1. svnserve 程序的运行方式 svnserve 程序有以下几种不同的运行方式: - 作为独立守护进程运行,监听请求。 - 通过 Unix 的 inetd 守护进程,在特定端口收到请求时临时启动 svnserve。 - 由 SSH 通过加密隧道调用临时的 svns…

作者头像 李华
网站建设 2026/1/17 1:06:11

24、Subversion 配置与使用全解析

Subversion 配置与使用全解析 1. 组访问控制 在 Subversion 中,组和用户一样可以被授予访问控制权限。可以使用“@”前缀来区分组,示例如下: [calc:/projects/calc] @calc-developers = rw [paint:/projects/paint] @paint-developers = rw jane = r同时,组还可以包含其…

作者头像 李华
网站建设 2026/1/17 21:15:19

20、Git远程仓库操作全解析

Git远程仓库操作全解析 1. 基础命令介绍 在Git的使用中,有两个基础命令在处理远程仓库时非常关键: - git push :该命令用于将本地仓库中的对象及其相关元数据传输到远程仓库。通过它,我们可以把本地的修改和提交同步到远程,方便团队协作和代码的共享。 - git ls - …

作者头像 李华
网站建设 2026/1/17 20:21:08

【权威解读】Open-AutoGLM发布后,AutoML领域将被彻底改写?

第一章&#xff1a;Open-AutoGLM是什么意思 Open-AutoGLM 是一个面向自动化自然语言处理任务的开源框架&#xff0c;旨在通过大语言模型&#xff08;LLM&#xff09;实现任务自适应、流程自动化与模型协同调度。其核心设计理念是将自然语言理解、代码生成、任务分解与执行反馈整…

作者头像 李华