工作流Activiti初体验【一】

2024-06-24 13:32
文章标签 工作 初体验 activiti

本文主要是介绍工作流Activiti初体验【一】，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

在这里记录一下我的Activiti历程：（以下示例不涉及真实业务，所有逻辑均建立在学习的基础上）

bpmn图
bpmn

发起任务我设置了一个权限组user1，只要是这个权限的用户都可以发起任务
权限组
分发任务我设置了一个用户组，用户组中每个用户都可以处理这步流程，只要有一个人处理这步任务，分发的流程就算结束了
分发任务
分发任务这一环节还有个判断，允许任务下发和不允许任务下发
判断
任务分发完成则来到子流程，每个被分到任务的人需要执行任务，所以需要派生出多个实例。子流程里面用户集users包含着每一个user
子流程
子流程里面开始的事件需要接收用户参数生产每个实例
执行任务
后面的步骤跟前面差不多，就不细说了

代码部分

配置文件xml

<beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans.xsd"><!-- 配置流程引擎配置对象 --><bean id="processEngineConfiguration"class="org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration"><property name="jdbcDriver" value="com.mysql.cj.jdbc.Driver" /><property name="jdbcUrl" value="jdbc:mysql://127.0.0.1:3306/activiti?characterEncoding=utf8&amp;useSSL=false&amp;nullCatalogMeansCurrent=true" /><property name="jdbcUsername" value="root" /><property name="jdbcPassword" value="MySQLadmin1!" /><!-- 建表策略：若没有工作流表则创建，若存在工作流表则更新 --><property name="databaseSchemaUpdate" value="true" /></bean><!-- 配置一个流程引擎工厂bean，用于创建流程引擎对象 --><bean id="processEngine" class="org.activiti.spring.ProcessEngineFactoryBean"><!-- 通过set方法注入流程引擎配置对象 --><property name="processEngineConfiguration" ref="processEngineConfiguration" /></bean>
</beans>

ActivitiConfig.java

package com.avanty.activiti;import org.activiti.engine.*;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;@Configuration
public class ActivitiConfig {/*** 配合xml配置文件使用*/@Beanpublic ProcessEngine processEngine() {String resource = "activiti/activitiConfig.xml";String beanName = "processEngineConfiguration";ProcessEngineConfiguration conf = ProcessEngineConfiguration.createProcessEngineConfigurationFromResource(resource, beanName);return conf.buildProcessEngine();}/*** @Bean可以用xml配置，也可以代码配置* @Bean public ProcessEngine processEngine() { //创建Activiti配置对象实例*       ProcessEngineConfiguration configuration =*       ProcessEngineConfiguration.createStandaloneInMemProcessEngineConfiguration();*       configuration.setJdbcDriver("com.mysql.cj.jdbc.Driver");*       configuration.setJdbcUrl("jdbc:mysql://127.0.0.1:3306/activiti?characterEncoding=utf8&useSSL=false&nullCatalogMeansCurrent=true");*       configuration.setJdbcUsername("root");*       configuration.setJdbcPassword("MySQLadmin1!"); //设置建表策略*       configuration.setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE);*       //得到引擎实例 return configuration.buildProcessEngine(); }*/@Beanpublic RepositoryService repositoryService(ProcessEngine processEngine) {return processEngine.getRepositoryService();}@Beanpublic RuntimeService runtimeService(ProcessEngine processEngine) {return processEngine.getRuntimeService();}@Beanpublic TaskService taskService(ProcessEngine processEngine) {return processEngine.getTaskService();}@Beanpublic HistoryService historyService(ProcessEngine processEngine) {return processEngine.getHistoryService();}@Beanpublic ManagementService managementService(ProcessEngine processEngine) {return processEngine.getManagementService();}@Beanpublic IdentityService identityService(ProcessEngine processEngine) {return processEngine.getIdentityService();}}

用来测试的DeployActiviti.java

