首页 > 其他分享 >SpringBoot整合 Camunda 流程引擎

SpringBoot整合 Camunda 流程引擎

时间:2023-06-29 18:44:06浏览次数:90  
标签:SpringBoot 1.3 流程 bpm 引擎 org import camunda Camunda

目录

1 整合 Camunda 流程引擎

1.1 简介

1.1.1 概念介绍

Camunda 概念:

  • 流程(PROCESS): 通过工具建模最终生成的BPMN文件,里面有整个流程的定义
  • 流程实例(Instance):流程启动后的实例
  • 流程变量(Variables):流程任务之间传递的参数
  • 任务(TASK):流程中定义的每一个节点
  • 流程部署:将之前流程定义的.bpmn文件部署到工作流平台

核心组件:

  • Process Engine-流程引擎
  • Web Applicatons- 基于web的管理页面

官方文档:https://docs.camunda.org/manual/7.18/user-guide/process-engine/process-engine-api/
下面是官网的一些文档,有时间可以看看,下面说一些核心的东西。
在这里插入图片描述

1.1.2 组件介绍

ProcessEngine 为流程引擎,可以通过它获取相关service,里面集成了很多相关service,默认实现如下:
在这里插入图片描述

RepositoryService:此服务提供用于管理和操作部署和流程定义的操作,使用camunda的第一要务
RuntimeService:运行相关,启动流程实例、删除、搜索等
TaskService:所有围绕任务相关的操作,如完成、分发、认领等
HistoryService:提供引擎搜集的历史数据服务
IdentityService:用户相关,实际中用不太到

1.2 Springboot集成

1.2.1 pom.xml

需要3个maven依赖,分别是对应 流程引擎、Web管理平台、提供rest api操作接口包

<dependency>
    <groupId>org.camunda.bpm.springboot</groupId>
    <artifactId>camunda-bpm-spring-boot-starter</artifactId>
    <version>7.18.0</version>
</dependency>
<dependency>
    <groupId>org.camunda.bpm.springboot</groupId>
    <artifactId>camunda-bpm-spring-boot-starter-rest</artifactId>
    <version>7.18.0</version>
</dependency>
<dependency>
    <groupId>org.camunda.bpm.springboot</groupId>
    <artifactId>camunda-bpm-spring-boot-starter-webapp</artifactId>
    <version>7.18.0</version>
</dependency>

1.2.2 配置文件

application.yml

## camunda登录信息配置
camunda.bpm:
  admin-user:
    id: admin  ##用户名
    password: 123456  ##密码
    firstName: yu
  filter:
    create: All tasks
 
## mysql连接信息
spring:
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://localhost:8101/camunda
    username: xxxx
    password: xxxx
    type: com.alibaba.druid.pool.DruidDataSource

1.2.3 数据库

使用的是mysql,建新库 camunda(数据库必须是存在的,不然启动不起来),启动后会自动生成所需表结构

启动后自动生成的表结构如下
图片
大概有这么几个表模块,重要的详细介绍下:

  • ACT_ID_
    这部分表示用户模块,配置文件里面的用户,信息就在此模块
  • ACT_HI_:表示流程历史记录
    • act_hi_actinst:执行的活动历史
    • act_hi_taskinst:执行任务历史
    • act_hi_procinst:执行流程实例历史
    • act_hi_varinst:流程变量历史表
  • ACT_RE_:表示流程资源存储
    • `act_re_procdef·:流程定义存储
    • `act_re_deployment·: 自动部署,springboot每次启动都会重新部署,生成记录
  • ACT_RU_:表示流程运行时表数据,流程结束后会删除
    • act_ru_execution:运行时流程实例
    • act_ru_task:运行时的任务
    • act_ru_variable:运行时的流程变量
  • ACT_GE_:流程通用数据
    • act_ge_bytearray:每次部署的文件2进制数据,所以如果文件修改后,重启也没用,因为重新生成了记录,需要清掉数据库,或者这个表记录

1.2.4 登录界面

登录地址为 http://localhost:8080/,输入用户名密码即为配置文件里面的 admin,123456
在这里插入图片描述
主控制台,登陆成功后,如下所示
在这里插入图片描述

1.3 绘制流程图

1.3.1 下载安装

首先需要一个工具 Camunda Modeler 来画,下载地址:https://camunda.com/download/modeler/
在这里插入图片描述
解压缩后打开如下:
在这里插入图片描述

