企业官网建设流程全解析

Flowable实战：动态获取下一节点信息与候选人的高阶技巧

在流程引擎开发中，动态展示下一环节信息是提升用户体验的关键需求。想象这样一个场景：当员工提交请假申请后，系统需要实时显示"下一审批人：部门经理张伟"；或者当报销流程进入会签环节时，界面需要展示"待5位财务专员并行审批"。这类需求看似简单，但Flowable原生API并未提供直接获取下一节点信息的接口，这正是许多开发者遇到的痛点。

1. 核心问题分析与基础实现

1.1 为什么需要动态获取下一节点

传统流程开发中，节点跳转逻辑通常硬编码在系统里。但随着业务复杂度提升，这种做法的弊端日益明显：

• 无法适应流程变更：当审批链调整时，需要重新修改代码部署
• 缺乏实时性：无法根据运行时变量动态决定分支路径
• 用户体验差：用户无法预知下一步操作对象

通过分析BpmnModel结构，我们可以实现动态节点追踪。以下是基础实现的关键步骤：

public NextNodeInfo getNextNodeInfo(String taskId) { // 获取当前任务 Task task = taskService.createTaskQuery().taskId(taskId).singleResult(); // 获取流程定义模型 BpmnModel bpmnModel = repositoryService.getBpmnModel( runtimeService.createProcessInstanceQuery() .processInstanceId(task.getProcessInstanceId()) .singleResult() .getProcessDefinitionId() ); // 获取当前节点元素 FlowNode currentNode = (FlowNode) bpmnModel.getFlowElement(task.getTaskDefinitionKey()); // 初始化返回对象 NextNodeInfo info = new NextNodeInfo(); info.setCurrentNodeName(currentNode.getName()); // 处理输出连线 processOutgoingFlows(currentNode.getOutgoingFlows(), info); return info; }

1.2 基础节点信息提取

对于简单的线性流程，获取下一节点相对直接：

1. 通过taskService查询当前任务
2. 获取关联的流程定义ID
3. 从RepositoryService加载BpmnModel
4. 遍历当前节点的outgoingFlows

关键数据结构示例：

2. 复杂场景处理：会签与网关

2.1 会签(多实例)节点解析

会签节点的特殊之处在于它的并行特性，需要额外处理循环集合表达式。以下是识别和处理会签节点的关键代码：

private void processUserTask(FlowElement element, NextNodeInfo info) { UserTask userTask = (UserTask) element; // 检查是否多实例 if (userTask.getLoopCharacteristics() != null) { info.setMultiInstance(true); info.setCollectionExpression( userTask.getLoopCharacteristics() .getInputDataItem() ); // 解析候选人集合 if (userTask.getAssignee() != null) { String assigneeExpression = userTask.getAssignee(); // 这里需要结合运行时变量解析实际候选人 List<String> candidates = resolveCollectionExpression( assigneeExpression, runtimeVariables ); info.setCandidateUsers(candidates); } } else { // 普通用户任务处理 info.setCandidateUsers( userTask.getCandidateUsers() ); } }

会签节点处理要点：

• 集合表达式解析：如${departmentMembers}需要转换为实际用户列表
• 完成条件计算：需要检查completionCondition表达式
• 基数确定：通过loopCardinality或集合大小确定实例数量

2.2 排他网关路径选择

排他网关的核心挑战在于条件表达式的动态计算。我们需要：

1. 收集当前流程所有变量
2. 评估每条出线的条件表达式
3. 确定实际会走的分支路径

private SequenceFlow evaluateGateway(ExclusiveGateway gateway, Map<String, Object> variables) { for (SequenceFlow flow : gateway.getOutgoingFlows()) { if (flow.getConditionExpression() == null) { return flow; // 默认路径 } try { Boolean result = (Boolean) expressionManager .createExpression(flow.getConditionExpression()) .getValue(variables); if (result != null && result) { return flow; } } catch (Exception e) { log.warn("条件表达式计算失败: {}", flow.getConditionExpression(), e); } } throw new FlowableException("没有符合条件的路径"); }

常见问题处理方案：

3. 高级技巧与性能优化

3.1 缓存策略设计

频繁访问流程定义模型会影响性能，合理的缓存策略至关重要：

public class BpmnModelCache { private static final Cache<String, BpmnModel> cache = Caffeine.newBuilder() .maximumSize(1000) .expireAfterWrite(1, TimeUnit.HOURS) .build(); public BpmnModel getModel(String processDefinitionId) { return cache.get(processDefinitionId, id -> repositoryService.getBpmnModel(id) ); } }

缓存设计考虑因素：

• 失效时机：流程定义更新时需要清除缓存
• 内存占用：控制缓存大小避免OOM
• 集群同步：分布式环境下需要同步各节点缓存

3.2 表达式解析优化

表达式解析是性能瓶颈之一，可以采用以下优化手段：

1. 预编译表达式：对固定表达式提前编译
2. 变量白名单：限制可访问的变量范围
3. 安全沙箱：防止恶意表达式执行

优化前后性能对比：

4. 完整工具类实现

4.1 核心工具类设计

将上述功能封装为可复用的工具类：

public class FlowableNodeUtil { private final RuntimeService runtimeService; private final TaskService taskService; private final RepositoryService repositoryService; private final ExpressionManager expressionManager; public NextNodeInfo getNextNodeInfo(String taskId) { // 实现细节参考前文... } private void processOutgoingFlows(List<SequenceFlow> flows, NextNodeInfo info) { // 处理各种节点类型分支... } // 内部类定义返回值结构 @Data public static class NextNodeInfo { private String currentNodeName; private String nextNodeName; private NodeType nextNodeType; private List<String> candidateUsers; private boolean multiInstance; private String collectionExpression; } }

4.2 异常处理与日志

完善的异常处理机制应包括：

• FlowableException：流程引擎原生异常
• NodeNotFoundException：无法定位节点
• ExpressionEvaluationException：表达式计算错误

日志记录要点：

@Slf4j public class FlowableNodeUtil { public NextNodeInfo getNextNodeInfo(String taskId) { try { // 业务逻辑... } catch (FlowableObjectNotFoundException e) { log.error("流程定义不存在: {}", taskId, e); throw new BusinessException("流程定义已失效"); } catch (Exception e) { log.error("获取下一节点异常: {}", taskId, e); throw new BusinessException("系统处理流程时出错"); } } }

在实际项目中使用时，我发现最常遇到的坑是会签节点的候选人解析。有一次因为忘记处理集合表达式中的SpEL语法，导致系统在生产环境显示了原始的${approvers}表达式而不是实际审批人列表。这个教训让我在工具类中特别加强了表达式处理的健壮性。