Flowable实战：从BPMN画图到Spring Boot集成，一个请假审批系统的保姆级搭建教程
Flowable实战：构建企业级请假审批系统的全流程指南
在数字化转型浪潮中，工作流引擎已成为企业应用的核心基础设施。作为Activiti的下一代产品，Flowable凭借其轻量级架构和强大的BPMN 2.0支持，正在成为Java开发者构建审批系统的首选方案。本文将带您从零开始，通过一个完整的请假审批系统案例，掌握Flowable与Spring Boot的深度整合技巧。
1. 环境准备与BPMN设计
1.1 开发环境配置
开始前需确保具备以下环境：
- JDK 11+（推荐Amazon Corretto）
- IntelliJ IDEA 2023+（社区版即可）
- Maven 3.8+
- MySQL 8.0或PostgreSQL 14
创建Spring Boot项目时添加关键依赖：
<dependency> <groupId>org.flowable</groupId> <artifactId>flowable-spring-boot-starter</artifactId> <version>6.7.2</version> </dependency> <dependency> <groupId>com.h2database</groupId> <artifactId>h2</artifactId> <scope>runtime</scope> </dependency>提示：生产环境建议使用MySQL而非H2，需额外配置数据源
1.2 BPMN流程图设计
安装Flowable BPMN插件后，创建leave-approval.bpmn20.xml文件。典型请假审批流程应包含：
- 开始事件：空启动事件
- 用户任务：提交申请、部门审批、HR备案
- 排他网关：处理审批结果分支
- 结束事件：审批通过/拒绝
关键属性配置示例：
<userTask id="deptApproval" name="部门审批" flowable:assignee="${deptLeader}"> <extensionElements> <flowable:formProperty id="comment" name="审批意见" type="string"/> </extensionElements> </userTask>2. 流程部署策略对比
Flowable提供多种部署方式，各有适用场景：
| 部署方式 | 适用场景 | 优点 | 缺点 |
|---|---|---|---|
| ClassPath | 固定流程 | 简单可靠 | 需重启更新 |
| 文件流 | 临时测试 | 灵活快速 | 无版本管理 |
| ZIP压缩包 | 批量部署 | 一次多流程 | 需打包步骤 |
| 文本格式 | 动态生成 | 内存操作 | 无校验 |
| 字节数组 | 前端集成 | 高性能 | 内存占用 |
推荐生产环境使用版本化部署：
@GetMapping("/deployWithVersion") public String deployWithVersion() { Deployment deployment = repositoryService.createDeployment() .addClasspathResource("processes/leave.bpmn20.xml") .name("请假流程V2.1") .key("leaveProcess") .category("HR") .deploy(); return "部署成功，版本：" + repositoryService.createProcessDefinitionQuery() .deploymentId(deployment.getId()) .singleResult() .getVersion(); }3. 流程实例的智能启动
3.1 参数化启动优化
带参启动时可嵌入业务逻辑校验：
public ProcessInstance startProcessWithValidation(String processKey, Map<String, Object> variables) { // 验证请假天数 Integer days = (Integer)variables.get("leaveDays"); if(days > 30) { throw new IllegalArgumentException("请假超过30天需特殊审批"); } // 自动计算审批路径 if(days > 5) { variables.put("needHrApproval", true); } return runtimeService.startProcessInstanceByKey( processKey, variables ); }3.2 动态任务分配
通过监听器实现灵活的任务分配：
public class DynamicAssigneeListener implements TaskListener { @Override public void notify(DelegateTask task) { String eventName = task.getEventName(); if(EVENTNAME_CREATE.equals(eventName)) { String dept = (String)task.getVariable("department"); String leader = orgService.queryLeaderByDept(dept); task.setAssignee(leader); } } }在BPMN中配置：
<userTask id="deptApproval" name="部门审批"> <extensionElements> <flowable:taskListener event="create" class="com.example.DynamicAssigneeListener"/> </extensionElements> </userTask>4. 审批功能进阶实现
4.1 多维度任务查询
构建高效的任务查询接口：
public PageInfo<TaskVO> queryTasks(TaskQueryDTO query) { TaskQuery taskQuery = taskService.createTaskQuery() .taskCandidateOrAssigned(query.getUserId()) .orderByTaskCreateTime().desc(); if(StringUtils.isNotBlank(query.getProcessKey())) { taskQuery.processDefinitionKey(query.getProcessKey()); } if(query.getDueDate() != null) { taskQuery.taskDueBefore(query.getDueDate()); } List<Task> tasks = taskQuery.listPage( query.getPageNum() - 1, query.getPageSize() ); return new PageInfo<>(tasks.stream() .map(this::convertToVO) .collect(Collectors.toList())); }4.2 审批链设计模式
实现多级审批的优雅方案：
public void completeWithChain(String taskId, Map<String, Object> variables) { Task currentTask = taskService.createTaskQuery() .taskId(taskId).singleResult(); // 基础审批逻辑 taskService.complete(taskId, variables); // 判断是否需要下一级审批 Boolean needNextLevel = (Boolean)variables.get("needNextLevel"); if(needNextLevel != null && needNextLevel) { String nextAssignee = calculateNextApprover( currentTask.getProcessInstanceId() ); Task nextTask = taskService.createTaskQuery() .processInstanceId(currentTask.getProcessInstanceId()) .singleResult(); taskService.setAssignee(nextTask.getId(), nextAssignee); } }5. 流程可视化与监控
5.1 动态流程图生成
增强版的流程图生成方法：
@GetMapping("/processDiagram") public void generateDiagram(HttpServletResponse response, @RequestParam String processInstanceId) throws IOException { // 获取高亮节点 List<String> activeActivities = runtimeService.getActiveActivityIds(processInstanceId); // 获取历史路径 List<String> highLightedFlows = historyService.createHistoricActivityInstanceQuery() .processInstanceId(processInstanceId) .orderByHistoricActivityInstanceStartTime().asc() .list() .stream() .map(HistoricActivityInstance::getActivityId) .collect(Collectors.toList()); BpmnModel bpmnModel = repositoryService.getBpmnModel( runtimeService.createProcessInstanceQuery() .processInstanceId(processInstanceId) .singleResult() .getProcessDefinitionId() ); try (InputStream is = processDiagramGenerator.generateDiagram( bpmnModel, "png", activeActivities, highLightedFlows, "宋体", "宋体", "宋体" )) { response.setContentType("image/png"); IOUtils.copy(is, response.getOutputStream()); } }5.2 审批时间线分析
通过历史数据生成审批时间线：
SELECT act.ACT_ID_ as nodeId, act.ACT_NAME_ as nodeName, MIN(act.START_TIME_) as startTime, MAX(act.END_TIME_) as endTime, TIMESTAMPDIFF(SECOND, MIN(act.START_TIME_), MAX(act.END_TIME_)) as duration FROM ACT_HI_ACTINST act WHERE act.PROC_INST_ID_ = #{processInstanceId} GROUP BY act.ACT_ID_, act.ACT_NAME_ ORDER BY MIN(act.START_TIME_)6. 生产环境最佳实践
6.1 性能优化配置
在application.yml中添加关键配置：
flowable: async-executor: activate: true core-pool-size: 10 max-pool-size: 50 queue-size: 1000 database-schema-update: false history-level: audit6.2 异常处理策略
实现全局流程异常处理器：
@ControllerAdvice public class FlowableExceptionHandler { @ExceptionHandler(FlowableException.class) public ResponseEntity<ErrorResponse> handleFlowableException( FlowableException ex) { ErrorResponse error = new ErrorResponse(); error.setTimestamp(LocalDateTime.now()); if(ex instanceof FlowableObjectNotFoundException) { error.setCode("PROCESS_NOT_FOUND"); error.setMessage("流程资源不存在"); return ResponseEntity.status(404).body(error); } // 其他异常处理... } }在项目实践中发现，合理的流程版本管理策略能显著降低维护成本。建议采用语义化版本控制，并在部署时自动归档旧版本流程图。对于复杂的审批场景，可以考虑使用Flowable的DMN决策表来简化网关逻辑。