1.3.2 绘制

新建一个
在这里插入图片描述
其中 BPMNDMNFormCamunda中使用的三种不同的模型和技术。

  • BPMN(Business Process Model and Notation):这是一种图形表示法,用于在业务流程模型中指定业务流程的业务步骤。BPMN的目标是支持业务流程的管理,无论是那些流程已经被自动化,还是尚未被自动化。BPMN创建了一个标准化的桥梁,通过公共视觉语言填补了业务策略与业务实施之间的鸿沟。
  • DMN(Decision Model and Notation):这是一种标准化的模型和表示法,用于定义和管理业务决策。DMN的目标是使决策模型变得更加透明和可理解,同时也能够自动化决策过程。
  • Form:在Camunda中,表单用于在业务流程中收集和显示数据。Camunda支持两种类型的表单:生成的表单和自定义表单。生成的表单是由Camunda自动创建的,基于流程变量的类型和结构。自定义表单则允许开发人员自定义表单的外观和行为。

1.3.2.1 任务分类

只介绍最常用的两种
用户任务 (User Task)具体来说就是需要手动执行的任务,即需要我们这变写完业务代码后,调用代码 taskService.complete(taskId, variables); 才会完成的任务
在这里插入图片描述
系统任务(Service Task)系统会自动帮我们完成的任务
图片

1.3.2.2 网关

分为这么几类,会根据我们传入的流程变量及设定的条件走
在这里插入图片描述

  • 排他网关(exclusive gateway)
    这个网关只会走一个,我们走到这个网关时,会从上到下找第一个符合条件的任务往下走
  • 并行网关(Parallel Gateway)
    这个网关不需要设置条件,会走所有的任务
  • 包含网关(Inclusive Gateway)
    这个网关会走一个或者多个符合条件的任务

示例
在这里插入图片描述
如上图包含网关,需要在网关的连线初设置表达式 condition,参数来自于流程变量

两个参数:switch2d 、 switch3d

  • 如果 都为true,则走任务1,3
  • 如果 switch2d 为true switch3d为false,则只走任务1
  • 如果 switch3d 为true switch2d为false,则只走任务3
  • 如果都为false,则直接走网关,然后结束

1.3.2.3 指定key

右侧控制面板中的id就是这个流程的key,可以自定义设定
在这里插入图片描述

1.3.3 集成在idea中

idea中的路径:file -> Setting -> Tools -> External Tools
在这里插入图片描述
这里设置后,选中 bpmn 文件,点击 tools ->External Tools 选中camunda(刚刚上面自己命名的扩展工具的名字),就会打开流程图编辑页面进行操作
在这里插入图片描述

1.3.4 引入项目测试

将画好的流程图保存文件为 test_1.bpmn,在刚才的springboot项目中resources新建一个bpmn文件夹,放进去,
在这里插入图片描述
重启项目,发现web界面中已经被集成进来了
在这里插入图片描述
conttoller

package cn.controller;

import cn.service.TestTaskService;
import org.camunda.bpm.engine.repository.ProcessDefinition;
import org.camunda.bpm.engine.task.Task;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;

@RestController
public class TaskController {

    @Autowired
    private TestTaskService testTaskService;

    //开启流程
    @PostMapping("/start/process")
    public void startProcess(){
        testTaskService.startProcess();
    }
    //查询流程定义
    @PostMapping("/find/process")
    public List<ProcessDefinition> findProcess(){
        return testTaskService.findProcesses();
    }
    //查询任务
    @PostMapping("/task")
    public List<Task> findTasks(){
        return testTaskService.findTasks();
    }
}

service

package cn.service;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import org.camunda.bpm.engine.RepositoryService;
import org.camunda.bpm.engine.RuntimeService;
import org.camunda.bpm.engine.TaskService;
import org.camunda.bpm.engine.repository.ProcessDefinition;
import org.camunda.bpm.engine.runtime.ProcessInstance;
import org.camunda.bpm.engine.task.Task;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;

@Service
public class TestTaskService {

    @Autowired
    private TaskService taskService;
    @Autowired
    private RuntimeService runtimeService;
    @Autowired
    private RepositoryService repositoryService;

