LiteFlow LiteFlow
首页
  • v2.16.1 (当前版本)
  • What's New

    • What' s New In LiteFlow v2.16.1?
    • What' s New In LiteFlow v2.16.0?
  • 历史版本

    • v2.15.X
    • v2.13.X
    • v2.12.X
    • v2.11.X
    • v2.10.X
    • v2.9.X
    • v2.8.X
  • 升级指南

    • 2.13.0升级指南
    • 2.12.4升级指南
    • 2.12.0升级指南
    • 升级到2.9.3说明
    • 升级到2.9.X说明
    • 升级到2.8.X说明
    • 升级到2.7.X说明
AI Agent
AI Skill
IDEA 插件
  • 答疑解惑

    • 常见问题
    • 如何理解上下文这个概念?
    • Slot是一个什么样的概念?
  • 项目与社区

    • 项目介绍
    • 项目成员
    • 更新记录
    • 参与开发
    • 加入群聊
    • 谁在使用
赞助
GitHub (opens new window)

广告采用随机轮播方式显示 ❤️成为赞助商
首页
  • v2.16.1 (当前版本)
  • What's New

    • What' s New In LiteFlow v2.16.1?
    • What' s New In LiteFlow v2.16.0?
  • 历史版本

    • v2.15.X
    • v2.13.X
    • v2.12.X
    • v2.11.X
    • v2.10.X
    • v2.9.X
    • v2.8.X
  • 升级指南

    • 2.13.0升级指南
    • 2.12.4升级指南
    • 2.12.0升级指南
    • 升级到2.9.3说明
    • 升级到2.9.X说明
    • 升级到2.8.X说明
    • 升级到2.7.X说明
AI Agent
AI Skill
IDEA 插件
  • 答疑解惑

    • 常见问题
    • 如何理解上下文这个概念?
    • Slot是一个什么样的概念?
  • 项目与社区

    • 项目介绍
    • 项目成员
    • 更新记录
    • 参与开发
    • 加入群聊
    • 谁在使用
