登录
注册
开源
企业版
高校版
搜索
帮助中心
使用条款
关于我们
开源
企业版
高校版
私有云
模力方舟
AI 队友
登录
注册
轻量养虾,开箱即用!低 Token + 稳定算力,Gitee & 模力方舟联合出品的 PocketClaw 正式开售!点击了解详情
代码拉取完成,页面将自动刷新
开源项目
>
程序开发
>
流程引擎/工具
&&
捐赠
捐赠前请先登录
取消
前往登录
扫描微信二维码支付
取消
支付完成
支付提示
将跳转至支付宝完成支付
确定
取消
Watch
不关注
关注所有动态
仅关注版本发行动态
关注但不提醒动态
630
Star
7.5K
Fork
1.8K
GVP
dromara
/
liteFlow
代码
Issues
145
Pull Requests
4
Wiki
统计
流水线
服务
JavaDoc
质量分析
Jenkins for Gitee
腾讯云托管
腾讯云 Serverless
悬镜安全
阿里云 SAE
Codeblitz
SBOM
开发画像分析
我知道了,不再自动展开
更新失败,请稍后重试!
移除标识
内容风险标识
本任务被
标识为内容中包含有代码安全 Bug 、隐私泄露等敏感信息,仓库外成员不可访问
关于when和then混合使用时(有any和isAccess的情况下),then的节点先执行的问题
已完成
#I4XRBA
第七人格
创建于
2022-03-14 17:13
**测试分支** : master 2.6.11 **业务场景:** a.校验手机号 b.校验身份证 c.注册 1、一般情况下a/b有一个校验通过,则进行注册 2、某些业务情况下可以不访问a,即a中isAccess = false(只需要校验身份证即可注册) 3、期望访问路径 b===>c;但是却出现c===>b或者c **抽象规则配置如下** : ``` <flow> <chain name="chain1"> <!--异步模式,其中a为isAccess = false--> <when value="a,b" any="true"/> <!--同步模式--> <then value="c"/> </chain> </flow> ``` **依赖** ``` <dependency> <groupId>com.yomahub</groupId> <artifactId>liteflow-spring-boot-starter</artifactId> <version>2.6.11</version> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> <version>2.1.5.RELEASE</version> </dependency> ``` **伪代码** ``` @Component("a") public class ACmp extends NodeComponent { @Override public void process() throws InterruptedException { System.out.println("ACmp==========>"); // 为节点c,投掷我们的私有属性 this.sendPrivateDeliveryData("c","nb-->A"); System.out.println("ACmp==========>执行完毕"); //do your business } @Override public boolean isAccess(){ // 某种情况下,不会访问A节点 return false; } } ``` ``` @Component("b") public class BCmp extends NodeComponent { @Override public void process(){ System.out.println("BCmp==========>"); // 为节点c,投掷我们的私有属性 this.sendPrivateDeliveryData("c","nb"); System.out.println("BCmp==========>执行完毕"); //do your business } @Override public boolean isAccess(){ return true; } } ``` ``` @Component("c") public class CCmp extends NodeComponent { @Override public void process() { System.out.println("CCmp==========>"); Object privateDeliveryData = this.getPrivateDeliveryData(); System.out.println("从节点b中拿到的私有属性为:"+privateDeliveryData); System.out.println("CCmp==========>执行完毕"); //do your business } } ``` ``` @RestController public class HelloWorldController { @Resource private FlowExecutor flowExecutor; public void testConfig() { for (int i = 0; i < 100; i++) { LiteflowResponse<MySlot> response = flowExecutor.execute2Resp("chain1", "链路参数", MySlot.class); } } /** * 你好,gay * * @return {@link Object} */ @GetMapping("/hello") public Object hello() { testConfig(); return "Hello World~"; } } ``` **错误的详细日志** :  **期望结果**  **尝试解决思路** executeAsyncCondition方法中过滤isAccess=false的节点(可以解决问题,但是不知道与框架设计是否冲突——>所有的可执行节点,最终都会落到node上) 
**测试分支** : master 2.6.11 **业务场景:** a.校验手机号 b.校验身份证 c.注册 1、一般情况下a/b有一个校验通过,则进行注册 2、某些业务情况下可以不访问a,即a中isAccess = false(只需要校验身份证即可注册) 3、期望访问路径 b===>c;但是却出现c===>b或者c **抽象规则配置如下** : ``` <flow> <chain name="chain1"> <!--异步模式,其中a为isAccess = false--> <when value="a,b" any="true"/> <!--同步模式--> <then value="c"/> </chain> </flow> ``` **依赖** ``` <dependency> <groupId>com.yomahub</groupId> <artifactId>liteflow-spring-boot-starter</artifactId> <version>2.6.11</version> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> <version>2.1.5.RELEASE</version> </dependency> ``` **伪代码** ``` @Component("a") public class ACmp extends NodeComponent { @Override public void process() throws InterruptedException { System.out.println("ACmp==========>"); // 为节点c,投掷我们的私有属性 this.sendPrivateDeliveryData("c","nb-->A"); System.out.println("ACmp==========>执行完毕"); //do your business } @Override public boolean isAccess(){ // 某种情况下,不会访问A节点 return false; } } ``` ``` @Component("b") public class BCmp extends NodeComponent { @Override public void process(){ System.out.println("BCmp==========>"); // 为节点c,投掷我们的私有属性 this.sendPrivateDeliveryData("c","nb"); System.out.println("BCmp==========>执行完毕"); //do your business } @Override public boolean isAccess(){ return true; } } ``` ``` @Component("c") public class CCmp extends NodeComponent { @Override public void process() { System.out.println("CCmp==========>"); Object privateDeliveryData = this.getPrivateDeliveryData(); System.out.println("从节点b中拿到的私有属性为:"+privateDeliveryData); System.out.println("CCmp==========>执行完毕"); //do your business } } ``` ``` @RestController public class HelloWorldController { @Resource private FlowExecutor flowExecutor; public void testConfig() { for (int i = 0; i < 100; i++) { LiteflowResponse<MySlot> response = flowExecutor.execute2Resp("chain1", "链路参数", MySlot.class); } } /** * 你好,gay * * @return {@link Object} */ @GetMapping("/hello") public Object hello() { testConfig(); return "Hello World~"; } } ``` **错误的详细日志** :  **期望结果**  **尝试解决思路** executeAsyncCondition方法中过滤isAccess=false的节点(可以解决问题,但是不知道与框架设计是否冲突——>所有的可执行节点,最终都会落到node上) 
评论 (
2
)
登录
后才可以发表评论
状态
已完成
待办的
进行中
已完成
已关闭
负责人
未设置
铂赛东
bryan31
负责人
协作者
+负责人
+协作者
标签
bug
未设置
标签管理
里程碑
未关联里程碑
未关联里程碑
Pull Requests
未关联
未关联
关联的 Pull Requests 被合并后可能会关闭此 issue
分支
未关联
分支 (
-
)
标签 (
-
)
开始日期   -   截止日期
-
置顶选项
不置顶
置顶等级:高
置顶等级:中
置顶等级:低
优先级
不指定
严重
主要
次要
不重要
参与者(2)
Java
1
https://gitee.com/dromara/liteFlow.git
git@gitee.com:dromara/liteFlow.git
dromara
liteFlow
liteFlow
点此查找更多帮助
搜索帮助
Git 命令在线学习
如何在 Gitee 导入 GitHub 仓库
Git 仓库基础操作
企业版和社区版功能对比
SSH 公钥设置
如何处理代码冲突
仓库体积过大,如何减小?
如何找回被删除的仓库数据
Gitee 产品配额说明
GitHub仓库快速导入Gitee及同步更新
什么是 Release(发行版)
将 PHP 项目自动发布到 packagist.org
评论
仓库举报
回到顶部
登录提示
该操作需登录 Gitee 帐号,请先登录后再操作。
立即登录
没有帐号,去注册