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

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

    • 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是一个什么样的概念,在框架中起到什么样的作用?
💖赞助
🧩插件
🔥PPT
  • 项目介绍
  • 项目成员
  • 更新记录
  • 参与开发
👥加入群聊
🧤谁在使用
  • Gitee (opens new window)
  • GitCode (opens new window)
  • Github (opens new window)

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

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

    • 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是一个什么样的概念,在框架中起到什么样的作用?
💖赞助
🧩插件
🔥PPT
  • 项目介绍
  • 项目成员
  • 更新记录
  • 参与开发
👥加入群聊
🧤谁在使用
  • Gitee (opens new window)
  • GitCode (opens new window)
  • Github (opens new window)
  • LiteFlow简介
  • 项目特性
  • 快速开始(Hello world)

  • 配置项

  • 规则文件

  • 用代码动态构造规则

  • 使用详细指南

    • 开启和关闭
    • 规则文件路径
    • 同步异步编排
    • 执行器
    • 数据上下文
    • Response对象
    • 普通组件
    • 条件组件
    • 脚本组件
    • 声明式组件
    • 前置后置组件
    • 组件别名
    • 组件标签
    • 组件事件回调
    • 子流程
    • 隐式子流程
    • 私有投递
    • 组件重试
    • 平滑热刷新
      • 基于规则文件-主动刷新
      • 基于规则文件-被动刷新
      • 基于动态代码构建-刷新
    • 组件切面
    • 步骤信息
    • 打印信息详解
    • 不同格式规则加载
    • When异步线程池
    • 自定义组件执行器
    • 简单监控
  • 示例工程

  • 性能表现
  • v2.7.X文档
  • 使用详细指南
铂赛东
2022-06-01
目录

平滑热刷新

LiteFlow从2.6.4开始支持了优雅平滑热刷新的特性。

即你可以在不重启服务的情况下,进行规则的重载。并且在高并发下刷新的时候,正在执行流程的线程是完全平滑的,不会因为刷新的过程而出现中断的现象。

在刷新时,正在执行的流程还是走的旧的流程,刷新好。后续request会自动切换到新的流程。

LiteFlow原生支持的zookeeper配置源,不需要你做任何事,只要zk上的规则更改了之后,会自动热平滑刷新。

但是对于自定义配置源来说,LiteFlow提供了主动刷新和被动刷新2个接口,根据需要自行选择。

# 基于规则文件-主动刷新

你可以在spring容器中拿到FlowExecutor对象后,调用以下接口:

flowExecutor.reloadRule();

这个方法会按照启动时的方式去拉取你最新的流程配置信息,进行平滑热刷新。

# 基于规则文件-被动刷新

所谓被动刷新,适用于使用了诸如配置中心,nacos,etcd等自定配置源,这类配置源可以反向推送最新的数据。对于java客户端这边,一定会有一个诸如listener的监听器去监听数据的变更。

如果你监听到了变更,你可以通过调用这个方法去实现平滑热刷新:

FlowBus.refreshFlowMetaData(FlowParserTypeEnum.TYPE_JSON, newContent);

其中第一个参数是指文件格式什么,支持xml/json/yml

第二个参数指的是推送过来的最新配置文本数据

# 基于动态代码构建-刷新

如果你是基于动态代码构建的规则,则意味着没有规则文件,以上两种方式是基于规则文件的。

其实基于动态代码构建的,建议你把动态代码构建的代码封装成一个方法。有变动时,再重新执行一遍构建就可以了。会重新覆盖的。并且这一过程,也是平滑的。

帮助我们改善此文档 (opens new window)
上次更新: 2022/10/07, 00:22:18
组件重试
组件切面

← 组件重试 组件切面→

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