保姆级教程：在Flowable 6.x中配置调用子流程，实现多实例并行审批
保姆级教程：在Flowable 6.x中配置调用子流程实现多实例并行审批
当企业审批流程需要多个部门负责人同时签署意见时，传统的串行审批会导致效率瓶颈。Flowable的调用子流程配合多实例特性，能像交响乐指挥一样精准协调多个并行审批任务。本文将手把手带您实现一个真实的"部门经理会签"场景，从BPMN绘制到参数传递，彻底掌握这一高频需求。
1. 理解调用子流程的核心机制
调用子流程（Call Activity）是BPMN规范中的标准元素，它允许一个流程实例动态启动另一个独立的流程实例。与嵌套子流程不同，被调用的流程拥有自己的生命周期和实例ID，这种松耦合设计带来了三大独特优势：
- 流程复用：通用审批逻辑（如部门审核）可封装为独立流程，供多个主流程调用
- 并行扩展：通过多实例配置，单次调用可触发多个子流程实例并行运行
- 参数隔离：主流程与子流程通过明确定义的输入输出参数交互，避免变量污染
在采购审批场景中，当需要技术部、财务部、法务部三个部门并行会签时，调用子流程的架构优势尤为明显。主流程只需配置一次调用节点，系统就会自动创建三个独立的审批实例。
2. 构建基础BPMN模型
2.1 主流程设计
使用Flowable Modeler创建主流程purchase_approval，关键节点包括：
<process id="purchase_approval" name="采购审批主流程"> <startEvent id="start"/> <userTask id="initiate" name="发起采购申请"/> <callActivity id="multiDeptSign" name="多部门会签"/> <exclusiveGateway id="decision"/> <userTask id="ceoApprove" name="CEO最终审批"/> <endEvent id="end"/> </process>2.2 子流程设计
新建department_approval作为被调用流程：
<process id="department_approval" name="部门审批子流程"> <startEvent id="subStart"/> <userTask id="deptReview" name="部门负责人审批"> <extensionElements> <flowable:formProperty id="comment" name="审批意见" type="string"/> </extensionElements> </userTask> <endEvent id="subEnd"/> </process>提示：子流程的ID必须与调用配置严格匹配，建议使用全小写+下划线命名规范
3. 配置多实例调用活动
3.1 关键属性设置
在multiDeptSign调用节点配置：
- 被调用元素类型：选择
Key（推荐）或ID - 被调用元素值：填写
department_approval - 多实例类型：选择
Parallel（并行）
3.2 集合与变量配置
| 配置项 | 值示例 | 作用说明 |
|---|---|---|
| 集合(Collection) | ${deptList} | 存储部门ID数组的流程变量 |
| 元素变量 | currentDept | 迭代时存储当前部门ID |
| 完成条件 | ${nrOfCompletedInstances/nrOfInstances >= 0.6} | 60%通过即继续 |
对应的Java代码设置变量：
Map<String, Object> variables = new HashMap<>(); variables.put("deptList", Arrays.asList("dept_tech", "dept_finance", "dept_legal")); runtimeService.startProcessInstanceByKey("purchase_approval", variables);4. 实现参数双向传递
4.1 输入参数映射
将主流程的采购单ID传递给所有子流程实例：
<callActivity id="multiDeptSign" calledElement="department_approval"> <extensionElements> <flowable:in source="purchaseId" target="purchaseId"/> </extensionElements> </callActivity>4.2 输出参数处理
由于并行模式下输出参数受限，推荐两种解决方案：
方案一：使用信号事件
<sequenceFlow id="toSignal" sourceRef="deptReview" targetRef="signalEnd"/> <intermediateThrowEvent id="signalEnd"> <signalEventDefinition signalRef="approvalSignal"/> </intermediateThrowEvent>方案二：服务任务写库
public class ApprovalResultCollector implements JavaDelegate { public void execute(DelegateExecution execution) { String comment = (String) execution.getVariable("comment"); // 写入数据库或消息队列 } }5. 调试与性能优化
5.1 历史数据验证
SELECT * FROM ACT_HI_PROCINST WHERE CALL_PROC_INST_ID_ = '主流程实例ID';5.2 性能优化建议
- 对高频调用的子流程启用
async: true属性 - 在集合变量中使用轻量级ID而非完整对象
- 设置合理的
asyncExecutor线程池大小
我在实际项目中遇到过200+并行实例的场景，通过预加载子流程定义和启用二级缓存，将响应时间从8秒降至1.2秒。关键是在测试环境充分模拟高并发情况，使用FlowableStressTest工具进行基准测试。