程序与技术分享:activity(工作流)初步学习记录

本文涉及的产品
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
云数据库 RDS PostgreSQL,高可用系列 2核4GB
云数据库 RDS MySQL,高可用系列 2核4GB
简介: 程序与技术分享:activity(工作流)初步学习记录

1.概念


工作流(Workflow),就是“业务过程的部分或整体在计算机应用环境下的自动化”,它主要解决的是“使在多个参与者之间按照某种预定义的规则传递文档、信息或任务的过程自动进行,从而实现某个预期的业务目标,或者促使此目标的实现”。


2.Activity介绍


Activiti5是由Alfresco软件在2010年5月17日发布的业务流程管理(BPM)框架,它是覆盖了业务流程管理、工作流、服务协作等领域的一个开源的、灵活的、易扩展的可执行流程语言框架。Activiti基于Apache许可的开源BPM平台,创始人Tom Baeyens是JBoss jBPM的项目架构师,它特色是提供了eclipse插件,开发人员可以通过插件直接绘画出业务


流程图。


3.工作流引擎


ProcessEngine对象,这是Activiti工作的核心。负责生成流程运行时的各种实例及数据、监控和管理流程的运行。


4:数据库


Activiti数据库支持:


Activiti的后台是有数据库的支持,所有的表都以ACT_开头。 第二部分是表示表的用途的两个字母标识。 用途也和服务的API对应。


ACTRE: 'RE'表示repository。 这个前缀的表包含了流程定义和流程静态资源 (图片,规则,等等)。


ACTRU: 'RU'表示runtime。 这些运行时的表,包含流程实例,任务,变量,异步任务,等运行中的数据。 Activiti只在流程实例执行过程中保存这些数据, 在流程结束时就会删除这些记录。 这样运行时表可以一直很小速度很快。


ACTID: 'ID'表示identity。 这些表包含身份信息,比如用户,组等等。


ACTHI: 'HI'表示history。 这些表包含历史数据,比如历史流程实例, 变量,任务等等。


ACTGE: 通用数据, 用于不同场景下,如存放资源文件。


4.1表结构


资源库流程规则表


1) act_re_deployment 部署信息表


2) act_re_model 流程设计模型部署表


3) act_re_procdef 流程定义数据表


运行时数据库表


1) act_ru_execution 运行时流程执行实例表


2) act_ru_identitylink 运行时流程人员表,主要存储任务节点与参与者的相关信息


3) act_ru_task 运行时任务节点表


4) act_ru_variable 运行时流程变量数据表


历史数据库表


1) act_hi_actinst 历史节点表


2) act_hi_attachment 历史附件表


3) act_hi_comment 历史意见表


4) act_hi_identitylink 历史流程人员表


5) act_hi_detail 历史详情表,提供历史变量的查询


6) act_hi_procinst 历史流程实例表


7) act_hi_taskinst 历史任务实例表


8) act_hi_varinst 历史变量表


组织机构表


1) act_id_group 用户组信息表


2) act_id_info 用户扩展信息表


3) act_id_membership 用户与用户组对应信息表


4) act_id_user 用户信息表


这四张表很常见,基本的组织机构管理,关于用户认证方面建议还是自己开发一套,组件自带的功能太简单,使用中有很多需求难以满足


通用数据表


1) act_ge_bytearray 二进制数据表


2) act_ge_property 属性数据表存储整个流程引擎级别的数据,初始化表结构时,会默认插入三条记录


5.activiti.cfg.xml(activiti的配置文件)


Activiti核心配置文件,配置流程引擎创建工具的基本参数和数据库连接池参数。


定义数据库配置参数:


jdbcUrl: 数据库的JDBC URL。


jdbcDriver: 对应不同数据库类型的驱动。


jdbcUsername: 连接数据库的用户名。


jdbcPassword: 连接数据库的密码。


基于JDBC参数配置的数据库连接 会使用默认的MyBatis连接池。 下面的参数可以用来配置连接池(来自MyBatis参数):


jdbcMaxActiveConnections: 连接池中处于被使用状态的连接的最大值。默认为10。


jdbcMaxIdleConnections: 连接池中处于空闲状态的连接的最大值。


jdbcMaxCheckoutTime: 连接被取出使用的最长时间,超过时间会被强制回收。 默认为20000(20秒)。


jdbcMaxWaitTime: 这是一个底层配置,让连接池可以在长时间无法获得连接时, 打印一条日志,并重新尝试获取一个连接。(避免因为错误配置导致沉默的操作失败)。 默认为20000(20秒)。


