Spring Boot 整合 Camunda 实现工作流

工作流是我们开发企业应用几乎必备的一项功能，工作流引擎发展至今已经有非常多的产品。最近正好在接触Camunda，所以来做个简单的入门整合介绍。如果您也刚好在调研或者刚开始计划接入，希望本文对您有所帮助。如果您是一名Java开发或Spring框架爱好者，欢迎关注我，持续更新技术干货。

Camunda简介

Camunda是一个灵活的工作流和流程自动化框架。其核心是一个运行在Java虚拟机内部的原生BPMN 2.0流程引擎。它可以嵌入到任何Java应用程序和任何运行时容器中。

官网网站: https://www.camunda.org/

入门文档: Getting started with Camunda Platform | docs.camunda.org

动手整合Camunda

下面就来一步步动手尝试一下吧。

准备工作

使用Camunda提供的项目初始化工具Camunda Automation Platform 7 Initializr

如上图，包名之类的根据自己需要做好配置，最后输入管理账号和密码，点击Generate Project按钮，自动下载工程。

解压下载后的工程，使用IntelliJ IDEA打开，其项目结构

打开pom.xml文件，添加camunda依赖：

<dependency><groupId>org.camunda.connect</groupId><artifactId>camunda-connect-core</artifactId>
</dependency><dependency><groupId>org.camunda.bpm</groupId><artifactId>camunda-engine-plugin-connect</artifactId>
</dependency>

由于Camunda Automation Platform 7 Initializr默认的Spring Boot版本已经是3.1了，所以如果要做一些降级调整，可以手工修改pom.xml中dependencyManagement配置，比如下面这样：

<dependencyManagement><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-dependencies</artifactId><version>2.6.4</version><type>pom</type><scope>import</scope></dependency><dependency><groupId>org.camunda.bpm</groupId><artifactId>camunda-bom</artifactId><version>7.15.0</version><scope>import</scope><type>pom</type></dependency></dependencies>
</dependencyManagement>

打开配置文件application.yaml，可以看到类似下面的内容

spring.datasource.url: jdbc:h2:file:./camunda-h2-databasecamunda.bpm.admin-user:id: transduckpassword: 111111、

spring.datasource.url：工作流引擎使用的数据库配置，您也可以根据官网文档去调整到其他数据库中（尤其生产环境）。

camunda.bpm.admin-user：管理员账户配置，可以在这里修改用户名和密码

创建一个简单的工作流

下面我们尝试创建一个简单的工作流：

第一步，我们将请求用户提供两个输入：name和message第二步，我们将这些输入传递给我们的服务以创建消息输出

开始编码：

创建第一步提到的数据模型

public class model {private String message;private String name;public model() { }public String getMessage() {return message;}public void setMessage(String message) {this.message = message;}public String getName() {return name;}public void setName(String name) {this.name = name;}@Overridepublic String toString() {return "" + message + ", " + name;}
}

根据第二步，创建接收消息的接口

@RequestMapping("/")
@RestController
public class controller {Logger logger = Logger.getLogger(this.getClass().getName());@PostMapping("/message")public model createMessage(@RequestBody model model) {logger.info("-------Message Creator Initialized-------");model m = new model();m.setMessage(model.getMessage());m.setName(model.getName());logger.info("Message created --> " + m.toString());return m;}
}