赞助
GitHub (opens new window)
  • 🍤LiteFlow简介
  • 🍓项目特性
  • 🧁环境支持

    • ☕️JDK支持度
    • 🌿Springboot支持度
    • 🌱Spring的支持度
  • 🍟快速开始(Hello world)

    • 🍄说明
    • 🌿Springboot场景安装运行
    • 🌱Spring场景安装运行
    • 🍩Solon场景安装运行
    • 🌵其他场景安装运行
  • 🍢配置项

    • 🍄说明
    • 🌿Springboot下的配置项
    • 🌱Spring下的配置项
    • 🍩Solon下的配置项
    • 🌵其他场景代码设置配置项
  • 🔗组件

    • 🛍继承式组件

      • 📎普通组件
      • ✂️选择组件
      • ⛓布尔组件
      • 🧬次数循环组件
      • ⌛️迭代循环组件
      • 🏄LiteflowComponent
      • 🛀组件内方法覆盖和调用
    • 🎁声明式组件

      • 🥭什么叫声明式组件
      • 🧅类级别式声明
      • 🥥方法级别式声明
  • 🧩EL规则

    • 🍄说明
    • 🌴串行编排
    • 🎋并行编排
    • 🌾选择编排
    • 🌵条件编排
    • 🌳循环编排
    • 🥦异步循环模式
    • 🎃捕获异常表达式
    • 🍄与或非表达式
    • 🍁使用子流程
    • 🍂使用子变量
    • 💐复杂编排例子
    • 🍒前置和后置编排
    • 🍉组件参数语法

      • 说明
      • tag语法
      • data语法
      • bind语法
    • 🫐重试语法
    • ⏱️超时控制语法
    • 🥯链路继承
    • 🔆验证规则
    • 🌰关于注释
    • 🌻关于分号
    • 🐚组件名包装
  • 🌮上下文

    • 🍄说明
    • 🌯数据上下文的定义和使用
    • 🪶用初始化好的上下文传入
    • 🥨给上下文设置别名
    • 🥙上下文参数注入
    • 🪴用表达式获取上下文参数
  • 🛩执行器

    • 🍄说明
    • 🎡执行方法
    • 🎢流程入参
    • 🎈LiteflowResponse对象
    • 🪃直接执行EL规则
  • 🍋脚本组件

    • 🌭脚本语言介绍
    • 🍫脚本语言种类

      • ☕️Java脚本引擎
      • 🥏Groovy脚本引擎
      • 🧀Javascript脚本引擎
      • 🥞QLExpress脚本引擎
      • 🍧Python脚本引擎
      • 🍝Lua脚本引擎
      • 🥐Aviator脚本引擎
      • 🥠Kotlin脚本引擎
    • 🍣脚本与Java进行交互
    • 🍱多脚本语言混合共存
    • 🌯文件脚本的定义
    • 🍘动态刷新脚本
    • 🍦验证脚本
    • 🗑卸载脚本
  • 🗂规则配置源

    • 📕本地规则文件配置
    • 📘SQL数据库配置源(旧)
    • 📗ZK规则文件配置源(旧)
    • 📋Nacos配置源(旧)
    • 🗄Etcd配置源(旧)
    • 📜Apollo配置源(旧)
    • 📑Redis配置源(旧)

      • 配置说明
      • 轮询模式配置
      • 订阅模式配置
    • 📙自定义配置源
  • 🏦Rule-DB模式

    • 🏦Rule-DB是什么
    • 🐬快速开始(SQL)
    • 🐘快速开始(PostgreSQL)
    • 🍃快速开始(MongoDB)
    • 📕快速开始(Redis)
    • 📗快速开始(ZooKeeper)
    • 🗄快速开始(Etcd)
    • 📋快速开始(Nacos)
      • Step 1:引入依赖
      • Step 2:写配置
      • Step 3:发布第一条规则
      • Step 4:执行
    • 🍢配置项参考
    • 🗃存储结构参考
    • 📤发布API与写入规范
    • ⚖️一致性与收敛模型
    • 🪁内存与性能
    • 🔭可观测性与降级
    • 🚧限制与迁移
  • 🍼元数据管理

    • ⛰元数据操作器
    • 🍖平滑热刷新
    • 🍮启动不检查规则
    • 🥨启动不检查脚本
  • 🌌异步中的线程池

    • 💧说明
    • 🐋FlowExecutor层面的线程池
    • 🐠组件异步层面的线程池
    • 🪶虚拟线程
  • 🎲动态构造

    • 🍄说明
    • 🥜构造Node
    • 🌰构造EL
    • 🍞构造Chain
  • 🧮决策路由

    • 🏖概念以及介绍
    • 🍽决策路由用法
  • 😸生命周期

    • 🐮启动时生命周期
    • 🐳执行时生命周期
  • 🎨高级特性

    • 🍌本地规则文件监听
    • 🥠组件降级
    • 🍑组件别名
    • 🥝组件事件回调
    • 🐋组件回滚
    • 🥑隐式子流程
    • 🫐活跃规则保活策略
    • 🍕私有投递
    • 🍪组件切面
    • 🍡步骤信息
    • 🧊异常
    • 🧇打印信息详解
    • 🧁自定义请求Id
    • 🫕快速解析模式
    • 🌭不同格式规则加载
    • 🍿自定义组件执行器
    • 🍥简单监控
    • 🧉XML的DTD
  • 📈指标监控

    • 📈指标监控概述
    • 🚀快速接入
    • 📋指标目录
    • 🔌Actuator端点说明
    • 📐分位与直方图
    • 🔍常用PromQL与告警
    • ⚡性能影响与基数控制
  • ⛱测试用例以及示例

    • 🪁测试用例
    • 🪀DEMO案例
  • 🪂性能表现
  • v2.16.X文档
  • 🏦Rule-DB模式
铂赛东
2026-07-25
目录

📋快速开始(Nacos)

版本支持:v2.16.1+

要求Nacos Server 2.x及以上

并发发布的原子性靠publishConfigCas来保证,1.x没有这个能力。

这个模块显式用的是nacos-client:2.5.3,而旧的liteflow-rule-nacos插件还在用1.4.4,所以迁移的时候不要把两个模块放进同一个classpath。如果外部BOM把客户端降级到不含CAS API的版本,模块会在初始化时直接报错。

# Step 1:引入依赖

<dependency>
    <groupId>com.yomahub</groupId>
    <artifactId>liteflow-spring-boot-starter</artifactId>
    <version>2.16.1</version>
</dependency>
<dependency>
    <groupId>com.yomahub</groupId>
    <artifactId>liteflow-rule-db-nacos</artifactId>
    <version>2.16.1</version>
