news 2026/6/10 11:58:10

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/5/29 4:15:53

AI测试误判事故的法律责任框架

一、AI测试误判的特殊性 黑盒特性困境 传统软件测试可通过代码逻辑追溯问题&#xff0c;而AI模型的决策过程通常无法逆向解析&#xff0c;导致责任认定困难。例如&#xff0c;在2024年某自动驾驶测试中&#xff0c;系统将行人影子误判为障碍物&#xff0c;最终引发追尾事故&…

作者头像 李华
网站建设 2026/6/10 0:43:28

28、Subversion 完全使用指南

Subversion 完全使用指南 1. Subversion 命令行客户端基础 使用 Subversion 命令行客户端时,只需输入 svn ,接着输入想要使用的子命令,以及任何想要操作的选项或目标。子命令和选项的出现顺序没有特定要求。例如,以下几种使用 svn status 的方式都是有效的: $ svn…

作者头像 李华
网站建设 2026/6/9 18:47:30

32、Subversion 命令行工具使用指南

Subversion 命令行工具使用指南 在版本控制系统的使用中,Subversion 是一款广泛应用的工具。以下将详细介绍 Subversion 中一些重要命令行工具的使用方法和功能。 1. svnadmin 工具 svnadmin 是用于管理 Subversion 版本库的工具,下面介绍其两个常用命令。 1.1 svnadmin …

作者头像 李华
网站建设 2026/6/10 13:38:22

47 Docker镜像编排

文章目录前言理论部分8_镜像的创建8.1_Docker 镜像结构8.2_Dockerfile 指令详解8.3_镜像三种创建方式9_Compose编排9.1_Compose 核心概念9.2_YAML 语法规范10_Harbor私有仓库10.1_Harbor 核心组件10.2_Harbor 安全机制实验部分8_镜像的创建8.1_构建 Apache 镜像9_Compose编排9.…

作者头像 李华
网站建设 2026/6/9 23:22:09

清华大学开源的Open-AutoGLM究竟藏着哪些黑科技?(独家深度拆解)

第一章&#xff1a;清华大学开源的Open-AutoGLM究竟藏着哪些黑科技&#xff1f;&#xff08;独家深度拆解&#xff09;Open-AutoGLM 是清华大学自然语言处理实验室推出的一款面向自动化图学习与生成语言建模融合的开源框架&#xff0c;其核心在于打通图神经网络&#xff08;GNN…

作者头像 李华
网站建设 2026/6/10 12:35:43

Dify平台入职培训内容生成系统设计

Dify平台入职培训内容生成系统设计 在企业数字化转型的浪潮中&#xff0c;人力资源管理正面临前所未有的效率挑战。尤其是新员工入职培训这一环节&#xff0c;传统模式下高度依赖HR人工整理资料、重复回答相同问题、难以个性化适配岗位需求——不仅耗时费力&#xff0c;还容易因…

作者头像 李华