Camunda

简介

Camunda是一个工作流引擎，执行Bpmn2.0标准。与它同类型的流程引擎有jbpm、activiti、flowable，但与Camunda相比，Camunda性能和稳定性都表现较好，更轻量级。

Camunda包括：流程设计器（Modeler）、流程引擎（Engine）、API接口（REST/Java API）、任务列表（TaskList）、流程管理控制台（Cockpit）、系统管理工具（Admin）。

详细介绍参考博客：https://blog.csdn.net/qq_41468822/article/details/135343266

示例demo下载： https://github.com/caohuajin/spring-boot-camunda.git

架构图

camunda整体架构如下图所示，主要包括两部分：流程建模工具（modeler）和流程引擎（Engine）。业务分析与开发人员（Business Analyst/Developer）通过modeler设计业务流程，将结果存入repository中，业务分析与开发人员一般不需要懂开发。流程引擎则负责流程实例的创建、执行、维护和管理，并通过REST/Java API向用户提供服务，基于这些API，流程用户（End User）通过Tasklist工具参与流程的执行，运维人员（operator）通过Cockpit工具查看、管理和维护流程的状态，管理人员（administrator）通过Admin工具进行用户的权限管理。当然，我们也可以基于REST/Java API开发自己的相应工具。通过下面的实例展示可知，camunda提供的tasklist、cockpit、admin工具非常有可能不是很符合你们团队的需求，需要自己开发部分功能。

BPMN概念

BPMN（Business Process Model and Notation）是一种用于描述业务流程的图形化标准。它提供了一种统一的方法来表示业务过程，使得业务分析师、业务用户和技术人员之间可以更好地沟通和理解业务流程。

以下是 BPMN 中的一些主要概念：

1. 流程（Process）：流程是指业务中的一系列活动或任务，以实现特定的业务目标。在 BPMN 中，流程可以被建模成各种形式，包括业务流程、子流程和协作流程等。
2. 活动（Activity）：活动是流程中的基本单元，代表执行的任务或操作。活动可以是一个简单的任务，也可以是一个复杂的子流程。
3. 事件（Event）：事件是流程中的状态变化，可以触发或影响流程的执行。例如，开始事件表示流程的开始，结束事件表示流程的结束，中间事件表示在流程执行过程中发生的中间状态。
4. 网关（Gateway）：网关用于控制流程的分支、合并和路由。根据条件，网关可以决定流程的执行路径。
5. 序列流（Sequence Flow）：序列流表示流程中活动之间的顺序关系，指示流程执行的方向。
6. 数据对象（Data Object）：数据对象表示流程中使用的数据或信息。它可以是输入、输出或中间数据，用于支持流程的执行。
7. 泳道（Swimlane）：泳道用于组织流程中的活动，可以按角色、部门或其他组织方式进行划分。泳道提供了对流程执行者的可视化描述。

BPMN 的这些概念可以帮助用户以图形化的方式清晰地描述业务流程，从而更好地进行流程分析、优化和执行。

Camunda Modeler

用于创建、编辑和管理流程模型的软件工具。下载地址：https://camunda.com/download/modeler/

集成Spring boot

配置环境：

• jdk 17
• mysql latest
• camunda-bpm-spring-boot-starter 7.20.0
• spring-boot-starter-parent 3.2.3

application.yaml

spring:
  application:
    name: camunda-demo
  jersey:
    application-path: /engine-rest
  datasource:
    driver-class-name: com.mysql.jdbc.Driver
    url: jdbc:mysql://127.0.0.1:3306/camunda_demo?allowPublicKeyRetrieval=true&useSSL=false&useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&useOldAliasMetadataBehavior=true
    username: root
    password: root
camunda.bpm:
  generic-properties:
    properties:
      enforceHistoryTimeToLive: false
  admin-user:
    id: demo
    password: demo
    firstName: Demo
  filter:
    create: All tasks
  database:
    type: mysql
server:
  port: 8080
  tomcat:
    uri-encoding: UTF-8

maven的pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>guru.springframework</groupId>
    <artifactId>spring-boot-camunda</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <packaging>jar</packaging>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>3.2.3</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>

    <name>spring-boot-camunda</name>
    <description>Demo project for Spring Boot and Camunda</description>

    <properties>
        <camunda.spring-boot.version>7.20.0</camunda.spring-boot.version>
        <maven.compiler.release>17</maven.compiler.release>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.18.30</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-jpa</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-tx</artifactId>
        </dependency>
        <dependency>
            <groupId>org.camunda.bpm.springboot</groupId>
            <artifactId>camunda-bpm-spring-boot-starter</artifactId>
            <version>${camunda.spring-boot.version}</version>
        </dependency>
        <dependency>
            <groupId>org.camunda.bpm.springboot</groupId>
            <artifactId>camunda-bpm-spring-boot-starter-webapp</artifactId>
            <version>${camunda.spring-boot.version}</version>
        </dependency>
        <dependency>
            <groupId>org.camunda.bpm.springboot</groupId>
            <artifactId>camunda-bpm-spring-boot-starter-rest</artifactId>
            <version>${camunda.spring-boot.version}</version>
        </dependency>
        <dependency>
            <groupId>org.camunda.bpm.extension.swagger</groupId>
            <artifactId>camunda-bpm-swagger-json</artifactId>
            <version>7.8.0</version>
        </dependency>
        <dependency>
            <groupId>org.webjars</groupId>
            <artifactId>swagger-ui</artifactId>
            <version>3.1.4</version>
        </dependency>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>5.1.49</version>
        </dependency>
    </dependencies>
</project>

常用web地址

• Swagger UI：http://localhost:8080/webjars/swagger-ui/3.1.4/index.html?docExpansion=none&url=/swagger.json#/

• REST API: http://localhost:8080/engine-rest/
• Camunda web：http://localhost:8080/camunda/app/welcome/default/#!/welcome

使用示例

基于JavaDelegate配置Camunda 的自动化服务节点

示例代码：

package guru.springframework.services.process;

import org.camunda.bpm.engine.delegate.DelegateExecution;
import org.camunda.bpm.engine.delegate.JavaDelegate;

public class TestDelegate implements JavaDelegate {
    @Override
    public void execute(DelegateExecution delegateExecution) throws Exception {
        System.out.println("TestDelegate: " + delegateExecution.getProcessInstanceId());
    }
}

Modeler配置：

基于ExecutionListener监听整个流程执行过程中的事件

import org.camunda.bpm.engine.delegate.DelegateExecution;
import org.camunda.bpm.engine.delegate.ExecutionListener;

public class AmountApprovalDecisionListener implements ExecutionListener {
    
    @Override
    public void notify(DelegateExecution execution) throws Exception {
        double amount = (double) execution.getVariable("amount");
        execution.setVariable("amount", amount);
    }
}