1. Activiti工作流引擎概述Activiti是一个轻量级的开源工作流引擎基于BPMN 2.0标准实现。作为Alfresco软件公司在2010年推出的产品它已经成为Java领域最受欢迎的工作流解决方案之一。工作流引擎的核心价值在于将业务流程从应用程序代码中抽离出来实现业务逻辑与流程控制的解耦。在实际项目中我们经常遇到需要处理复杂审批流程的场景。比如员工请假申请需要经过部门经理、HR、财务等多级审批传统硬编码方式会导致流程变更时需要修改代码并重新部署。而使用Activiti我们只需要修改流程定义文件无需改动业务代码。2. 环境搭建与基础配置2.1 开发环境准备建议使用以下技术栈组合JDK 1.8Spring Boot 2.7.xActiviti 7.1.0.M6当前最新稳定版MySQL 5.7/PostgreSQLMaven依赖配置示例dependency groupIdorg.activiti/groupId artifactIdactiviti-spring-boot-starter/artifactId version7.1.0.M6/version /dependency2.2 数据库初始化Activiti默认会创建23张表主要分为以下几类通用数据表ACT_GE_*流程定义表ACT_RE_*运行时数据表ACT_RU_*历史数据表ACT_HI_*身份认证表ACT_ID_*建议的MySQL配置参数spring.datasource.urljdbc:mysql://localhost:3306/activiti?useSSLfalseserverTimezoneUTCcharacterEncodingUTF-8 spring.datasource.usernameroot spring.datasource.password123456 spring.datasource.driver-class-namecom.mysql.cj.jdbc.Driver # Activiti配置 activiti.database-schema-updatetrue activiti.async-executor-activatetrue3. 核心概念与流程设计3.1 BPMN 2.0基础元素事件(Event)开始事件NoneStartEvent, TimerStartEvent结束事件NoneEndEvent, TerminateEndEvent边界事件ErrorBoundaryEvent网关(Gateway)排他网关(Exclusive Gateway)并行网关(Parallel Gateway)包容网关(Inclusive Gateway)任务(Task)用户任务(User Task)服务任务(Service Task)脚本任务(Script Task)3.2 流程设计器使用推荐使用Eclipse插件或在线工具bpmn.io设计流程用户任务配置要点Assignee固定分配人Candidate Users候选人Candidate Groups候选组Due Date任务期限服务任务实现方式public class MyJavaDelegate implements JavaDelegate { Override public void execute(DelegateExecution execution) { // 获取流程变量 String businessKey execution.getProcessInstanceBusinessKey(); // 业务处理逻辑 } }4. 高级特性与实战技巧4.1 动态流程处理运行时任务分配taskService.setAssignee(taskId, userId); taskService.addCandidateUser(taskId, userId);流程变量管理// 设置变量 runtimeService.setVariable(executionId, varName, value); // 获取变量 Object value runtimeService.getVariable(executionId, varName);4.2 异步处理优化配置异步执行器提升性能activiti.async-executor-activatetrue activiti.async-executor-core-pool-size10 activiti.async-executor-max-pool-size20 activiti.async-executor-queue-size1004.3 历史数据归档对于高频使用的系统建议配置历史数据清理策略bean idprocessEngineConfiguration classorg.activiti.spring.SpringProcessEngineConfiguration property namehistory valueaudit/ property namehistoryCleaningTimeCycleConfig value0 0 1 * * ?/ /bean5. 常见问题解决方案5.1 流程版本控制当需要更新已部署的流程时修改BPMN文件后重新部署会自动生成新版本旧流程实例继续使用原版本新发起的流程实例使用最新版本5.2 事务管理关键配置项Transactional public void startProcess() { // 启动流程和业务操作要在同一事务中 runtimeService.startProcessInstanceByKey(myProcess); businessService.doBusinessOperation(); }5.3 性能优化建议避免在循环中操作流程引擎API批量操作使用Batch API合理设置历史级别建议audit定期清理历史数据6. 实际案例请假审批流程6.1 流程定义示例process idleaveApproval name请假审批流程 startEvent idstart/ userTask iddeptLeaderAudit name部门领导审批 extensionElements activiti:formProperty idcomment name审批意见 typestring/ /extensionElements /userTask exclusiveGateway iddecision/ sequenceFlow sourceRefdecision targetRefhrAudit conditionExpression xsi:typetFormalExpression ${days 3} /conditionExpression /sequenceFlow endEvent idend/ /process6.2 流程启动代码MapString, Object variables new HashMap(); variables.put(applicant, userId); variables.put(days, leaveDays); ProcessInstance instance runtimeService.startProcessInstanceByKey( leaveApproval, businessKey, variables);6.3 审批处理代码// 查询待办任务 ListTask tasks taskService.createTaskQuery() .taskCandidateOrAssigned(userId) .processDefinitionKey(leaveApproval) .list(); // 完成任务 MapString, Object taskVars new HashMap(); taskVars.put(approved, true); taskService.complete(taskId, taskVars);7. 监控与管理7.1 流程实例监控// 查询运行中流程 ListProcessInstance instances runtimeService.createProcessInstanceQuery() .processDefinitionKey(leaveApproval) .active() .list(); // 获取活动节点 ListActivityInstance activities runtimeService .getActivityInstance(processInstanceId);7.2 使用Actuator端点Spring Boot集成后提供的监控端点/actuator/activiti流程定义信息/actuator/activiti/jobs作业队列情况8. 最佳实践与经验分享流程设计原则保持单个流程不超过15个节点复杂逻辑尽量用网关拆分关键节点添加监听器记录日志异常处理技巧// 添加边界事件捕获异常 boundaryEvent iderrorBoundary attachedToRefserviceTask errorEventDefinition errorRefbizError/ /boundaryEvent性能测试建议使用JMeter模拟并发流程启动监控数据库连接池使用情况关注ACT_RU_*表的增长趋势与微服务集成// 在服务任务中调用FeignClient serviceTask idcallRemote activiti:classorg.activiti.engine.impl.bpmn.behavior.WebServiceActivityBehavior extensionElements activiti:field namewsdl activiti:string${remoteWsdl}/activiti:string /activiti:field /extensionElements /serviceTask在实际项目中使用Activiti时建议从简单流程开始逐步深入。特别注意流程版本管理和历史数据清理策略的规划这两个问题在系统运行后期最容易引发问题。对于高并发场景一定要充分测试异步执行器的配置参数。
1. Activiti工作流引擎概述Activiti是一个轻量级的开源工作流引擎基于BPMN 2.0标准实现。作为Alfresco软件公司在2010年推出的产品它已经成为Java领域最受欢迎的工作流解决方案之一。工作流引擎的核心价值在于将业务流程从应用程序代码中抽离出来实现业务逻辑与流程控制的解耦。在实际项目中我们经常遇到需要处理复杂审批流程的场景。比如员工请假申请需要经过部门经理、HR、财务等多级审批传统硬编码方式会导致流程变更时需要修改代码并重新部署。而使用Activiti我们只需要修改流程定义文件无需改动业务代码。2. 环境搭建与基础配置2.1 开发环境准备建议使用以下技术栈组合JDK 1.8Spring Boot 2.7.xActiviti 7.1.0.M6当前最新稳定版MySQL 5.7/PostgreSQLMaven依赖配置示例dependency groupIdorg.activiti/groupId artifactIdactiviti-spring-boot-starter/artifactId version7.1.0.M6/version /dependency2.2 数据库初始化Activiti默认会创建23张表主要分为以下几类通用数据表ACT_GE_*流程定义表ACT_RE_*运行时数据表ACT_RU_*历史数据表ACT_HI_*身份认证表ACT_ID_*建议的MySQL配置参数spring.datasource.urljdbc:mysql://localhost:3306/activiti?useSSLfalseserverTimezoneUTCcharacterEncodingUTF-8 spring.datasource.usernameroot spring.datasource.password123456 spring.datasource.driver-class-namecom.mysql.cj.jdbc.Driver # Activiti配置 activiti.database-schema-updatetrue activiti.async-executor-activatetrue3. 核心概念与流程设计3.1 BPMN 2.0基础元素事件(Event)开始事件NoneStartEvent, TimerStartEvent结束事件NoneEndEvent, TerminateEndEvent边界事件ErrorBoundaryEvent网关(Gateway)排他网关(Exclusive Gateway)并行网关(Parallel Gateway)包容网关(Inclusive Gateway)任务(Task)用户任务(User Task)服务任务(Service Task)脚本任务(Script Task)3.2 流程设计器使用推荐使用Eclipse插件或在线工具bpmn.io设计流程用户任务配置要点Assignee固定分配人Candidate Users候选人Candidate Groups候选组Due Date任务期限服务任务实现方式public class MyJavaDelegate implements JavaDelegate { Override public void execute(DelegateExecution execution) { // 获取流程变量 String businessKey execution.getProcessInstanceBusinessKey(); // 业务处理逻辑 } }4. 高级特性与实战技巧4.1 动态流程处理运行时任务分配taskService.setAssignee(taskId, userId); taskService.addCandidateUser(taskId, userId);流程变量管理// 设置变量 runtimeService.setVariable(executionId, varName, value); // 获取变量 Object value runtimeService.getVariable(executionId, varName);4.2 异步处理优化配置异步执行器提升性能activiti.async-executor-activatetrue activiti.async-executor-core-pool-size10 activiti.async-executor-max-pool-size20 activiti.async-executor-queue-size1004.3 历史数据归档对于高频使用的系统建议配置历史数据清理策略bean idprocessEngineConfiguration classorg.activiti.spring.SpringProcessEngineConfiguration property namehistory valueaudit/ property namehistoryCleaningTimeCycleConfig value0 0 1 * * ?/ /bean5. 常见问题解决方案5.1 流程版本控制当需要更新已部署的流程时修改BPMN文件后重新部署会自动生成新版本旧流程实例继续使用原版本新发起的流程实例使用最新版本5.2 事务管理关键配置项Transactional public void startProcess() { // 启动流程和业务操作要在同一事务中 runtimeService.startProcessInstanceByKey(myProcess); businessService.doBusinessOperation(); }5.3 性能优化建议避免在循环中操作流程引擎API批量操作使用Batch API合理设置历史级别建议audit定期清理历史数据6. 实际案例请假审批流程6.1 流程定义示例process idleaveApproval name请假审批流程 startEvent idstart/ userTask iddeptLeaderAudit name部门领导审批 extensionElements activiti:formProperty idcomment name审批意见 typestring/ /extensionElements /userTask exclusiveGateway iddecision/ sequenceFlow sourceRefdecision targetRefhrAudit conditionExpression xsi:typetFormalExpression ${days 3} /conditionExpression /sequenceFlow endEvent idend/ /process6.2 流程启动代码MapString, Object variables new HashMap(); variables.put(applicant, userId); variables.put(days, leaveDays); ProcessInstance instance runtimeService.startProcessInstanceByKey( leaveApproval, businessKey, variables);6.3 审批处理代码// 查询待办任务 ListTask tasks taskService.createTaskQuery() .taskCandidateOrAssigned(userId) .processDefinitionKey(leaveApproval) .list(); // 完成任务 MapString, Object taskVars new HashMap(); taskVars.put(approved, true); taskService.complete(taskId, taskVars);7. 监控与管理7.1 流程实例监控// 查询运行中流程 ListProcessInstance instances runtimeService.createProcessInstanceQuery() .processDefinitionKey(leaveApproval) .active() .list(); // 获取活动节点 ListActivityInstance activities runtimeService .getActivityInstance(processInstanceId);7.2 使用Actuator端点Spring Boot集成后提供的监控端点/actuator/activiti流程定义信息/actuator/activiti/jobs作业队列情况8. 最佳实践与经验分享流程设计原则保持单个流程不超过15个节点复杂逻辑尽量用网关拆分关键节点添加监听器记录日志异常处理技巧// 添加边界事件捕获异常 boundaryEvent iderrorBoundary attachedToRefserviceTask errorEventDefinition errorRefbizError/ /boundaryEvent性能测试建议使用JMeter模拟并发流程启动监控数据库连接池使用情况关注ACT_RU_*表的增长趋势与微服务集成// 在服务任务中调用FeignClient serviceTask idcallRemote activiti:classorg.activiti.engine.impl.bpmn.behavior.WebServiceActivityBehavior extensionElements activiti:field namewsdl activiti:string${remoteWsdl}/activiti:string /activiti:field /extensionElements /serviceTask在实际项目中使用Activiti时建议从简单流程开始逐步深入。特别注意流程版本管理和历史数据清理策略的规划这两个问题在系统运行后期最容易引发问题。对于高并发场景一定要充分测试异步执行器的配置参数。