6.准备工作


  1.下载activity(Activity官网下载)


  2.Eclipse安装流程设计器插件


  在有网络情况下:


    打开 Help -> Install New Software,如下图:


  点击Add按钮,装配新插件名称的地址,填下以下字段


  Name: Activiti BPMN 2.0 designer


  Location:


    回到Install界面,在面板正中列表中把所有展示出来的项目都勾上,并且把下图红色框框的勾上,它会检查所有当前安装所需要的插件并可以被Eclipse下载


  安装完以后,点击新建工程new->Other…打开面板,如果看到下图:说明安装插件已经成功。


下面是准备开发环境:


在activiti-5.22->wars目录下是一些示例项目,解压activiti-rest项目,导入activiti-rest目录中WEB-INF\lib下所有包。添加到classpath中。


由于我们使用的是Mysql数据库,Mysql数据库的链接驱动Activiti官方包中并没有提供,需要我们自己导入。手动导入mysql-connector-java.jar,添加到classpath下。(本人用的用maven工程导入依赖)


初始化数据库:


@Test


public void test() {


//1.创建Activity配置对象的实例


ProcessEngineConfiguration configuration = ProcessEngineConfiguration.createStandaloneProcessEngineConfiguration();


//2.设置数据库连接信息


//设置数据库地址


configuration.setJdbcUrl("jdbc:");


//数据库驱动


configuration.setJdbcDriver("com.mysql.jdbc.Driver");


//用户名


configuration.setJdbcUsername("root");


//密码


configuration.setJdbcPassword("");


//设置数据建表策略


/**


DB_SCHEMA_UPDATE_TRUE 如果不存在表就创建表,存在表就使用


/


configuration.setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE);


//3.使用配置对象创建流程引擎实例(检查数据库等连接环境)


ProcessEngine processEngine = configuration.buildProcessEngine();


System.out.println(processEngine);


}


执行成功,数据库会生成25张表。


(在Actiiti5中定制流程必定会操作到数据库,如果都像上面那样写一大段代码会非常麻烦,所以我们可以把数据库连接配置写入配置文件。一个类似spring结构的配置文件,清空内容后改名为activiti.cfg.xml,用来做流程引擎的相关配置。主要定义了数据库连接和建表策略。)


下面是配置文件连接数据库与创建表的过程:


activiti.cfg.xml:


<?xml version="1.0" encoding="UTF-8"?>



xmlns:context="http://www.springframework.org/schema/context" xmlns:tx="http://www.springframework.org/schema/tx"


xmlns:jee="http://www.springframework.org/schema/jee" xmlns:aop="http://www.springframework.org/schema/aop"


xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd


http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd


http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd


http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-3.0.xsd


http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd">








需要把log4j.properties添加到resource


测试类:


/**


使用配置文件


/


@Test


public void test2() throws Exception{


ProcessEngine processEngine = ProcessEngineConfiguration.createProcessEngineConfigurationFromResource("activiti.cfg.xml").buildProcessEngine();


System.out.println(processEngine);


}


下一步:


创建helloword.bpmn,同时这是一个xml文件,创建完后会生成一张流程图的(不一一描述)


下面是第一个入门程序编写模拟


//调用引擎,初始化


ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();


/**


部署流程定义


///代码效果参考:http://www.jhylw.com.cn/353937817.html


@Test


public void deployment() {


Deployment deployment = processEngine.getRepositoryService()//与流程定义和部署相关的Service


.createDeployment()//创建一个部署对象


.name("helloword")//添加部署的名称


.addClasspathResource("diagrams/helloword.bpmn")//从classpath下加载资源,一次一个


.addClasspathResource("diagrams/helloword.png")


.deploy();//完成部署


System.out.println("部署ID"+deployment.getId());//1


System.out.println("部署名称"+deployment.getName());


}


/**


启动流程实例


/


@Test


public void startProcessInstance() {


String processDefinitionKey = "helloword";


ProcessInstance processInstance = processEngine.getRuntimeService()//与正在执行的流程实例和执行对象相关的Service


.startProcessInstanceByKey(processDefinitionKey);//根据Key值来查询流程,也可以//代码效果参考:http://www.jhylw.com.cn/032228417.html

根据ID

System.out.println("流程实例ID:"+processInstance.getId()); //2501


//对应数据库act_ru_execution


System.out.println("流程定义ID:"+processInstance.getProcessDefinitionId()); //helloword:1:4


//对应数据库act_re_deployment


}


/**


查询当前个人的任务


/


@Test


public void fingByPerson() {


String assignee = "张三";


List list = processEngine.getTaskService()//与正在执行的任务管理相关的Service


.createTaskQuery()//创建任务查询对象


.taskAssignee(assignee)//指定个人任务查询,指定代理人


.list();//以list形式记录对象


if(list != null && list.size()>0) {


for(Task task:list) {


System.out.println("任务ID:"+task.getId());//2501


System.out.println("任务名称:"+task.getName());//提交申请


System.out.println("任务的创建时间:"+task.getCreateTime());//Wed Jun 06 18:12:15 CST 2018


System.out.println("任务的代理人:"+task.getAssignee());//张三


System.out.println("流程实例ID:"+task.getProcessInstanceId());//2501


System.out.println("执行对象ID:"+task.getExecutionId());//2501


System.out.println("流程定义ID:"+task.getProcessDefinitionId());//helloword:1:4


}


}


}


/**


完成个人任务


*/


@Test


public void complete() {


String taskId = "2504";


processEngine.getTaskService()


.complete(taskId );


System.out.println("完成任务ID:"+taskId);


}


以上代码模拟了一个流程执行的流程:部署----启动流程实例-----查询当前正在执行的流程-----然后提交,当前(提交申请)的流程结束----会转到下一个流程执行者处理。


张三提交申请完成:


会把流程传送到部门经理(李四)审核,李四审核后传到总经理王五审核


数据库会记录流程的信息

相关实践学习
每个IT人都想学的“Web应用上云经典架构”实战
本实验从Web应用上云这个最基本的、最普遍的需求出发,帮助IT从业者们通过“阿里云Web应用上云解决方案”,了解一个企业级Web应用上云的常见架构,了解如何构建一个高可用、可扩展的企业级应用架构。
MySQL数据库入门学习
本课程通过最流行的开源数据库MySQL带你了解数据库的世界。 &nbsp; 相关的阿里云产品:云数据库RDS MySQL 版 阿里云关系型数据库RDS(Relational Database Service)是一种稳定可靠、可弹性伸缩的在线数据库服务,提供容灾、备份、恢复、迁移等方面的全套解决方案,彻底解决数据库运维的烦恼。 了解产品详情:&nbsp;https://www.aliyun.com/product/rds/mysql&nbsp;
相关文章
|
XML 数据库 数据格式
嵌入式工作流程开发!工作流 Activiti 框架中子流程的使用指南
本篇文章对工作流Activiti框架中的子流程进行的详尽的分析和说明,在工作流Activiti集成到项目中开发时,可以嵌入子流程进行使用。子流程包括了事件子流程,事务子流程以及调用活动子流程。通过对内嵌子流程的方式的学习,可以帮助我们将工作流框架很好地应用在继承式建模的流程场景下。
1330 0
嵌入式工作流程开发!工作流 Activiti 框架中子流程的使用指南
|
1月前
|
SQL 关系型数据库 MySQL
MySQL权限管理:用户与权限控制详解
本文深入解析MySQL权限管理系统,涵盖用户体系、权限模型及实战技巧,帮助构建安全的数据库防线。
|
3月前
|
Java Linux Docker
Docker
本文介绍了Docker的基础知识和使用方法,包括镜像打包、容器操作、Dockerfile编写及自定义构建镜像等内容。通过实际案例演示了如何将Java项目打包为JAR文件,并创建Docker镜像运行容器,最终验证服务运行状态。适合初学者快速掌握Docker核心技能。
214 2
Docker
|
11月前
|
编解码 监控 网络协议
HLS 和 RTSP 的优势
【10月更文挑战第25天】HLS和RTSP各自的优势使其在不同的应用场景中发挥着重要作用。HLS适用于需要广泛兼容性、自适应码率和简单部署的场景,如在线视频点播、直播等;而RTSP则更适合对实时性、精确播放控制和互操作性要求较高的专业级实时流媒体应用。了解它们的优势有助于根据具体的项目需求选择最合适的流媒体传输协议。
343 61
|
移动开发 JSON 前端开发
跨域资源共享(CORS):详解跨域请求的限制与解决方法
跨域资源共享(CORS):详解跨域请求的限制与解决方法
|
11月前
|
网络协议 API 数据格式
HTTP 和 TCP 协议的主要区别
【10月更文挑战第25天】HTTP 和 TCP 在网络通信中扮演着不同的角色,各自具有独特的功能和特点,它们相互配合,共同为实现网络应用的各种需求提供了基础支持。
|
Oracle Java 关系型数据库
Java SpringBoot集成Activiti7工作流
Java SpringBoot集成Activiti7工作流
|
开发框架 监控 数据可视化
|
SQL 关系型数据库 MySQL
explain是什么?explain优缺点及如何使用explain优化SQL
explain是什么?explain优缺点及如何使用explain优化SQL
444 1
|
消息中间件 NoSQL OLAP
doris数据库是否可以替代redis
【4月更文挑战第20天】doris数据库是否可以替代redis
756 0