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

    • 🌈What' s New In LiteFlow v2.15.0?
  • 历史版本

    • 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说明
👑LF CLUB社区
  • 常见问题
  • 专题解释

    • 如何理解上下文这个概念?
    • Slot是一个什么样的概念,在框架中起到什么样的作用?
💖赞助
🧩IDEA插件
🔥PPT
  • 项目介绍
  • 项目成员
  • 更新记录
  • 参与开发
👥加入群聊
🧤谁在使用
  • Gitee (opens new window)
  • GitCode (opens new window)
  • Github (opens new window)

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

    • 🌈What' s New In LiteFlow v2.15.0?
  • 历史版本

    • 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说明
👑LF CLUB社区
  • 常见问题
  • 专题解释

    • 如何理解上下文这个概念?
    • Slot是一个什么样的概念,在框架中起到什么样的作用?
💖赞助
🧩IDEA插件
🔥PPT
  • 项目介绍
  • 项目成员
  • 更新记录
  • 参与开发
👥加入群聊
🧤谁在使用
  • Gitee (opens new window)
  • GitCode (opens new window)
  • Github (opens new window)
  • 🍤LiteFlow简介
  • 🍓项目特性
  • 🧁环境支持

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

    • 🍄说明
    • 🌿Springboot场景安装运行

      • 🧬依赖
      • ⚙️配置
      • 🛫执行
    • 🌱Spring场景安装运行

      • 🧬依赖
      • ⚙️配置
      • 🛫执行
    • 🌵其他场景安装运行

      • 🍄说明
      • 🧬依赖
      • ⚙️配置
      • 🛫执行
  • 🍢配置项

    • 🍄说明
    • 🌿Springboot下的配置项
    • 🌱Spring下的配置项
    • 🌵其他场景代码设置配置项
  • 🗂规则以及配置源

    • 📔规则文件格式
    • 📕本地规则文件配置
    • 📗ZK规则文件配置源
      • 依赖
      • 配置
      • 配置说明
      • 存储数据说明
      • 自动刷新
      • 脚本key的语言配置
      • 规则的启用关闭和脚本启用关闭
      • 小例子
    • 📘SQL数据库配置源
    • 📋Nacos配置源
    • 🗄Etcd配置源
    • 📜Apollo配置源
    • 📑Redis配置源

      • 配置说明
      • 轮询模式配置
      • 订阅模式配置
    • 📙自定义配置源
  • 🔗常规组件

    • 📎普通组件
    • ✂️选择组件
    • ⛓布尔组件
    • 🧬次数循环组件
    • ⌛️迭代循环组件
  • 🧩EL规则的写法

    • 🍄说明
    • 🌴串行编排
    • 🎋并行编排
    • 🌾选择编排
    • 🌵条件编排
    • 🌳循环编排
    • 🎃捕获异常表达式
    • 🍄与或非表达式
    • 🍁使用子流程
    • 🍂使用子变量
    • 💐复杂编排例子
    • 🌻关于分号
    • 🌰关于注释
    • 🐚组件名包装
    • 🔆验证规则
  • 🌮数据上下文

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

    • 🍄说明
    • 🎡执行方法
    • 🎢流程入参
    • 🎈LiteflowResponse对象
  • 🍋脚本组件

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

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

    • 🥭什么叫声明式组件
    • 🧅类级别式声明
    • 🥥方法级别式声明
  • 🎲用代码动态构造规则

    • 🍄说明
    • 🥜构造Node
    • 🌰构造EL
    • 🍞构造Chain
  • 🍼元数据管理

    • ⛰概念以及介绍
    • 🍖平滑热刷新
    • 🍮启动不检查规则
    • 🫔查看指定规则下的所有组件
  • 🧮决策路由

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

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

    • 🍒前置和后置组件
    • 🍌本地规则文件监听
    • 🥠组件降级
    • 🍉组件参数
    • 🍑组件别名
    • 🍍组件标签
    • 🥝组件事件回调
    • 🐋组件回滚
    • 🥑隐式子流程
    • 🍕私有投递
    • 🍣组件重试
    • 🫐EL中的重试
    • 🥦异步循环模式
    • ⏱️超时控制
    • 🥯链路继承
    • 🍪组件切面
    • 🍡步骤信息
    • 🧊异常
    • 🧇打印信息详解
    • 🧁自定义请求Id
    • 🫕快速解析模式
    • 🌭不同格式规则加载
    • 🥗异步线程池自定义
    • 🍿自定义组件执行器
    • 🍥简单监控
    • 🧉XML的DTD
  • ⛱测试用例以及示例

    • 🪁测试用例
    • 🪀DEMO案例
  • 🪂性能表现
  • v2.12.X文档
  • 🗂规则以及配置源
