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

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

    • v2.9.X
    • v2.8.X
    • v2.7.X
    • v2.6.X
  • 升级指南

    • 升级到2.9.3说明
    • 升级到2.9.X说明
    • 升级到2.8.X说明
    • 升级到2.7.X说明
❓问答
💖赞助
🧩插件
🔥PPT
  • 项目介绍
  • 项目成员
  • 更新记录
  • 参与开发
加入群聊
用户
  • TLog-轻量级的分布式日志追踪神器 (opens new window)
  • ERD ONLINE-开箱即用的数据库建模、产品版本管理软件 (opens new window)
  • Forest-更轻量、更简单实用的HTTP客户端框架 (opens new window)
Gitee (opens new window)
Github (opens new window)
  • 简体中文 (opens new window)
  • English (opens new window)
💒首页
  • v2.10.1(当前版本)
  • What's New

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

    • v2.9.X
    • v2.8.X
    • v2.7.X
    • v2.6.X
  • 升级指南

    • 升级到2.9.3说明
    • 升级到2.9.X说明
    • 升级到2.8.X说明
    • 升级到2.7.X说明
❓问答
💖赞助
🧩插件
🔥PPT
  • 项目介绍
  • 项目成员
  • 更新记录
  • 参与开发
加入群聊
用户
  • TLog-轻量级的分布式日志追踪神器 (opens new window)
  • ERD ONLINE-开箱即用的数据库建模、产品版本管理软件 (opens new window)
  • Forest-更轻量、更简单实用的HTTP客户端框架 (opens new window)
Gitee (opens new window)
Github (opens new window)
  • 简体中文 (opens new window)
  • English (opens new window)
  • LiteFlow介绍
  • 项目特性
  • 安装和集成

    • Springboot场景安装运行

      • 依赖
      • 配置
      • 执行
    • Spring场景安装运行

      • 依赖
      • 配置
      • 执行
    • 其他场景安装运行

      • 说明
      • 依赖
      • 配置
      • 执行
  • 规则文件

    • 规则文件格式
    • 本地规则文件配置
    • ZK规则文件配置
    • 自定义配置源
  • 用代码动态构造规则

    • 说明
    • 如何构造
  • 使用详细指南

    • 开启和关闭
    • 同步异步编排
    • 执行器
    • 数据槽
    • 普通组件
    • 条件组件
    • 脚本组件
    • 声明式组件
    • 前置后置组件
    • 组件标签
    • 子流程
    • 隐式子流程
    • 私有投递
      • 什么叫私有投递
      • 解决方式
    • 组件重试
    • 平滑热刷新
    • 组件切面
    • 异常处理机制
    • 步骤打印
    • 不同格式规则加载
    • When异步线程池
    • 自定义组件执行器
    • 简单监控
  • 示例工程

    • 测试用例
    • DEMO案例
  • 性能表现
  • v2.6.X文档
  • 使用详细指南
铂赛东
2022-06-01
目录

私有投递

LiteFlow从2.6.0版本开始,开始支持私有投递特性

# 什么叫私有投递

在之前的介绍中已经阐述了在一个请求中,各个LiteFLow的组件都共享同一个slot(相当于同一个上下文的概念)。

在一个请求中,slot里的所有数据对这个请求链路中所有的节点都是公开的。每个组件都可以存取数据。

但是存在这样一个情况,比如我的规则是这样定义的:






 




<?xml version="1.0" encoding="UTF-8"?>
<flow>
    <chain name="chain1">
        <then value="a"/>
        <!-- 5个相同的b组件并发执行 -->
        <when value="b,b,b,b,b"/>
        <then value="c"/>
    </chain>
</flow>

在执行完组件a之后,进行了同样的5个b组件的并发。在b组件上逻辑是同一套,但是要接收5个不同的参数。

我们知道,在之前的描述中,a组件可以往slot里放数据,其他组件可以取到a组件往slot放的东西,但是在这个场景中,普通的存放数据是无法让b组件取到5个不同的参数来进行并发处理的。

概念

所以为此,LiteFlow特地设计了私有投递的概念,指的是:一个组件可以显示的声明为某个特定的组件去投递1个或多个参数,而投递的参数,也只有这个特定的组件才能获取到,其他组件是获取不到的。并且这个投递的参数(一个或多个)只能被取一次。

有了这个特性,那上述的场景就可以利用私有投递的特性去解决了。

# 解决方式

我们先定义组件a:










 




@LiteflowComponent("a")
public class ACmp extends NodeComponent {
	@Override
	public void process() {
		System.out.println("ACmp executed!");
		Slot slot = getSlot();
		slot.setData("testSet", new HashSet<>());

		for (int i = 0; i < 5; i++) {
			this.sendPrivateDeliveryData("b",i+1);
		}
	}
}

可以看到我们为b组件进行了私有投递,调用了this.sendPrivateDeliveryData方法,指定了b组件

然后我们再来看b组件:






 




@LiteflowComponent("b")
public class BCmp extends NodeComponent {
	@Override
	public void process() {
		System.out.println("BCmp executed!");
		Integer value = this.getPrivateDeliveryData();
		//do your biz
	}
}

b组件调用了this.getPrivateDeliveryData()方法,获取了a组件投递的参数。因为参数只能被获取一次(内部用队列来实现),所以保证了每个b组件获取到的参数都是不一样的。

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

← 隐式子流程 组件重试→

Theme by Vdoing | Copyright © 2020-2023 铂赛东 | MIT License
  • 跟随系统
  • 浅色模式
  • 深色模式
  • 阅读模式