</dependency>

# Step 2:写配置

这里要定两件事:插件用哪个客户端连Nacos,以及规则记在哪个隔离名下。两者没有关联。

先说连接。项目已经接了Nacos配置中心的话,连接一行都不用配,插件按类型把容器里的ConfigService取出来直接用,连接、鉴权、命名空间都沿用这个bean。有多个ConfigService时,用config-service-bean-name指明用哪个。复用的bean归容器所有,Provider关闭时不会去调它的shutDown()。

容器里确实没有ConfigService,那就配地址让插件自己建:

liteflow.rule-db.nacos.server-addr=127.0.0.1:8848
# namespace 填命名空间ID,不是显示名称;留空使用 public
# liteflow.rule-db.nacos.namespace=your-namespace-id
# group 默认 LITEFLOW_RULE_DB
# data-id-prefix 默认 liteflow-rule-db

顺序上bean优先于server-addr,找到了bean就不会再看server-addr;两个都没有则启动报错。

再说隔离名。liteflow.rule-db.application-name直接决定Catalog的dataId,不同取值互相看不到。它只管隔离,和用哪个客户端无关。

Spring Boot下它留空时会取spring.application.name:

spring.application.name=order-service

两个都没配会回落成default,多个应用共用一套Nacos时请确保取值不同。Solon插件没有这个回落,需要显式配liteflow.rule-db.application-name。这个值还要和Step 3里Publisher的applicationName(...)一致。

运行时会把当前应用映射成一条Nacos配置:

dataId = {data-id-prefix}.{application-name}.catalog.json
group  = {group}

举个例子,应用名是order-service时,默认的dataId就是liteflow-rule-db.order-service.catalog.json,group是LITEFLOW_RULE_DB。这条配置不用你在控制台预先建好,首次发布时Publisher会创建。

# Step 3:发布第一条规则

规则的增删改只能走Publisher API。正文、版本、sequence和lastChange都在同一次CAS里提交,在控制台手改是覆盖不了这套并发语义的,本页末尾有说明。

import com.yomahub.liteflow.publisher.PublishChainRequest;
import com.yomahub.liteflow.publisher.RulePublisher;
import com.yomahub.liteflow.publisher.RulePublisherFactory;
import com.yomahub.liteflow.repository.nacos.NacosPublisherConfig;

try (RulePublisher publisher = RulePublisherFactory.create(
        NacosPublisherConfig.builder()
                .serverAddr("127.0.0.1:8848")
                .applicationName("order-service")
                .build())) {
    publisher.publishChain(PublishChainRequest.builder()
            .chainId("orderChain")
            .el("THEN(a, b)")
            .expectedVersion(0L)
            .build());
}

每次发布会先读取当前的Catalog,再通过Nacos的CAS整体替换。Catalog里的正文、业务版本、全局sequence和lastChange都在同一次CAS里提交。并发写入产生冲突时会重新读取再重试,最多8次;如果你显式传了expectedVersion而它已经失效,则抛VersionConflictException。

执行节点通过Nacos Listener感知lastChange,一旦发现序号跳跃、内容损坏或者回调失败,会立即请求一次全量对账。

容量必须提前评估

一个应用的全部chain和脚本正文都在同一条Nacos配置里,受Nacos服务端nacos.core.config.max-size、数据库字段以及接入层的单配置大小限制,而模块不会自动分片。

所以上线前请用生产等价的配置压测一下Catalog的最大体积,并预留增长空间。如果规则数量多、正文很长或者发布频繁,建议优先选SQL、PostgreSQL或MongoDB。

执行端不会长期保留整份Catalog正文,但每次冷读取和对账都要传输并解码整份配置。

不要在控制台直接改Catalog

正确的发布要基于当前内容的MD5做CAS,同时维护正文MD5、业务版本、连续的sequence和lastChange,控制台的覆盖写保持不了这套并发语义。请只用RulePublisher。

# Step 4:执行

和前面一样,照常调flowExecutor.execute2Resp(...)。

帮助我们改善此文档 (opens new window)
🗄快速开始(Etcd)
🍢配置项参考

← 🗄快速开始(Etcd) 🍢配置项参考→

Theme by Vdoing | Copyright © 2020-2026 铂赛东 | MIT License
沪ICP备18012955号-2