铂赛东
2022-06-07
目录

📗ZK规则文件配置源

# 依赖

LiteFlow支持把配置放在zk集群中,基于zk的通知机制,LiteFlow支持实时修改流程

如果需要用到zk,需要添加以下额外依赖插件:

<dependency>
    <groupId>com.yomahub</groupId>
    <artifactId>liteflow-rule-zk</artifactId>
    <version>2.12.4.1</version>
</dependency>

# 配置

依赖了插件包之后,你无需再配置liteflow.ruleSource路径。

只需要配置插件的额外参数即可:

    liteflow:
      rule-source-ext-data-map:
        connectStr: 127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183
        chainPath: /liteflow/chain
        #如果你没有脚本组件,以下可以不配置
        scriptPath: /liteflow/script
    
    liteflow.rule-source-ext-data={\
        "connectStr":"127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183",\
        "chainPath":"/liteflow/chain",\
        "scriptPath":"/liteflow/script"\
    }
    
    // Make sure to add code blocks to your code group

    # 配置说明

    配置项 说明
    connectStr zk的连接串,可以是集群
    chainPath 你的规则目录节点(下面会有很多个规则,一个规则一个节点)
    scriptPath 你的脚本目录节点(下面会有很多个脚本,一个脚本一个节点)

    # 存储数据说明

    在ZK中,假设你的chainPath为:/liteflow/chain

    那么这个路径下的每一个节点就是一个规则,节点的key的格式为:规则ID[:是否启用],其中方括号内的为可选项,value为单纯的EL(THEN(a,b,c)),比如:

    /liteflow/chain

    ---chain1

    ---chain2

    对于脚本path来说,假设你的scriptPath为:/liteflow/script

    那么这个路径下的每一个节点都是一个脚本组件,节点的key有固定格式:脚本组件ID:脚本类型[:脚本名称:脚本语言:是否启用],其中方括号内的为可选项。 value为脚本数据,比如:

    /liteflow/script

    ---s1:script:脚本组件s1

    ---s2:boolean_script:布尔脚本组件s2

    关于脚本类型,可以参照脚本语言介绍这一章节。

    # 自动刷新

    使用了此zk配置源插件,凡是zk节点里面的规则改动,会自动推送到业务系统,进行实时的平滑热刷新。你无需做任何事情。

    # 脚本key的语言配置

    如果你只依赖了一种脚本语言插件包,那么语言这项是不需要配置的。会自动识别的。如果你配置了多语言脚本,那么脚本语言这一项,是必须要写的。

    比如s1:boolean_script:布尔脚本s1:js。

    关于脚本的多语言共存,请参考多脚本语言混合共存这一章。

    # 规则的启用关闭和脚本启用关闭v2.12.0+

    LiteFlow也支持在zk节点上保留数据的同时关闭和启动规则/脚本。

    之前说到规则的key的固定格式为规则ID[:是否启用],如果配置chain1:false,那么这个规则就是关闭状态。相当于逻辑删除。

    当然如果你只是配置key为chain1,那么等价于chain1:true。

    对于脚本key来说,固定格式为脚本组件ID:脚本类型[:脚本名称:脚本语言:是否启用],如果配置s1:script:脚本s1:groovy:false,那么这个脚本就是关闭状态,相当于逻辑删除。

    如果不配置最后一项,比如s1:script:脚本s1:groovy,那么等价于s1:script:脚本s1:groovy:true。

    提示

    对于规则key或者脚本key来说,一定要以冒号为分隔符对应好位置,如果你想配置是否启动,那么是在第5项,前面4项就必须要写,如果你写成s1:script:脚本s1:false那将会报错。

    # 小例子

    为了让大家能简单上手ZK规则文件的配置和运行,这里有一个小demo,大家可以拉到本地来运行,需要你替换zk的配置信息。

    运行项目前,先读项目里的readme.txt文件。

    https://github.com/bryan31/liteflow-ext-rule-demo

    帮助我们改善此文档 (opens new window)
    上次更新: 2025/02/16, 21:26:30
    📕本地规则文件配置
    📘SQL数据库配置源

    ← 📕本地规则文件配置 📘SQL数据库配置源→

    Theme by Vdoing | Copyright © 2020-2025 铂赛东 | MIT License
    沪ICP备18012955号-2
    • 跟随系统
    • 浅色模式
    • 深色模式
    • 阅读模式