CGraph框架中复杂流程控制的设计与实现

引言

在现代软件开发中，复杂流程控制是一个常见需求。本文将以CGraph框架为基础，探讨如何实现一个包含条件判断、循环执行和事件触发的复杂业务流程。我们将分析一个典型场景，并介绍如何使用CGraph提供的各种机制来构建这样的流程。

业务场景分析

我们需要实现的业务流程具有以下特点：

1. 主流程控制：A→B→C的序列执行，其中C的执行次数在1-30次之间随机变化
2. 循环机制：A→B→C的循环需要重复1-10次
3. 嵌套循环：B→C的循环本身需要重复5次
4. 异常处理：A、B、C执行过程中可能跳转到D
5. 事件触发：D执行过程中，当E标志为1时需要执行E
6. 最终处理：所有循环结束后执行F

CGraph解决方案

1. 主流程控制实现

对于A→B→C的主流程，我们可以使用CGraph的GPipeline来构建基本执行序列：

GPipelinePtr pipeline = new GPipeline();
pipeline->registerGElement<ANode>(nullptr);
pipeline->registerGElement<BNode>({ANode});
pipeline->registerGElement<CNode>({BNode});

2. 循环机制实现

CGraph提供了两种实现循环的方式：

方式一：使用isHold机制

通过设置节点的isHold属性，可以让节点在特定条件下保持执行状态：

class CNode : public GNode {
protected:
    int count = 0;
    int maxCount = random(1, 30);    // 随机1-30次
    
    CSTATUS run() override {
        count++;
        if (count >= maxCount) {
            setLoop(false);    // 退出循环
        }
        return STATUS_OK;
    }
};

方式二：使用setLoop方法

对于固定次数的循环，可以直接设置循环次数：

pipeline->setLoop(10);    // 主循环10次

3. 条件等待实现

对于需要等待特定标志的场景，可以使用GMessage机制：

// 在A节点中等待B标志
class ANode : public GNode {
    CSTATUS run() override {
        while (!GMessageParam::get("BFlag")) {
            std::this_thread::sleep_for(std::chrono::milliseconds(100));
        }
        return STATUS_OK;
    }
};

// 在B节点中设置标志
class BNode : public GNode {
    CSTATUS run() override {
        GMessageParam::set("BFlag", true);
        return STATUS_OK;
    }
};

4. 异常跳转实现

对于A、B、C执行过程中跳转到D的需求，可以使用GEvent机制：

// 注册事件
pipeline->registerGEvent<DEvent>({ANode, BNode, CNode});

// 在节点中触发事件
class ANode : public GNode {
    CSTATUS run() override {
        if (needJumpToD) {
            GEventParam::trigger("JumpToD");
        }
        return STATUS_OK;
    }
};

5. 条件触发实现

对于D执行过程中需要条件触发E的场景：

class DNode : public GNode {
    CSTATUS run() override {
        // D的正常处理逻辑
        
        if (GMessageParam::get("EFlag") == 1) {
            GEventParam::trigger("ExecuteE");
        }
        return STATUS_OK;
    }
};

// 注册E事件
pipeline->registerGEvent<EEvent>({DNode});

完整架构设计

基于以上分析，我们可以设计如下架构：

1. 主流程层：负责A→B→C的主线控制
2. 循环控制层：通过isHold和setLoop实现各种循环
3. 消息通信层：使用GMessage实现节点间的标志传递
4. 事件处理层：通过GEvent实现异常跳转和条件触发
5. 监控层：可以添加监控节点观察流程执行状态

实现建议

1. 模块化设计：将复杂逻辑分解到不同节点中
2. 状态持久化：对于循环计数等状态需要持久化保存
3. 超时处理：为等待操作添加超时机制
4. 日志记录：详细记录流程执行情况便于调试
5. 可视化验证：使用dump功能验证流程是否符合预期

总结

通过合理运用CGraph提供的各种机制，我们可以构建出复杂的业务流程控制系统。关键在于：

1. 清晰划分业务流程的各个阶段
2. 选择合适的控制机制（消息、事件、循环等）
3. 保持各模块间的松耦合
4. 完善的错误处理和状态监控

这种设计模式不仅适用于当前场景，也可以推广到其他类似的复杂流程控制需求中。CGraph框架提供的丰富功能为这类需求提供了灵活而强大的解决方案。