Spring Boot 整合 Camunda 实现工作流

2024-01-18
福建
本文字数：2685 字
阅读完需：约 9 分钟

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

Camunda 简介

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

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

入门文档: https://docs.camunda.org/get-started/

动手整合 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-database
camunda.bpm.admin-user:  id: transduck  password: 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;    }        @Override    public String toString() {        return "" + message + ", " + name;    }}

复制代码

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

@RequestMapping("/")@RestControllerpublic 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;    }}