在业务系统开发中我们经常需要处理复杂的业务流程例如订单审核、请假审批、数据同步等。这些流程往往涉及多个步骤、多个角色和复杂的流转逻辑。如果将这些逻辑硬编码在业务代码中不仅会导致代码臃肿、难以维护更会在流程变更时引发大规模的代码修改。工作流引擎正是为了解决这类问题而生的利器它允许我们将业务流程可视化地“画”出来并通过引擎驱动其自动执行。本文将围绕工作流的“编辑”与“执行”两大核心环节结合当前流行的开源工作流引擎为你提供一套从零搭建到实战落地的完整指南。1. 工作流核心概念为什么需要它在深入技术细节之前我们首先要理解工作流是什么以及它能为我们解决什么问题。工作流简单来说就是一系列相互衔接、自动进行的业务活动或任务。它将现实世界中的业务流程抽象为计算机可理解的模型这个模型定义了任务的顺序、执行者、条件分支和数据处理规则。核心价值可视化与可维护性流程逻辑不再隐藏在代码的if-else中而是通过流程图BPMN标准清晰展现。业务人员也能理解变更时只需调整流程图无需修改代码。灵活性与敏捷性当业务规则变化时如增加一个审批环节通常只需要在流程设计器中拖拽节点、修改配置即可快速响应大大缩短迭代周期。解耦与复用将流程逻辑从业务系统中剥离形成独立的流程服务。同一套流程引擎可以支撑多个不同的业务模块实现逻辑复用。状态追踪与监控引擎会记录每个流程实例例如某一张具体的请假单的当前状态、历史路径和处理人便于审计和问题排查。常见应用场景OA审批请假、报销、采购等需要多级审批的流程。订单处理从下单、支付、发货到售后涉及多个系统协作的订单生命周期管理。CI/CD流水线代码提交后的自动构建、测试、部署流程。数据ETL定时的数据抽取、清洗、转换和加载任务流。客服工单用户提交问题后的自动分派、处理、升级和关闭流程。理解了“为什么”之后接下来的“如何做”就清晰了我们需要一个工具来“编辑”设计流程并需要一个引擎来“执行”它。2. 环境准备与主流工作流引擎选型在开始动手之前我们需要选择合适的工具。目前开源社区中有多个成熟的工作流引擎它们各有侧重。2.1 主流开源工作流引擎简介Flowable / Activiti简介两者同源都是基于BPMN 2.0标准的轻量级Java工作流引擎。Activiti是原版Flowable是核心团队分支出来的版本目前社区更活跃功能也更丰富。特点与Spring Boot集成极佳提供了REST API、流程设计器基于BPMN.js、历史数据追踪、表单引擎等全套解决方案。非常适合需要深度定制和复杂业务集成的Java后端项目。Camunda简介同样基于BPMN 2.0是Activiti的另一个重要分支。它更强调“流程自动化”和“决策自动化”提供了强大的操作界面Cockpit、Tasklist和决策引擎DMN。特点企业级特性丰富监控和管理UI开箱即用社区和商业支持都很完善。适合对运维监控有较高要求的中大型项目。n8n简介一个基于节点的低代码工作流自动化工具。严格来说它更偏向于“集成自动化”而非“BPM业务流程管理”。特点通过可视化连接各种应用如Slack、Gmail、数据库、API的节点来构建自动化流程无需代码。非常适合IT运维、市场自动化和简单的业务数据同步场景。其他相关工具Coze / Dify这类AI应用开发平台内置的“工作流”功能主要用于编排AI模型调用、条件判断和数据处理的步骤以实现复杂的AI智能体Agent逻辑与传统BPM工作流目标不同。选型建议如果你是Java技术栈需要处理严谨的、与人交互的审批类业务流程优先选择Flowable或Camunda。本文后续实战将以Flowable为例因其与Spring Boot的整合最为简单直接。如果你的目标是连接不同SaaS服务实现无代码自动化n8n是绝佳选择。如果你的核心是构建AI应用编排大模型调用链则应关注Coze、Dify或LangChain等框架。2.2 基础开发环境准备我们将以Flowable Spring Boot为例演示工作流从编辑到执行的全过程。操作系统Windows 10/11, macOS, 或 Linux (如 Ubuntu 20.04)JavaJDK 8 或 JDK 11 (推荐 JDK 11 LTS版本更稳定)构建工具Maven 3.6 或 Gradle 6.xIDEIntelliJ IDEA (推荐) 或 Eclipse with Spring Tools数据库MySQL 5.7 或 PostgreSQL 10 (Flowable支持多种数据库这里以MySQL为例)其他工具Postman 或 curl (用于测试API)请确保你的开发环境中已正确安装并配置好上述基础软件。3. 核心原理拆解BPMN 2.0与引擎架构要玩转工作流必须理解其基石BPMN 2.0和引擎的运行时架构。3.1 BPMN 2.0流程的“设计语言”BPMNBusiness Process Model and Notation是一套全球通用的业务流程建模与标注标准。我们可以把它理解为绘制流程图的“语法”。Flowable等引擎能够直接读取和执行BPMN 2.0格式的XML文件。一个最简单的BPMN流程包含以下核心元素事件流程的开始、结束和中间发生的事。如开始事件、结束事件。活动需要执行的工作。如用户任务需要人处理、服务任务自动调用Java类或HTTP服务。网关控制流程的分支与合并。如排他网关XOR只选一条路、并行网关AND所有路径同时执行。顺序流连接上述元素的箭头指明执行顺序。泳道区分不同角色或部门的执行区域。一个请假流程的BPMN模型可能看起来像这样概念图[开始事件] - [员工提交请假申请] - [经理审批?] - {排他网关} 是 - [HR备案] - [结束事件] 否 - [申请被驳回] - [结束事件]这个模型会被保存为一个.bpmn20.xml文件。3.2 Flowable引擎核心架构理解架构有助于我们在编码和排错时找准位置。Flowable引擎的核心服务如下RepositoryService流程定义的管理者。负责部署BPMN文件、查询流程定义。RuntimeService流程实例的管理者。负责启动一个流程定义、创建流程实例、设置流程变量。TaskService用户任务的管理者。负责查询待办任务、完成任务、设置任务变量、指派处理人。HistoryService历史数据的查询者。流程实例结束后通过它查询所有的执行痕迹。IdentityService用户与组的管理者。在简单集成中常与我们自己的用户系统对接此服务使用较少。FormService表单相关服务。可选一次典型的流程执行交互通过RepositoryService部署一个请假流程的BPMN文件。员工发起申请时通过RuntimeService根据流程定义启动一个新的流程实例并传入申请天数、原因等流程变量。流程流转到“经理审批”这个用户任务TaskService中会产生一条待办任务分配给经理。经理登录系统通过TaskService查询到自己的待办任务查看任务详情包含流程变量然后做出“同意”或“驳回”的操作TaskService.complete()该方法。引擎根据任务完成时携带的结果也是变量驱动流程通过网关流向下一节点HR备案或直接结束。流程结束后可以通过HistoryService查询整个流程的审批记录。4. 完整实战构建一个请假审批工作流现在我们动手搭建一个完整的Spring Boot项目实现一个请假审批流程。4.1 创建项目并添加依赖使用 Spring Initializr 或 IDE 创建一个新的 Spring Boot 项目。pom.xml 关键依赖?xml version1.0 encodingUTF-8? project xmlnshttp://maven.apache.org/POM/4.0.0 xmlns:xsihttp://www.w3.org/2001/XMLSchema-instance xsi:schemaLocationhttp://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd modelVersion4.0.0/modelVersion parent groupIdorg.springframework.boot/groupId artifactIdspring-boot-starter-parent/artifactId version2.7.18/version !-- 选择一个稳定的版本 -- relativePath/ /parent groupIdcom.example/groupId artifactIdflowable-demo/artifactId version0.0.1-SNAPSHOT/version nameflowable-demo/name descriptionDemo project for Flowable/description properties java.version11/java.version flowable.version6.8.0/flowable.version /properties dependencies !-- Spring Boot Web -- dependency groupIdorg.springframework.boot/groupId artifactIdspring-boot-starter-web/artifactId /dependency !-- Flowable Spring Boot Starter -- dependency groupIdorg.flowable/groupId artifactIdflowable-spring-boot-starter/artifactId version${flowable.version}/version /dependency !-- MySQL Driver -- dependency groupIdmysql/groupId artifactIdmysql-connector-java/artifactId scoperuntime/scope /dependency !-- Spring Boot Test -- dependency groupIdorg.springframework.boot/groupId artifactIdspring-boot-starter-test/artifactId scopetest/scope /dependency /dependencies build plugins plugin groupIdorg.springframework.boot/groupId artifactIdspring-boot-maven-plugin/artifactId /plugin /plugins /build /project4.2 配置数据库与Flowableapplication.yml 配置文件spring: datasource: url: jdbc:mysql://localhost:3306/flowable_db?useUnicodetruecharacterEncodingUTF-8serverTimezoneAsia/Shanghai username: root password: your_password driver-class-name: com.mysql.cj.jdbc.Driver # Flowable 配置 flowable: # 禁用异步执行器适合演示和简单场景 async-executor-activate: false # 启动时检查数据库结构不存在则自动创建 database-schema-update: true # 关闭历史数据记录级别可选‘none’, ‘activity’, ‘audit’, ‘full’ history-level: audit # 是否检查流程定义文件BPMN的合法性 check-process-definitions: true注意请提前在MySQL中创建名为flowable_db的数据库。启动应用后Flowable会自动在该库中创建约60张表用于存储流程定义、实例、任务、历史等数据。4.3 编辑流程定义BPMN 2.0 XML在src/main/resources/processes/目录下创建文件leave-request.bpmn20.xml。你可以使用Flowable提供的Eclipse插件、在线设计器或直接编写XML。这里我们直接编写一个清晰的XML。?xml version1.0 encodingUTF-8? definitions xmlnshttp://www.omg.org/spec/BPMN/20100524/MODEL xmlns:xsihttp://www.w3.org/2001/XMLSchema-instance xmlns:flowablehttp://flowable.org/bpmn typeLanguagehttp://www.w3.org/2001/XMLSchema expressionLanguagehttp://www.w3.org/1999/XPath targetNamespacehttp://www.flowable.org/processdef !-- 定义一个流程id是代码中引用的标识name是显示名称 -- process idleaveRequest name请假申请流程 isExecutabletrue !-- 1. 开始事件 -- startEvent idstartEvent name开始申请/ !-- 2. 员工提交申请用户任务 -- userTask idsubmitLeaveRequest name提交请假申请 flowable:assignee${applicant} documentation员工填写请假单并提交/documentation /userTask !-- 3. 经理审批用户任务 -- userTask idmanagerApprove name经理审批 flowable:candidateGroupsmanager documentation部门经理审批请假申请/documentation /userTask !-- 4. 排他网关根据审批结果决定流向 -- exclusiveGateway iddecisionGateway name审批决定/ !-- 5. HR备案服务任务自动执行 -- serviceTask idhrRecord nameHR备案 flowable:classcom.example.flowabledemo.task.HrRecordTask/ !-- 6. 申请被驳回用户任务 -- userTask idrequestRejected name申请被驳回 flowable:assignee${applicant} documentation通知员工申请被驳回/documentation /userTask !-- 7. 结束事件 -- endEvent idendEvent name流程结束/ !-- 顺序流连接各个元素 -- sequenceFlow idflow1 sourceRefstartEvent targetRefsubmitLeaveRequest/ sequenceFlow idflow2 sourceRefsubmitLeaveRequest targetRefmanagerApprove/ !-- 从网关出来的流可以带有条件 -- sequenceFlow idflow3 sourceRefmanagerApprove targetRefdecisionGateway/ sequenceFlow idflow4 sourceRefdecisionGateway targetRefhrRecord !-- 条件当流程变量 approved 为 true 时走这条路 -- conditionExpression xsi:typetFormalExpression${approved true}/conditionExpression /sequenceFlow sequenceFlow idflow5 sourceRefdecisionGateway targetRefrequestRejected conditionExpression xsi:typetFormalExpression${approved false}/conditionExpression /sequenceFlow sequenceFlow idflow6 sourceRefhrRecord targetRefendEvent/ sequenceFlow idflow7 sourceRefrequestRejected targetRefendEvent/ /process /definitions流程解读员工${applicant}提交申请。任务流转到“经理”组candidateGroupsmanager的任何人。经理审批后会设置一个布尔类型的流程变量approved。排他网关根据approved的值决定流程走向true则流向HR备案自动服务false则流向驳回通知任务回到申请人。服务任务HrRecordTask是一个自动执行的Java类。4.4 编写业务代码服务任务与API首先实现自动执行的HR备案服务任务。文件src/main/java/com/example/flowabledemo/task/HrRecordTask.javapackage com.example.flowabledemo.task; import org.flowable.engine.delegate.DelegateExecution; import org.flowable.engine.delegate.JavaDelegate; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.stereotype.Component; Component(hrRecordTask) // 注意这里的Bean名称要与BPMN中flowable:class属性值一致 public class HrRecordTask implements JavaDelegate { private static final Logger logger LoggerFactory.getLogger(HrRecordTask.class); Override public void execute(DelegateExecution execution) { // 可以从流程变量中获取业务数据 String applicant (String) execution.getVariable(applicant); Integer leaveDays (Integer) execution.getVariable(leaveDays); String reason (String) execution.getVariable(reason); // 模拟HR系统备案逻辑例如写入数据库或发送消息 logger.info(【HR系统备案】员工 {} 的请假申请已通过经理审批。, applicant); logger.info(备案信息请假 {} 天事由{}, leaveDays, reason); // 这里可以调用其他Service完成实际业务 // hrService.record(applicant, leaveDays, reason); } }接下来创建REST API控制器用于启动流程、查询任务、完成任务等操作。文件src/main/java/com/example/flowabledemo/controller/LeaveController.javapackage com.example.flowabledemo.controller; import org.flowable.engine.HistoryService; import org.flowable.engine.RepositoryService; import org.flowable.engine.RuntimeService; import org.flowable.engine.TaskService; import org.flowable.engine.repository.Deployment; import org.flowable.engine.runtime.ProcessInstance; import org.flowable.task.api.Task; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; import java.util.HashMap; import java.util.List; import java.util.Map; RestController RequestMapping(/api/leave) public class LeaveController { Autowired private RepositoryService repositoryService; Autowired private RuntimeService runtimeService; Autowired private TaskService taskService; Autowired private HistoryService historyService; /** * 1. 部署流程定义通常只需一次可以放在项目启动时做 */ PostMapping(/deploy) public String deploy() { Deployment deployment repositoryService.createDeployment() .addClasspathResource(processes/leave-request.bpmn20.xml) .name(请假流程部署) .deploy(); return 流程部署成功部署ID: deployment.getId(); } /** * 2. 员工发起请假申请启动流程实例 */ PostMapping(/start) public String startProcess(RequestParam String applicant, RequestParam Integer leaveDays, RequestParam String reason) { MapString, Object variables new HashMap(); variables.put(applicant, applicant); variables.put(leaveDays, leaveDays); variables.put(reason, reason); // approved变量将在经理审批时设置 ProcessInstance processInstance runtimeService.startProcessInstanceByKey(leaveRequest, variables); return 流程启动成功流程实例ID: processInstance.getId(); } /** * 3. 查询某个用户的待办任务 */ GetMapping(/tasks) public ListMapString, Object getTasks(RequestParam String candidateGroupOrUser) { // 这里简单演示实际应根据用户身份复杂查询 ListTask tasks taskService.createTaskQuery() .taskCandidateGroup(candidateGroupOrUser) // 按组查询如 ‘manager‘ .or() .taskAssignee(candidateGroupOrUser) // 或按指定人查询 .endOr() .list(); return tasks.stream().map(task - { MapString, Object map new HashMap(); map.put(taskId, task.getId()); map.put(taskName, task.getName()); map.put(processInstanceId, task.getProcessInstanceId()); map.put(createTime, task.getCreateTime()); // 可以获取流程变量 MapString, Object processVariables runtimeService.getVariables(task.getProcessInstanceId()); map.put(variables, processVariables); return map; }).toList(); } /** * 4. 经理审批任务 */ PostMapping(/complete/{taskId}) public String completeTask(PathVariable String taskId, RequestParam Boolean approved, RequestParam(required false) String comment) { // 在完成任务前设置流程变量网关会根据这个变量做判断 MapString, Object taskVariables new HashMap(); taskVariables.put(approved, approved); if (comment ! null !comment.isEmpty()) { taskService.addComment(taskId, null, comment); // 添加审批意见 } taskService.complete(taskId, taskVariables); return 任务处理完成。审批结果: (approved ? 通过 : 驳回); } }4.5 运行与验证启动应用运行Spring Boot主类。观察日志Flowable会自动创建数据库表。部署流程可选因为check-process-definitions: true通常会在启动时自动部署类路径下的BPMN文件。你也可以调用POST /api/leave/deploy。员工张三发起请假curl -X POST http://localhost:8080/api/leave/start?applicantzhangsanleaveDays3reason回家探亲响应会返回一个流程实例ID如processInstanceId: 25001。经理李四查询待办curl http://localhost:8080/api/leave/tasks?candidateGroupOrUsermanager会返回一个任务列表其中包含“经理审批”任务并附带了张三提交的请假信息变量。经理李四审批通过curl -X POST http://localhost:8080/api/leave/complete/{taskId}?approvedtruecomment同意将上一步查询到的taskId替换到URL中。执行后引擎会自动完成“经理审批”任务根据approvedtrue的条件流程会流向“HR备案”节点自动执行我们编写的HrRecordTask类的execute方法。你会在应用日志中看到备案信息输出然后流程结束。查看历史可通过代码或Flowable自带的管理API流程结束后可以通过historyService查询完整的流程执行轨迹。至此一个完整的工作流“编辑”BPMN设计和“执行”Spring Boot集成的闭环就完成了。你可以通过修改BPMN XML文件轻松地增加一个“总监审批”环节或者将“HR备案”改为“用户任务”让HR手动处理而业务代码Controller几乎不需要改动。5. 常见问题与排查思路在实际集成和使用工作流引擎时你可能会遇到以下典型问题。问题现象可能原因排查思路与解决方案流程部署失败报XML schema错误BPMN 2.0 XML文件格式错误或不符合规范。1. 使用Flowable Eclipse设计器或在线验证工具检查XML语法。2. 检查id属性是否唯一元素是否闭合。3. 确保根标签是definitions且包含了必要的命名空间。启动流程实例失败提示No processes deployed with key ‘xxx’流程定义未部署或流程key不正确。1. 调用repositoryService.createProcessDefinitionQuery().processDefinitionKey(“xxx”).list()确认流程是否存在。2. 检查BPMN文件中process id”xxx”的id值是否与代码中传入的key一致。3. 确认包含BPMN文件的资源路径是否正确是否被Spring Boot正确加载。用户任务查询不到或候选人/指派人不正确任务查询条件错误或BPMN中任务分配表达式未正确解析。1. 使用taskService.createTaskQuery().processInstanceId(instanceId).list()查询该实例下所有任务确认任务是否已创建。2. 检查BPMN中flowable:assignee”${applicant}”表达式确保在启动流程时applicant变量已正确设置且类型为String。3. 对于组任务candidateGroups检查是否包含了当前查询用户所在的组。流程变量获取为null变量未设置或变量作用域问题。1. 流程变量可以在启动时设置也可以在任务完成时设置。确认设置变量的时机和位置。2. 注意runtimeService.getVariables(executionId)获取的是流程实例级变量taskService.getVariables(taskId)获取的是任务局部变量。使用execution.getVariable()在JavaDelegate中获取。3. 变量名是否拼写正确。服务任务JavaDelegate未执行Bean名称不匹配或Spring容器未找到Bean。1. 确认BPMN中flowable:class属性值如com.example.HrRecordTask与Component注解的Bean名称一致。更推荐使用flowable:delegateExpression”${hrRecordTask}”并注入Spring Bean。2. 确认实现JavaDelegate的类已被Spring组件扫描到。网关条件不生效流程走错分支条件表达式语法错误或变量类型不匹配。1. 检查BPMN中conditionExpression的写法例如${approved true}变量approved必须是布尔型。2. 在网关前通过execution.setVariable()或任务完成时传入的变量Map确保条件变量已正确设置。数据库表未自动创建配置flowable.database-schema-update设置为false或数据库连接失败。1. 检查application.yml中数据库连接配置是否正确。2. 确认flowable.database-schema-update设置为true或create-drop。3. 查看启动日志是否有数据库相关的错误信息。6. 最佳实践与工程建议将工作流引擎引入生产项目需要考虑更多工程化因素。流程设计规范命名清晰流程ID、任务ID、变量名使用有业务意义的英文如leave_request,manager_approval_task。版本控制BPMN文件应纳入Git等版本控制系统。Flowable在部署相同key的流程时会自动生成新版本旧版本的流程实例仍继续运行。简化流程避免设计过于复杂的、嵌套很深的流程图。可考虑将子流程抽取为可复用的“调用活动”。集成与封装服务封装不要在各个Controller中直接注入RuntimeService,TaskService。应封装一层业务门面服务如ProcessBusinessService统一处理流程启动、任务查询完成等操作并在此层添加日志、异常转换、权限校验等。用户体系对接Flowable的IdentityService通常不与公司现有用户系统直接耦合。更常见的做法是在查询任务时根据当前登录用户的角色和部门动态构造查询条件如taskCandidateGroup in (‘dept_leader‘, ‘project_manager‘)而不是硬编码。事务与一致性Flowable默认与Spring事务集成。确保你的业务操作如更新业务状态表和流程操作如taskService.complete()在同一个Transactional注解下保证原子性。在JavaDelegate的execute方法中抛出异常会导致当前事务回滚流程也会在此处暂停并可以根据BPMN错误事件定义进行错误处理。性能与监控历史数据清理对于高频流程历史表ACT_HI_*会快速增长。需要制定归档或清理策略。Flowable提供了历史数据管理API。异步执行对于耗时长的自动任务服务任务考虑使用flowable.async-executor-activatetrue启用异步执行器避免阻塞流程引擎线程。监控利用HistoryService统计流程耗时、节点耗时用于分析瓶颈。也可以集成Spring Boot Actuator或使用Flowable自带的管理REST API监控引擎健康状态。流程变更与数据迁移谨慎修改运行中流程的定义直接部署新版本的BPMN不会影响已运行的旧版本流程实例。对于需要迁移的实例Flowable提供了流程实例迁移API但操作复杂且风险高。最佳实践对于重大流程变更建议将旧流程定义归档并创建新的流程定义使用新的process key或版本号。新业务走新流程旧业务待其自然运行结束。这要求流程设计之初就考虑一定的扩展性和兼容性。工作流的编辑与执行本质是将易变的业务逻辑从稳定的系统代码中抽离出来。通过Flowable这样的引擎我们获得了应对业务频繁变更的弹性。掌握它不仅能提升开发效率更能让你的系统架构变得更加清晰和健壮。建议你基于本文的示例进行扩展尝试设计更复杂的流程如并行网关、子流程、消息事件并将其与你现有的业务模块深度集成体会其带来的价值。
