Spring Boot Activiti7从零构建企业级审批工作流引擎1. 传统状态字段管理的困境与工作流引擎的价值在传统OA/ERP系统开发中我们经常使用状态字段如status来跟踪业务流程。比如请假审批流程可能会设计这样的状态流转public class LeaveRequest { private Integer status; //0-草稿 1-提交 2-部门审批通过 3-人事归档 4-驳回 }这种实现方式存在明显缺陷硬编码流程逻辑每次流程变更都需要修改代码并重新部署缺乏可视化监控无法直观查看流程当前节点和历史轨迹权限控制复杂需要手动编写不同状态下的操作权限校验扩展性差并行审批、会签等复杂场景实现困难工作流引擎的核心优势对比维度状态字段方式Activiti工作流引擎流程可视化无图形化流程设计器流程变更需改代码修改流程定义文件无需重启历史追踪需自行实现自动记录完整流程历史复杂流程支持实现困难内置并行网关、会签等特性系统耦合度高低流程与业务解耦2. Activiti7核心架构与Spring Boot集成2.1 Activiti7核心服务Activiti7通过六大服务接口提供完整的工作流能力// 流程仓库服务部署、查询流程定义 RepositoryService repositoryService processEngine.getRepositoryService(); // 运行时服务启动、查询流程实例 RuntimeService runtimeService processEngine.getRuntimeService(); // 任务服务查询、办理任务 TaskService taskService processEngine.getTaskService(); // 历史服务查询历史数据 HistoryService historyService processEngine.getHistoryService(); // 表单服务处理动态表单 FormService formService processEngine.getFormService(); // 管理服务系统管理功能 ManagementService managementService processEngine.getManagementService();2.2 Spring Boot集成配置Maven依赖配置dependency groupIdorg.activiti/groupId artifactIdactiviti-spring-boot-starter/artifactId version7.1.0.M6/version /dependency dependency groupIdcom.h2database/groupId artifactIdh2/artifactId scoperuntime/scope /dependencyapplication.yml配置spring: activiti: database-schema-update: true # 自动更新数据库结构 history-level: full # 完整历史记录 check-process-definitions: true # 启动时检查流程定义 async-executor-activate: false # 关闭异步执行器开发环境3. 请假审批流程实战开发3.1 流程定义设计使用Activiti Modeler设计请假审批流程开始事件→ 2.填写请假单→ 3.部门审批→4a.人事归档≤3天4b.总经理审批→ 5.人事归档3天→ 6.结束事件对应的BPMN XML核心部分process idleaveApproval name请假审批流程 startEvent idstartEvent/ userTask idfillLeave name填写请假单 activiti:assignee${applicant}/ userTask iddeptApprove name部门经理审批 activiti:candidateGroupsdeptManager/ exclusiveGateway iddecisionGateway/ sequenceFlow idflow1 sourceRefstartEvent targetReffillLeave/ sequenceFlow idflow2 sourceReffillLeave targetRefdeptApprove/ sequenceFlow idflow3 sourceRefdeptApprove targetRefdecisionGateway/ sequenceFlow idflow4 sourceRefdecisionGateway targetRefhrArchive conditionExpression xsi:typetFormalExpression ${days 3} /conditionExpression /sequenceFlow sequenceFlow idflow5 sourceRefdecisionGateway targetRefceoApprove conditionExpression xsi:typetFormalExpression ${days 3} /conditionExpression /sequenceFlow userTask idceoApprove name总经理审批 activiti:candidateGroupsceo/ sequenceFlow idflow6 sourceRefceoApprove targetRefhrArchive/ userTask idhrArchive name人事归档 activiti:candidateGroupshr/ sequenceFlow idflow7 sourceRefhrArchive targetRefendEvent/ endEvent idendEvent/ /process3.2 流程部署与启动部署流程定义Service public class ProcessDeployer { Autowired private RepositoryService repositoryService; public void deployProcess() { Deployment deployment repositoryService.createDeployment() .addClasspathResource(processes/leave-approval.bpmn20.xml) .name(请假审批流程) .deploy(); logger.info(流程部署成功ID: {}, deployment.getId()); } }启动流程实例public class LeaveService { Autowired private RuntimeService runtimeService; public String startLeaveProcess(LeaveDTO leaveDTO) { // 设置流程变量 MapString, Object variables new HashMap(); variables.put(days, leaveDTO.getDays()); variables.put(reason, leaveDTO.getReason()); variables.put(applicant, leaveDTO.getApplicant()); // 关联业务Key ProcessInstance instance runtimeService.startProcessInstanceByKey( leaveApproval, leaveDTO.getLeaveId(), variables ); return instance.getId(); } }3.3 任务处理实现查询待办任务public ListTaskDTO getTasksByUser(String userId, String group) { // 个人任务 ListTask personalTasks taskService.createTaskQuery() .taskAssignee(userId) .list(); // 组任务 ListTask groupTasks taskService.createTaskQuery() .taskCandidateUser(userId) .taskCandidateGroup(group) .list(); return Stream.concat(personalTasks.stream(), groupTasks.stream()) .map(this::convertToDTO) .collect(Collectors.toList()); }办理任务Transactional public void completeTask(String taskId, String userId, boolean approved, String comment) { // 校验任务权限 Task task taskService.createTaskQuery() .taskId(taskId) .taskCandidateOrAssigned(userId) .singleResult(); if (task null) { throw new BusinessException(无权操作该任务); } // 拾取组任务 if (task.getAssignee() null) { taskService.claim(taskId, userId); } // 添加批注 if (StringUtils.isNotBlank(comment)) { taskService.addComment(taskId, task.getProcessInstanceId(), comment); } // 设置审批结果变量 MapString, Object variables new HashMap(); variables.put(approved, approved); // 完成任务 taskService.complete(taskId, variables); }4. 高级特性实现4.1 动态任务分配通过监听器实现动态任务分配public class DeptManagerAssignmentListener implements TaskListener { Override public void notify(DelegateTask delegateTask) { // 从业务系统获取部门经理 String deptId (String) delegateTask.getVariable(deptId); String manager departmentService.getManagerByDept(deptId); // 设置任务负责人 delegateTask.setAssignee(manager); // 设置任务到期时间3个工作日内审批 delegateTask.setDueDate(DateUtils.addBusinessDays(new Date(), 3)); } }在BPMN中配置userTask iddeptApprove name部门审批 extensionElements activiti:taskListener eventcreate classcom.example.workflow.DeptManagerAssignmentListener/ /extensionElements /userTask4.2 会签实现多人并行会签场景配置userTask idmultiApprove name多部门会签 extensionElements activiti:multiInstanceLoopCharacteristics isSequentialfalse activiti:collection${approvers} activiti:elementVariableapprover activiti:completionCondition ${nrOfCompletedInstances/nrOfInstances 0.6} /activiti:completionCondition /activiti:multiInstanceLoopCharacteristics /extensionElements /userTask4.3 业务关联与历史查询业务关联查询public LeaveVO getLeaveWithProcess(String leaveId) { // 查询业务数据 Leave leave leaveRepository.findById(leaveId); // 查询关联的流程实例 ProcessInstance instance runtimeService.createProcessInstanceQuery() .processInstanceBusinessKey(leaveId) .singleResult(); // 查询审批历史 ListComment comments taskService.getProcessInstanceComments(instance.getId()); return assembleVO(leave, instance, comments); }历史流程查询public ListHistoricProcessInstance getFinishedProcesses(String applicant) { return historyService.createHistoricProcessInstanceQuery() .processDefinitionKey(leaveApproval) .variableValueEquals(applicant, applicant) .finished() .orderByProcessInstanceEndTime().desc() .list(); }5. 生产环境最佳实践5.1 性能优化方案数据库优化-- 创建常用查询索引 CREATE INDEX idx_act_ru_task_procinst ON act_ru_task(proc_inst_id_); CREATE INDEX idx_act_ru_execution_parent ON act_ru_execution(parent_id_);异步任务配置spring: activiti: async-executor-activate: true async-executor-thread-pool-size: 10 async-failed-job-wait-time: 300 # 失败重试间隔(秒)5.2 监控与运维Spring Boot Actuator端点/actuator/activiti # 流程引擎状态 /actuator/processes # 流程定义列表 /actuator/tasks # 运行中任务统计自定义监控看板RestController RequestMapping(/monitor) public class WorkflowMonitorController { GetMapping(/stats) public WorkflowStats getStats() { long running runtimeService.createProcessInstanceQuery().count(); long completed historyService.createHistoricProcessInstanceQuery() .finished().count(); return new WorkflowStats(running, completed); } }5.3 异常处理策略常见异常处理ControllerAdvice public class WorkflowExceptionHandler { ExceptionHandler(ActivitiObjectNotFoundException.class) public ResponseEntityString handleNotFound(ActivitiObjectNotFoundException ex) { return ResponseEntity.status(404).body(流程资源不存在); } ExceptionHandler(ActivitiTaskAlreadyClaimedException.class) public ResponseEntityString handleTaskClaimed(ActivitiTaskAlreadyClaimedException ex) { return ResponseEntity.status(409).body(任务已被他人领取); } }事务边界控制Transactional(propagation Propagation.REQUIRES_NEW) public void completeTaskWithTransaction(String taskId) { // 任务操作与业务更新放在同一事务 taskService.complete(taskId); businessService.updateStatus(taskId); }6. 扩展与集成方案6.1 与消息系统集成审批通知实现public class TaskNotificationListener implements TaskListener { Autowired private MessageQueueProducer messageProducer; Override public void notify(DelegateTask delegateTask) { TaskNotificationMessage message new TaskNotificationMessage( delegateTask.getId(), delegateTask.getName(), delegateTask.getAssignee() ); messageProducer.send(task.notification, message); } }6.2 与规则引擎集成public class ApprovalRuleEvaluator { Autowired private KieContainer kieContainer; public boolean evaluate(LeaveRequest request) { KieSession kieSession kieContainer.newKieSession(); kieSession.insert(request); kieSession.fireAllRules(); return request.isApproved(); } }6.3 微服务架构下的实现跨服务流程调用FeignClient(name hr-service) public interface HRServiceClient { PostMapping(/leave/approve) void approveLeave(RequestBody ApproveDTO dto); } public class HRTaskListener implements JavaDelegate { Autowired private HRServiceClient hrClient; Override public void execute(DelegateExecution execution) { String leaveId (String) execution.getVariable(leaveId); boolean approved (boolean) execution.getVariable(approved); hrClient.approveLeave(new ApproveDTO(leaveId, approved)); } }在实际项目中引入工作流引擎后某企业的请假审批流程平均处理时间从原来的3.2天缩短到1.5天流程异常率下降68%。特别是在应对突发性流程变更时开发团队不再需要频繁发布系统更新只需通过调整流程定义即可快速响应业务变化。