    public void startProcess() {
        ProcessInstance instance = runtimeService.startProcessInstanceByKey("my_key");
        System.out.println("CaseInstanceId = "+instance.getCaseInstanceId());
        System.out.println("BusinessKey = "+instance.getBusinessKey());
        System.out.println("ProcessDefinitionId = "+instance.getProcessDefinitionId());
        System.out.println("ProcessInstanceId = "+instance.getProcessInstanceId());
        System.out.println("RootProcessInstanceId = "+instance.getRootProcessInstanceId());
        System.out.println("Id = "+instance.getId());
        System.out.println("TenantId = "+instance.getTenantId());
    }

    public List<ProcessDefinition> findProcesses() {
        return repositoryService.createProcessDefinitionQuery().list();
    }

    public List<Task> findTasks() {
        return taskService.createTaskQuery().list();
    }
}

参考链接:https://mp.weixin.qq.com/s/8w1S7Fwqxq_ghlE-z7d5BQ

标签:SpringBoot,1.3,流程,bpm,引擎,org,import,camunda,Camunda
From: https://www.cnblogs.com/jingzh/p/17514975.html

相关文章

  • springboot整合mybatis
    1,在application.yml中配置点击查看代码#mybatis#配置mapper路径mybatis:mapper-locations:classpath:mapper/*.xml2,在每个DAO接口上面追加@Mapper注解-------------------------------------------------------------增删改查的实现代码application.yml配......
  • springboot 通用限流方案设计与实现
    一、背景限流对于一个微服务架构系统来说具有非常重要的意义,否则其中的某个微服务将成为整个系统隐藏的雪崩因素,为什么这么说?举例来讲,某个SAAS平台有100多个微服务应用,但是作为底层的某个或某几个应用来说,将会被所有上层应用频繁调用,业务高峰期时,如果底层应用不做限流处理,该应用......
  • SpringBoot 2 种方式快速实现分库分表,轻松拿捏!
    大家好,我是小富~(一)好好的系统,为什么要分库分表?(二)分库分表的21条法则,hold住!本文是《分库分表ShardingSphere5.x原理与实战》系列的第三篇文章,本文将为您介绍ShardingSphere的一些基础特性和架构组成,以及在Springboot环境下通过JAVA编码和Yml配置两种方式快速实现分库......
  • idea springboot本地打包配置
    cleanpackage-plrenren-admin-am-amd......
  • springboot入门教程,大家都是怎么学习的?
     学习SpringBoot可以帮助你提高Java后端开发的效率和质量,更快速地构建应用程序,并与当前的开发趋势保持一致。不过,建议你始终关注最新的版本和技术发展,及时了解并学习最新的特性和最佳实践。SpringBoot入门教程对于初学者来说是非常好学的。B站上动力节点王妈妈的springboot3教程......
  • springboot入门教程,大家都是怎么学习的?
    ​学习SpringBoot可以帮助你提高Java后端开发的效率和质量,更快速地构建应用程序,并与当前的开发趋势保持一致。不过,建议你始终关注最新的版本和技术发展,及时了解并学习最新的特性和最佳实践。​Springboot对于初学者来说是非常好学的。B站上动力节点王妈妈的springboot3教程......
  • springboot3视频教程,很多可用的教学资源
    不得不说,学习SpringBoot是非常有必要的,尤其是对于Java后端开发人员来说。SpringBoot是基于SpringFramework的快速开发框架,通过自动配置和约定优于配置的原则,大大简化了Spring应用的开发和部署。它提供了丰富的功能和开箱即用的特性,可以帮助开发者快速搭建高效、可靠的企业级应用......
  • 小米,MiUI文字转语言没有首选引擎
    小米,MiUI文字转语言没有首选引擎,可以试着下载“小爱语音引擎”。链接:小爱语音引擎-小米应用商店(mi.com)微云:点击此处                            ......
  • 掌握这40个 SpringBoot 常用注解,开发效率翻几倍!
    SpringWebMVC与SpringBean注解SpringWebMVC注解@RequestMapping@RequestMapping注解的主要用途是将Web请求与请求处理类中的方法进行映射。SpringMVC和SpringWebFlux都通过RquestMappingHandlerMapping和RequestMappingHndlerAdapter两个类来提供对@RequestMappin......
  • springboot mybatis mapper 注入原理浅析
    spring+mybatis是我们常用的开发组合,一般情况,我们只需要写一个Mapper接口 加上@Mapper注解就可以使用了,那么他的工作原理是什么呢?标准mybatis调用应该是这样的流程1//读取配置2InputStreamconfig=Resources.getResourceAsStream("mybatis-config.xml");3//根......