package com.avanty.activiti;import org.activiti.engine.ProcessEngine;
import org.activiti.engine.RepositoryService;
import org.activiti.engine.RuntimeService;
import org.activiti.engine.TaskService;
import org.activiti.engine.repository.Deployment;
import org.activiti.engine.runtime.ProcessInstance;
import org.activiti.engine.task.Task;
import org.activiti.engine.task.TaskQuery;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner;
import org.springframework.stereotype.Component;import java.io.InputStream;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;@Component
public class DeployActiviti implements ApplicationRunner {/*** 流程部署相关表 `ACT_RE_DEPLOYMENT` `ACT_RE_MODEL` `ACT_GE_BYTEARRAY`* `ACT_GE_PROPERTY` `ACT_RE_PROCDEF`*//*** 流程运行相关表 `ACT_RU_EXECUTION` `ACT_RU_IDENTITYLINK` `ACT_RU_JOB` `ACT_RU_TASK`* `ACT_RU_VARIABLE`*//*** 流程历史相关表 `ACT_HI_IDENTITYLINK` `ACT_HI_VARINST` `ACT_HI_ACTINST`* `ACT_HI_TASKINST`*//*** TaskQuery taskQuery = taskService.createTaskQuery();* taskQuery.taskCandidateGroupIn(roleList);* taskQuery.taskCandidateOrAssigned(usrnames);* taskQuery.includeProcessVariables(); taskList = taskQuery.list();*/@AutowiredProcessEngine processEngine;@AutowiredRuntimeService runtimeService;@AutowiredTaskService taskService;@Overridepublic void run(ApplicationArguments args) {finish();}private void deployProcess() {RepositoryService service = processEngine.getRepositoryService();InputStream bpmn = this.getClass().getResourceAsStream("/activiti/Process.bpmn");Deployment deployment = service.createDeployment().name("任务流程").addInputStream("Process.bpmn", bpmn).deploy();System.out.println(deployment.getName());System.out.println(deployment.getId());}/*** 发起任务*/private void step1() {String processInstanceByKey = "Process";ProcessInstance processInstance = runtimeService.startProcessInstanceByKey(processInstanceByKey);System.out.println(processInstance.getId());}/*** 查看发起任务*/private void findStep1() {TaskQuery taskQuery = taskService.createTaskQuery();List<String> roleCodeList = new ArrayList<>();roleCodeList.add("user1");taskQuery.taskCandidateGroupIn(roleCodeList);taskQuery.includeProcessVariables();List<Task> tasks = taskQuery.list();for (Task task : tasks) {System.out.println(task.getId());System.out.println(task.getProcessInstanceId());System.out.println(task.getName());System.out.println(task.getAssignee());}}/*** 分发任务*/private void step2() {TaskQuery taskQuery = taskService.createTaskQuery();List<String> roleCodeList = new ArrayList<>();roleCodeList.add("user1");taskQuery.taskCandidateGroupIn(roleCodeList);taskQuery.includeProcessVariables();Task task = taskQuery.singleResult();Map<String, Object> variables = new HashMap<>();List<String> users = new ArrayList<>();users.add("Michael");users.add("Zhan");variables.put("users", users);taskService.complete(task.getId(), variables);System.out.println("finish");}/*** 查看分发任务*/private void findStep2() {String assignee = "Zhan";// String assignee = "Michael";List<Task> tasks1 = taskService.createTaskQuery().taskCandidateUser(assignee).list();for (Task task1 : tasks1) {System.out.println(task1.getId());System.out.println(task1.getName());}}/*** 子流程-执行任务*/private void step3() {TaskQuery taskQuery = taskService.createTaskQuery();taskQuery.taskCandidateOrAssigned("Michael");taskQuery.includeProcessVariables();Task task = taskQuery.singleResult();System.out.println(task.getId());Map<String, Object> variables = new HashMap<>();List<String> users = new ArrayList<>();users.add("admin");users.add("root");variables.put("users", users);variables.put("isPass", 1);taskService.complete(task.getId(), variables);System.out.println("finish");}/*** 子流程-查看执行任务*/private void findStep3() {String assignee = "admin";
//		String assignee = "root";List<Task> tasks = taskService.createTaskQuery().taskCandidateOrAssigned(assignee).list();for (Task task : tasks) {System.out.println(task.getId());System.out.println(task.getProcessInstanceId());System.out.println(task.getName());}}/*** 子流程-验收任务*/private void step4() {String assignee = "admin";Task task = taskService.createTaskQuery().taskCandidateOrAssigned(assignee).singleResult();System.out.println(task.getId());Map<String, Object> variables = new HashMap<>();List<String> users = new ArrayList<>();if (assignee.equals("root")) {users.add("administrator");users.add("su");}else if(assignee.equals("admin")) {users.add("alex");users.add("sudo");}variables.put("users", users);taskService.complete(task.getId(), variables);System.out.println("finish");}/*** 子流程-查看验收任务*/private void findStep4() {
//		 String assignee = "administrator";
//		String assignee = "su";
//		String assignee = "alex";String assignee = "sudo";List<Task> tasks = taskService.createTaskQuery().taskCandidateOrAssigned(assignee).list();for (Task task : tasks) {System.out.println(task.getId());System.out.println(task.getProcessInstanceId());System.out.println(task.getName());}}/*** 子流程-完成*/private void finish() {String assignee = "alex";Task task = taskService.createTaskQuery().taskCandidateOrAssigned(assignee).singleResult();Map<String, Object> variables = new HashMap<>();variables.put("isPass", 1);taskService.complete(task.getId(), variables);System.out.println("finish");}}

最后，附上项目地址 Activiti-Test
项目是用Eclipse写的，不用IDEA的原因是Eclipse的Activiti插件比IDEA的好，有自动对齐功能，强迫症的福音呐！

这篇关于工作流Activiti初体验【一】的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1090286。

相关文章

工作常用指令与快捷键

工作常用指令与快捷键

Git提交代码 git fetch  git add .  git commit -m “desc”  git pull  git push Git查看当前分支 git symbolic-ref --short -q HEAD Git创建新的分支并切换 git checkout -b XXXXXXXXXXXXXX git push origin XXXXXXXXXXXXXX
阅读更多...
嵌入式方向的毕业生，找工作很迷茫

嵌入式方向的毕业生，找工作很迷茫

一个应届硕士生的问题： 虽然我明白想成为技术大牛需要日积月累的磨练，但我总感觉自己学习方法或者哪些方面有问题，时间一天天过去，自己也每天不停学习，但总感觉自己没有想象中那样进步，总感觉找不到一个很清晰的学习规划……眼看 9 月份就要参加秋招了，我想毕业了去大城市磨练几年，涨涨见识，拓开眼界多学点东西。但是感觉自己的实力还是很不够，内心慌得不行，总怕浪费了这人生唯一的校招机会，当然我也明白，毕业
阅读更多...
husky 工具配置代码检查工作流：提交代码至仓库前做代码检查

husky 工具配置代码检查工作流：提交代码至仓库前做代码检查

提示：这篇博客以我前两篇博客作为先修知识，请大家先去看看我前两篇博客 博客指路：前端 ESlint 代码规范及修复代码规范错误-CSDN博客前端 Vue3 项目开发—— ESLint & prettier 配置代码风格-CSDN博客 husky 工具配置代码检查工作流的作用 在工作中，我们经常需要将写好的代码提交至代码仓库 但是由于程序员疏忽而将不规范的代码提交至仓库，显然是不合理的 所
阅读更多...
未来工作趋势：零工小程序在共享经济中的作用

未来工作趋势：零工小程序在共享经济中的作用

经济在不断发展的同时，科技也在飞速发展。零工经济作为一种新兴的工作模式，正在全球范围内迅速崛起。特别是在中国，随着数字经济的蓬勃发展和共享经济模式的深入推广，零工小程序在促进就业、提升资源利用效率方面显示出了巨大的潜力和价值。 一、零工经济的定义及现状 零工经济是指通过临时性、自由职业或项目制的工作形式，利用互联网平台快速匹配供需双方的新型经济模式。这种模式打破了传统全职工作的界限，为劳动
阅读更多...
Smarty模板引擎工作机制(一)

Smarty模板引擎工作机制(一)

深入浅出Smarty模板引擎工作机制，我们将对比使用smarty模板引擎和没使用smarty模板引擎的两种开发方式的区别，并动手开发一个自己的模板引擎，以便加深对smarty模板引擎工作机制的理解。 在没有使用Smarty模板引擎的情况下，我们都是将PHP程序和网页模板合在一起编辑的，好比下面的源代码： <?php$title="深处浅出之Smarty模板引擎工作机制";$content=
阅读更多...
3.比 HTTP 更安全的 HTTPS（工作原理理解、非对称加密理解、证书理解）

3.比 HTTP 更安全的 HTTPS（工作原理理解、非对称加密理解、证书理解）

所谓的协议 协议只是一种规则，你不按规则来就无法和目标方进行你的工作 协议说白了只是人定的规则，任何人都可以定协议 我们不需要太了解细节，这些制定和完善协议的人去做的，我们只需要知道协议的一个大概 HTTPS 协议 1、概述 HTTPS（Hypertext Transfer Protocol Secure）是一种安全的超文本传输协议，主要用于在客户端和服务器之间安全地传输数据
阅读更多...
以太网交换机工作原理学习笔记

以太网交换机工作原理学习笔记

在网络中传输数据时需要遵循一些标准，以太网协议定义了数据帧在以太网上的传输标准，了解以太网协议是充分理解数据链路层通信的基础。以太网交换机是实现数据链路层通信的主要设备，了解以太网交换机的工作原理也是十分必要的。 1、以太网协议介绍 1.1以太网协议 以太网是当今现有局域网（Local Area Network, LAN）采用的最通用的通信协议标准，该标准定义了在局域网中采用的电缆类型和信号
阅读更多...
JVM工作过程

JVM工作过程

将JVM工作过程粗略分为5个阶段，包括加载阶段、链接阶段、初始化阶段、执行阶段、回收阶段 其中， （1）加载阶段、链接阶段的解析部分主要由类加载器完成 （2）初始化阶段是由JVM的类加载机制在类加载过程的最后阶段自动触发的。 （3）执行阶段主要由执行引擎负责 （4）回收阶段主要是垃圾收集器（Garbage Collector）负责。 所以，在Java虚拟机（JVM）中，读取字节码文件、解析字节码
阅读更多...
平时工作学习重要注意的问题

平时工作学习重要注意的问题

总体原则：抓住重点，条理清晰，可回溯，过程都清楚。 1 要有问题跟踪表，有什么问题，怎么解决的，解决方案。 2 要有常用操作的手册，比如怎么连sqlplus，一些常用的信息，保存好，备查。
阅读更多...
Struts 2的工作流程

Struts 2的工作流程

基本简要流程如下：1、客户端浏览器发出HTTP请求。2、根据web.xml配置，该请求被 FilterDispatcher接收。3、根据struts.xml配置，找到需要调用的Action类和方法， 并通过IoC方式，将值注入给Aciton。4、Action调用业务逻辑组件处理业务逻辑，这一步包含表单验证。5、Action执行完毕，根据 struts.xml中的配置找到对应的返回结果result
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2