皮皮网

1.Golang框架实战-KisFlow流式计算框架(8)-KisFlow Action

Golang框架实战-KisFlow流式计算框架(8)-KisFlow Action

       KisFlow是一个流式计算框架，旨在提供简单易用的API，帮助开发者快速构建和部署流式计算应用。本文将详细介绍KisFlow中的Action模块，特别是Abort、DataReuse和ForceEntryNext等关键Action的最牛轰炸全开源源码实现和使用方式。

       ### Abort Action

       Abort Action允许开发者在执行Function时终止当前Flow的计算流程。Abort的实现依赖于一个名为AbortFuncHandler的业务回调方法。在该方法中，通过传递`flow.Next(kis.ActionAbort)`作为函数返回值，可以立即终止当前Flow的调度，从而避免执行后续的Function。

       ### Action模块定义

       为了实现Abort功能，首先定义了`Abort`接口，并在`action.go`文件中实现了Abort行为。Abort行为通过设置Action的`Abort`成员变量为`true`来表示终止流程。此外，106源码网定义了`ActionFunc`函数类型，用于传递给KisFlow执行特定的Action动作。最后，实现了`LoadActions`方法，用于加载和组合多个Action动作。

       ### Next方法实现

       `Next`方法是KisFlow的核心接口，用于在执行完一个Function后决定是否继续执行下一个Function。通过在`kis_flow.go`文件中添加Action成员和实现`Next`接口，解毒助手源码开发者可以在自定义业务回调中调用`flow.Next(kis.ActionAbort)`来终止流程。

       ### Abort控制Flow流程

       在`kis_flow.go`文件中，添加了一个成员变量`abort`来控制是否终止流程。在`Run`方法中，初始化并检查`abort`状态。在循环调度过程中，通过判断`abort`变量，可以选择性地跳过当前Function的dt源码模板执行，从而终止整个Flow的计算流程。同时，改进了流程以确保即使当前Function未提交数据（`flow.buffer`为空），也不会继续执行下一层Function。

       ### Action捕获及处理

       创建了一个专门处理Action动作的方法`dealAction`，该方法在`kis_flow_action.go`文件中实现。通过集成`dealAction`到`Run`流程中，可以确保在执行完特定Action（如Abort）后，btc分析源码立即停止Flow的运行。

       ### Action Abort单元测试

       为了验证Abort Action的正确性，设计了一个名为`abortFunc`的Function，并配置了相应的测试用例。通过`kis_action_test.go`文件中的测试代码，可以验证在执行Abort Action后，Flow确实会终止，而不会继续执行下一个Function。

       ### Action DataReuse

       DataReuse Action允许当前Function的结果直接复用至上一层Function的结果，作为下一层Function的输入。实现该功能涉及修改Action接口、提供复用数据的方法，并在`dealAction`中捕获并处理DataReuse Action。

       ### Action ForceEntryNext

       ForceEntryNext Action提供了一种机制，在当前Function未提交数据的情况下，强制执行下一层Function。实现该功能时需要注意，确保即使没有数据提交，也能正确地执行下一层Function。此外，包含了一个专门的测试用例，验证在不设置ForceEntryNext的情况下，Function的正常行为。

       ### Action JumpFunc

       JumpFunc Action允许在Flow中跳转到指定的Function继续执行。实现时，需要谨慎考虑潜在的无限循环风险。通过在`kis_flow_action.go`文件中捕获JumpFunc Action，并根据JumpFunc的值调整下次执行的Function指针，实现了该功能。同样，包含了一个测试用例来验证JumpFunc的正确性。

       ### 源代码

       KisFlow的源代码可访问以下链接：[KisFlow开源项目地址](github.com/aceld/kis-fl...)