解决方案

Activiti工作流教程

seo靠我 2023-09-26 02:45:19

这是篇关于Activiti工作流的教程,此教程通过编码的方式让大家快速掌握Activiti的使用方法,关于Activiti的理论性知识,大家可在学习这篇文章后,自行百度了解,此处不做赘述。

准备工作:ISEO靠我DEA需要安装actibpm插件,该插件在新版本IDEA中搜不到,需要去官网自行下载,然后导入。下载地址:actibpm下载地址,下载完成后是一个actibpm.jar,在IDEA的plugins中点SEO靠我击install plugin from Disk导入jar包即可。

使用Maven创建一个普通web项目,并导入Activiti及MySQL相关依赖(activiti需要数据库支持才能工作)。下面附上SEO靠我pom文件的相关代码。 <!--定义版本号--><properties><java.version>1.8</java.version><slf4j.version>1.6.6</slSEO靠我f4j.version><log4j.version>1.2.12</log4j.version><activiti.version>7.0.0.Beta1</activiti.version></pSEO靠我roperties><dependencies><!--activiti核心包--><dependency><groupId>org.activiti</groupId><artifactId>actSEO靠我iviti-engine</artifactId><version>${activiti.version}</version></dependency><!--activiti与spring整合的包-SEO靠我-><dependency><groupId>org.activiti</groupId><artifactId>activiti-spring</artifactId><version>${actiSEO靠我viti.version}</version></dependency><!--bpmn模型处理--><dependency><groupId>org.activiti</groupId><artifSEO靠我actId>activiti-bpmn-model</artifactId><version>${activiti.version}</version></dependency><!--bpmn转换-SEO靠我-><dependency><groupId>org.activiti</groupId><artifactId>activiti-bpmn-converter</artifactId><versioSEO靠我n>${activiti.version}</version></dependency><!--bpmn json数据转换--><dependency><groupId>org.activiti</gSEO靠我roupId><artifactId>activiti-json-converter</artifactId><version>${activiti.version}</version></depenSEO靠我dency><!--bpmn布局--><dependency><groupId>org.activiti</groupId><artifactId>activiti-bpmn-layout</artiSEO靠我factId><version>${activiti.version}</version></dependency><!--bpmn云支持--><dependency><groupId>org.actSEO靠我iviti.cloud</groupId><artifactId>activiti-cloud-services-api</artifactId><version>${activiti.versionSEO靠我}</version></dependency><!--mysql驱动--><dependency><groupId>mysql</groupId><artifactId>mysql-connectoSEO靠我r-java</artifactId><version>8.0.11</version></dependency><!--mybatis--><dependency><groupId>org.mybaSEO靠我tis</groupId><artifactId>mybatis</artifactId><version>3.4.5</version></dependency><!--连接池--><dependeSEO靠我ncy><groupId>commons-dbcp</groupId><artifactId>commons-dbcp</artifactId><version>1.4</version></depeSEO靠我ndency><dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>4.12</version></deSEO靠我pendency><dependency><groupId>log4j</groupId><artifactId>log4j</artifactId><version>${log4j.version}SEO靠我</version></dependency><dependency><groupId>org.slf4j</groupId><artifactId>slf4j-api</artifactId><veSEO靠我rsion>${slf4j.version}</version></dependency><dependency><groupId>commons-io</groupId><artifactId>coSEO靠我mmons-io</artifactId><version>2.4</version></dependency></dependencies> 在resources目录下,创建一个名SEO靠我为log4j.properties的日志配置文件,用于监测activiti工作流的日志信息。log4j.properties的详情配置如下: log4j.rootCategory=deSEO靠我bug,CONSOLE,LOGFILElog4j.logger.org.apache.axis.enterprise=FATAL,CONSOLElog4j.appender.CONSOLE=org.aSEO靠我pache.log4j.ConsoleAppender log4j.appender.CONSOLE.layout=org.apache.log4j.PatternLayout SEO靠我 log4j.appender.CONSOLE.layout.ConversionPattern=%d{ISO8601} %-6r[%15.15t] %-5p %30.30c %x - %m\SEO靠我nlog4j.appender.LOGFILE=org.apache.log4j.FileAppender #日志的存放路径 log4j.appender.LOGFILSEO靠我E.File=d:\\SOFT\\activiti.log log4j.appender.LOGFILE.Append=true log4j.appender.LOGFSEO靠我ILE.layout=org.apache.log4j.PatternLayout log4j.appender.LOGFILE.layout.ConversionPattern=%dSEO靠我{ISO8601} %-6r[%15.15t] %-5p %30.30c %x - %m\n 使用activiti提供的默认方式来创建mysql的表。默认方式的要求是在resourcSEO靠我es下创建activiti.cfg.xml文件。具体配置如下所示: <?xml version="1.0" encoding="UTF-8"?> <beans xmlnSEO靠我s="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"SEO靠我xmlns:context="http://www.springframework.org/schema/context"xmlns:tx="http://www.springframework.orSEO靠我g/schema/tx"xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframeworSEO靠我k.org/schema/beans/spring-beans.xsdhttp://www.springframework.org/schema/contexthttp://www.springfraSEO靠我mework.org.schema/context/spring-context.xsdhttp://www.springframework.org/schema/txhttp://www.sprinSEO靠我gframework.org/schema/tx/spring-tx.xsd"><!--dbcp连接池--><bean id="dataSource" class="org.apache.commonSEO靠我s.dbcp.BasicDataSource"><!--配置数据库相关的信息--><!--数据库驱动--><property name="driverClassName" value="com.mysSEO靠我ql.cj.jdbc.Driver"/><!--数据库连接--><property name="url" value="jdbc:mysql:///activitidb?serverTimezone=SEO靠我GMT%2B8&amp;useUnicode=true&amp;characterEncoding=UTF-8"/><!--数据库用户名--><property name="username" valSEO靠我ue="root"/><!--数据库密码--><property name="password" value="root"/><property name="maxActive" value="3"/SEO靠我><property name="maxIdle" value="1"/></bean><!--在默认方式下,这个bean的id必须是processEngineConfiguration。配置完这些内SEO靠我容,activiti会到指定的数据库自动生成需要的表--><bean id="processEngineConfiguration" class="org.activiti.engine.impl.cSEO靠我fg.StandaloneProcessEngineConfiguration"><!--引用数据源--><property name="dataSource" ref="dataSource"/><SEO靠我!--activiti生成数据表时的策略 设置为true时:如果数据库存在相应的表,则直接使用,否则创建--><property name="databaseSchemaUpdate" value="SEO靠我true"/></bean> 在test目录下新建一个类,名字随便起。然后写入以下代码,用于生成activiti所需的25张表。 public class ActivSEO靠我itiUtil {/***使用activiti提供的默认方式来创建mysql的表*/@Testpublic void createTable(){//执行该方法,会在数据库自动生成activiti所需SEO靠我的25张表ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();System.out.println(engine);} SEO靠我 } 代码执行后,去数据库可以发现已经生成了25张数据表,这些数据表都是以act为前缀的,表明是activiti所需的数据表。其中act_ge_*用于存放通用类型的数据;aSEO靠我ct_hi_*存放历史数据;act_re_*存放流程定义的内容和所需静态资源;act_ru_*存放activiti运行时所需的数据。 表名解释act_ge_bytearray通用的流程SEO靠我定义和流程资源act_ge_property系统相关属性act_hi_actinst历史的流程实例act_hi_attachment历史的流程附件act_hi_comment历史的说明性信息act_hSEO靠我i_detail历史的流程运行中的细节信息act_hi_identitylink历史的流程运行过程中用户关系act_hi_procinst历史的流程实例act_hi_taskinst历史的任务实例acSEO靠我t_hi_varinst历史的流程运行中的变量信息act_re_deployment部署单元信息act_re_model模型信息act_re_procdef已部署的流程定义act_ru_event_sSEO靠我ubscr运行时事件act_ru_execution运行时流程执行实例act_ru_identitylink运行时用户关系信息,存储任务节点与参与者的相关信息act_ru_job运行时作业act_ruSEO靠我_task运行时任务act_ru_variable运行时变量表

观察下面的类关系图,通过activiti.cfg.xml的配置,activiti会生成5个service,用于操作25张表。RepositSEO靠我uryService用来操作act_re_*表,HistoryService用来操作act_hi_*表,RuntimeService用来操作act_ru_*表。

接下来介绍如何在IDEA中创建流程定义。SEO靠我不过在操作之前,大家需要设置IDEA的编码格式,不然在使用bpmn时会出现中文乱码。点击菜单栏Help->Edit Custom VM options,打开文件,在文件的最后一行加入编码格式,如下所示SEO靠我

-Dfile.encoding=UTF-8

准备完毕后,在resources目录下创建bpmn目录,然后在bpmn目录下新建一个bpmn文件,命名随意,但最好有意义。比如我要做请假流程,此处命名为LeaSEO靠我ve.bpmn。bpmn的内容如下图所示。此处我们设置了3个节点:提交流程申请、部门经理审批和财务审批,对应的执行人分别设置为worker、manager和money。

bpmn文件的内容本质为XML文SEO靠我件,我们可以把新建的Leave.bpmn复制并重命名为Leave.bpmn.xml,查看相关的xml内容。其次我们还可以将绘制的流程导出图片,可供业务人员理解。具体如下:右键Leave.bpmn.xmSEO靠我l文件,选择Diagrams–Show BPMN 2.0 Designer,弹出的文件就是图片化的流程,然后点击Export to Image File按钮,选择存储路径,就可以将图片保存下来。

bpmSEO靠我n定义好之后,我们需要把定义好的流程保存到数据库中,通过activiti提供的API即可。在你的test目录的java文件下写入以下代码: /*** 部署流程定义 文件上传方式* 就是SEO靠我把定义好的bpmn,保存到数据库中*/@Testpublic void testDeployment() {//创建processEngineProcessEngine processEngine =SEO靠我 ProcessEngines.getDefaultProcessEngine();//得到RepositoryService实例RepositoryService repositoryServiceSEO靠我 = processEngine.getRepositoryService();//使用repositoryService进行部署Deployment deployment = repositorySSEO靠我ervice.createDeployment().addClasspathResource("bpmn/Leave.bpmn")//添加bpmn资源.addClasspathResource("bpSEO靠我mn/Leave.bpmn.png")//添加png资源.name("请假申请流程").deploy();//输出部署信息System.out.println("流程部署Id:" + deploymeSEO靠我nt.getId());System.out.println("流程部署名称:" + deployment.getName());} 流程定义好了,数据库也存好了,接下来就要启动定义SEO靠我好的流程了。通过下列代码即可开启一个流程实例: /**启动流程实例,相当于开启一个流程*/@Testpublic void testStartProcess() {//创建procesSEO靠我sEngineProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();//获取RunTimeServiceRuntSEO靠我imeService runtimeService = processEngine.getRuntimeService();//启动流程,这个 key是当时定义Leave.bpmn时填写的id(即第一SEO靠我张bpmn图片,左侧蓝色框框中,id对应的值,这个是自定义的)ProcessInstance processInstance = runtimeService.startProcessInstanceSEO靠我ByKey("myLeave");//输出内容System.out.println("流程定义id:" + processInstance.getProcessDefinitionId());SystSEO靠我em.out.println("流程实例id:" + processInstance.getId());System.out.println("当前活动id:" + processInstance.gSEO靠我etActivityId());} 流程启动成功后,就要查询当前个人待执行的任务,此次任务的执行人分别是worker->manager->money。 /*** 查询SEO靠我当前个人待执行的任务*/@Testpublic void testFindPersonalTaskList() {//任务负责人String assignee = "worker";ProcessEnSEO靠我gine processEngine = ProcessEngines.getDefaultProcessEngine();//创建TaskServiceTaskService taskServiceSEO靠我 = processEngine.getTaskService();//根据流程key和任务负责人查询任务。查询流程实例,有没有需要worker执行的节点List<Task> list = taskSSEO靠我ervice.createTaskQuery()//.processDefinitionKey("myLeave") //可以通过流程的key来查询.processInstanceId("25001"SEO靠我) //可以通过某个流程实例的id查询.taskAssignee(assignee).list();for (Task task : list) {System.out.println("流程实例idSEO靠我:" + task.getProcessInstanceId());System.out.println("任务id:" + task.getId());System.out.println("任务负SEO靠我责人:" + task.getAssignee());System.out.println("任务名称:" + task.getName());}} 上面代码执行完毕后,如果在控制台SEO靠我打印了内容(注:流程实例id是指这个流程的id,任务id是指当前节点的id),说明这个流程实例,有需要worker处理的节点,所以我们需要worker来完成当前节点,推动流程前进,所以,使用下面的代码SEO靠我,完成当前节点(需要worker执行的工作)。注意:下面代码执行完毕后,worker的工作就完成了,下一个节点需要由manager来完成。 //完成任务。当worker的任务执行完毕时SEO靠我,该流程向前推进,到了manager需要完成的节点@Testpublic void completeTask() {//获取引擎ProcessEngine processEngine = ProcesSEO靠我sEngines.getDefaultProcessEngine();//获取taskServiceTaskService taskService = processEngine.getTaskSerSEO靠我vice();//根据流程key和任务负责人 查询任务//返回一个任务对象,查询实例id是25001,执行者是worker的任务Task task = taskService.createTaskQuSEO靠我ery() // .processDefinitionKey("myLeave").processInstanceId("25001").taskAssignee("worker").SEO靠我singleResult();//完成任务,参数:任务IdtaskService.complete(task.getId());} 到目前为止,我们已经学会了通过bpmn定义流程,然SEO靠我后开启一个流程实例,并由相关人员(worker、manager等)推动流程前进。其实在bpmn文件中,我们可以定义多个流程,(虽然可以定义多个流程,但是为了容易理解,最好别这么做。建议一个bpmn定义SEO靠我一个流程,便于理解),接下来,我们通过代码,来查看某个bpmn文件下,定义的所有流程。 //查询流程定义,一个bpmn可以定义多个流程,该方法就是查询一个bpmn下定义的所有流程@TeSEO靠我stpublic void queryProcessDefinition() {//获取引擎ProcessEngine processEngine = ProcessEngines.getDefaulSEO靠我tProcessEngine();//获取repositoryServiceRepositoryService repositoryService = processEngine.getRepositSEO靠我oryService();//得到ProcessDefinitionQuery对象ProcessDefinitionQuery processDefinitionQuery = repositorySSEO靠我ervice.createProcessDefinitionQuery();//查询出当前所有的流程定义,查询Leave.bpmn文件定义了哪些流程(注意:Leave.bpmn在创建时,我们给他的idSEO靠我是myLeave)List<ProcessDefinition> definitionList = processDefinitionQuery.processDefinitionKey("myLeaSEO靠我ve").orderByProcessDefinitionVersion().desc().list();//输出流程定义信息for (ProcessDefinition processDefinitSEO靠我ion : definitionList) {System.out.println("流程定义id=" + processDefinition.getId());System.out.println(SEO靠我"流程定义name=" + processDefinition.getName());System.out.println("流程定义key=" + processDefinition.getKey(SEO靠我));System.out.println("流程定义version=" + processDefinition.getVersion());System.out.println("流程部署id=" SEO靠我+ processDefinition.getDeploymentId());}} 定义完流程后,我们可以开启一个流程实例,也可以同时开启多个流程实例。那么,我们怎么查看一个流程下有SEO靠我多少个正在执行的流程实例呢?可以通过下面的代码来实现: //查询某个流程下的所有进行中的流程实例@Testpublic void queryProcessInstance() {//流SEO靠我程定义keyString processDefinitionKey = "myLeave";ProcessEngine processEngine = ProcessEngines.getDefaulSEO靠我tProcessEngine();//获取RuntimeServiceRuntimeService runtimeService = processEngine.getRuntimeService()SEO靠我;List<ProcessInstance> list = runtimeService.createProcessInstanceQuery().processDefinitionKey(proceSEO靠我ssDefinitionKey).list();for (ProcessInstance processInstance : list) {System.out.println("----------SEO靠我--------------");System.out.println("流程实例id:" + processInstance.getProcessInstanceId());System.out.pSEO靠我rintln("所属流程定义id:" + processInstance.getProcessDefinitionId());System.out.println("是否执行完成:" + procesSEO靠我sInstance.isEnded());System.out.println("是否暂停:" + processInstance.isSuspended());System.out.println(SEO靠我"当前活动标识:" + processInstance.getActivityId());System.out.println("业务关键字:" + processInstance.getBusineSEO靠我ssKey());}} 如果后期发现某个流程定义得不对,要把它删除掉,该如何操作呢?注意,删除流程时要留意该流程有没有进行中的流程实例,如果存在流程实例,要使用级联删除才行。 SEO靠我 //删除流程定义@Testpublic void deleteDeployment() {//流程部署idString deploymentId = "2501";ProcessEngineSEO靠我 processEngine = ProcessEngines.getDefaultProcessEngine();//通过流程引擎获取repositoryServiceRepositoryServiSEO靠我ce repositoryService = processEngine.getRepositoryService();//删除流程定义,如果该流程定义已有流程实例启动,则删除时会报错repositoSEO靠我ryService.deleteDeployment(deploymentId);//设置为true,级联删除流程定义。即使该流程有流程实例启动,也可以删除//repositoryService.deSEO靠我leteDeployment(deploymentId, true);} 有时候我们还需要查看bpmn和png文件,观察某个流程包含哪些步骤,可是对于不懂开发的业务人员来说,总不能直SEO靠我接去代码中去看吧!因此,我们可以把bpmn和png从数据库中下载下来,保存在指定的服务器路径下。然后在页面中,通过img标签的形式,把下载的图片展示出来,这样就很方便了。此处只讲解如何从数据库下载文件SEO靠我。(将下载好的文件展示在页面,大家自行解决)。 //下载bpmn和png文件@Testpublic void queryBpmnFile() throws IOException {/SEO靠我/得到引擎ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();//获取repositoryServiceRepSEO靠我ositoryService repositoryService = processEngine.getRepositoryService();//得到查询器,设置查询条件,得到想要的流程定义ProcSEO靠我essDefinition processDefinition = repositoryService.createProcessDefinitionQuery().processDefinitionSEO靠我Key("myLeave").singleResult();//通过流程定义信息,得到部署IdString deploymentId = processDefinition.getDeploymentSEO靠我Id();//通过repositoryService的方法,实现读取图片信息和bpmn信息//png图片的流InputStream pngInput = repositoryService.getReSEO靠我sourceAsStream(deploymentId, processDefinition.getDiagramResourceName());//bpmn文件的流InputStream bpmnISEO靠我nput = repositoryService.getResourceAsStream(deploymentId, processDefinition.getResourceName());//构造SEO靠我OutputStream的流File file_png = new File("D:\\Leave.bpmn.png");File file_bpmn = new File("D:\\Leave.bpSEO靠我mn");FileOutputStream pngOut = new FileOutputStream(file_png);FileOutputStream bpmnOut = new FileOutSEO靠我putStream(file_bpmn);//输入流、输出流的转换IOUtils.copy(pngInput, pngOut);IOUtils.copy(bpmnInput, bpmnOut);//关SEO靠我闭流bpmnOut.close();bpmnOut.close();bpmnInput.close();pngInput.close();} 接下来我们介绍,怎么查看某个流程实例的执SEO靠我行情况,或者是某个流程下的所有实例的执行情况。这种功能很实用,我们可以把查询到的数据显示在页面,可以更直观地观察某个流程实例执行到了哪一步。关于查询流程的执行情况,这里提供了两种方式,第一种:如果查询SEO靠我条件中包含某个流程实例的id,那么就只查看这个流程实例的执行情况,这种情况更实用一些;第二种:如果查询条件中包含某个流程的定义id,那么就查看这个流程下所有流程实例的执行情况,这种情况或许不常用。 SEO靠我 //查询某个流程实例或者某个流程下的所有实例的执行情况@Testpublic void findHistoryInfo() {//得到引擎ProcessEngine processEngSEO靠我ine = ProcessEngines.getDefaultProcessEngine();//获取historyServiceHistoryService historyService = proSEO靠我cessEngine.getHistoryService();//获取actinst表的查询对象HistoricActivityInstanceQuery instanceQuery = historSEO靠我yService.createHistoricActivityInstanceQuery();//根据流程实例Id,查询单个流程实例的执行情况instanceQuery.processInstanceSEO靠我Id("5001");//根据流程定义ID,查询该流程所有实例的执行情况//instanceQuery.processDefinitionId("myLeave:1:2504");instanceQuSEO靠我ery.orderByHistoricActivityInstanceStartTime().asc();//查询所有内容List<HistoricActivityInstance> activitySEO靠我InstanceList = instanceQuery.list();//输出for (HistoricActivityInstance hi : activityInstanceList) {SySEO靠我stem.out.println(hi.getActivityId());System.out.println(hi.getActivityName());System.out.println(hi.SEO靠我getProcessDefinitionId());System.out.println(hi.getProcessInstanceId());System.out.println("--------SEO靠我-----------------");}}

总结:到目前为止,我们已经学习了activiti的基础操作,对于activiti数据库那几张常用的表大家最好能够知道,了解表结构后,出了问题也是容易排查的。SEO靠我另外,activiti虽然提供了工作流引擎的能力,但是在前端页面的展示功能,activiti是没有提供的,如果想要在页面更直观的查看流程的执行情况,还是要和前端交互。网上有不少activiti与前端整SEO靠我合的案例,大家可以参考,搭建属于自己的工作流框架。废话不多说,接下来我们介绍下activiti更高级的使用。

在开始前,大家需要明白两个概念,ProcessDefinition代表流程定义,ProcesSEO靠我sInstance代表流程实例。流程定义ProcessDefinition是以BPMN文件定义的一个工作流程,是一组工作规范,例如我们之前定义的请假流程。流程实例ProcessInstance则是指一SEO靠我个具体的业务流程。例如某个员工发起一次请假,就会实例化一个请假的流程实例,并且每个不同的流程实例之间是互不影响的。另外,activiti是一个专注于工作流程的框架,它和我们的业务是完全分离的,可是在实SEO靠我际应用中,一个流程必须要依赖于系统业务,因此,我们就需要把流程与业务整合在一起,说白了,就是把业务id存入流程实例表中,形成对应关系。 //启动一个流程实例时,和业务绑定起来@SEO靠我Testpublic void addBusinessKey() {//获取流程引擎ProcessEngine processEngine = ProcessEngines.getDefaultProSEO靠我cessEngine();//获取RuntimeServiceRuntimeService runtimeService = processEngine.getRuntimeService();//启SEO靠我动流程实例的过程中,添加businesskey//第一个参数:流程定义的key 第二个参数:业务关键字ProcessInstance instance = runtimeService.startPrSEO靠我ocessInstanceByKey("myLeave", "yeWuId");//输出System.out.println("businessKey:" + instance.getBusinessSEO靠我Key());} 挂起、激活流程实例:有很多时候,我们需要暂时停止一个流程,过一段时间就要恢复。例如月底不接受报销审批流程,年底不接受借贷审批流程,或者非工作日不接受售后报销SEO靠我流程等,这个时候,就可以将流程进行挂起操作。挂起后的流程就不会再继续执行。

在挂起流程时,有两种操作方式:一种是挂起流程定义,此时该流程定义下的所有流程实例都不可执行;另一种是挂起某个流程实例,对其他流SEO靠我程实例是没有影响的。注意:如果流程定义或者流程实例挂起后,在挂起状态下推动流程实例是会抛出异常的。 //全部流程实例的 挂起和激活@Testpublic void suspenSEO靠我dAllProcessInstance() {//获取流程引擎ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine(SEO靠我);//获取repositoryServiceRepositoryService repositoryService = processEngine.getRepositoryService();//SEO靠我查询流程定义,获取流程定义的查询对象ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQueSEO靠我ry().processDefinitionKey("myLeave").singleResult();//查询当前流程定义的实例是否都是挂起状态,true表示已挂起,false表示未挂起booleaSEO靠我n suspended = processDefinition.isSuspended();//获取流程定义的idString definitionId = processDefinition.getSEO靠我Id();//如果是挂起状态,改为激活状态if (suspended) {//如果是挂起,可以执行激活的操作。参数1:流程定义id;参数2:是否激活;参数3:激活时间repositoryServiceSEO靠我.activateProcessDefinitionById(definitionId, true, null);System.out.println("流程定义id:" + definitionIdSEO靠我 + ",已激活");} else {//如果是激活状态,改为挂起状态。参数1:流程定义id;参数2:是否暂停;参数3:暂停时间repositoryService.suspendProcessDefiSEO靠我nitionById(definitionId, true, null);System.out.println("流程定义id:" + definitionId + ",已挂起");}}//挂起和激活SEO靠我单个流程实例@Testpublic void suspendSingleProcessInstance() {//获取流程引擎ProcessEngine processEngine = ProcessSEO靠我Engines.getDefaultProcessEngine();//runtimeServiceRuntimeService runtimeService = processEngine.getRSEO靠我untimeService();//查询流程实例,获取流程实例的查询对象ProcessInstance processInstance = runtimeService.createProcessInSEO靠我stanceQuery().processInstanceId("5001").singleResult();//查询当前流程定义的实例是否都是挂起状态,true表示已挂起,false表示未挂起booSEO靠我lean suspended = processInstance.isSuspended();//获取流程实例的idString instanceId = processInstance.getId(SEO靠我);//如果是挂起状态,改为激活状态if (suspended) {//如果是挂起,可以执行激活的操作runtimeService.activateProcessInstanceById(instanSEO靠我ceId);System.out.println("流程实例id:" + instanceId + ",已激活");} else {//如果是激活状态,改为挂起状态runtimeService.susSEO靠我pendProcessInstanceById(instanceId);System.out.println("流程实例id:" + instanceId + ",已挂起");}} SEO靠我 流程变量的概念

流程变量是Activiti中非常重要的角色。我们之前定义的请假流程并没有用到流程变量,每个步骤都是非常固定的,但是,当我们需要实现一些复杂的业务流程,比如出差3天以内由部门经理审SEO靠我批,3天以上需要增加总经理审批这样的流程时,就需要用到流程变量了。流程变量不仅可以动态控制流程走势,还能通过变量动态地设置任务节点的负责人,这种情况在实际工作中是很常见的。

注:流程变量和之前介绍的业务SEO靠我关键字其实是有些相似的,都可以携带业务信息。并且也都可以通过activiti的api查询出来。但是通常在使用过程中,应该尽量减少流程变量中的业务信息,这样能够减少业务代码对activiti工作流的代码SEO靠我侵入。

流程变量的类型是Map。变量值不仅可以是字符串,也可以是POJO对象。但是当需要将一个POJO对象放入流程变量时,要注意这个对象必须实现序列化接口Serializable。流程变量的作用域有2种SEO靠我:Global变量和Local变量。Global是流程变量的默认作用域,作用范围是整个流程实例,Global变量中的变量名不能重复,如果设置了相同的变量名,后面设置的值会覆盖之前设置的变量值。LocaSEO靠我l的作用域只针对一个任务(节点),Local变量名可以和Global变量名相同,不会有影响。

在介绍流程变量的使用方法之前,我们先定义一个有分支情况的请假流程,如下图所示。

bpmn定义好流程之后,我们要SEO靠我使用代码,把流程部署到数据库。这个代码和之前部署流程的代码一样的。 //部署流程@Testpublic void testDeployment() {//创建processEngineSEO靠我ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();//得到RepositoryService实例ReposiSEO靠我toryService repositoryService = processEngine.getRepositoryService();//使用repositoryService进行部署DeploySEO靠我ment deployment = repositoryService.createDeployment().addClasspathResource("bpmn/evection-global.bpSEO靠我mn")//添加bpmn资源.name("出差申请流程-variables").deploy();//输出部署信息System.out.println("流程部署Id:" + deployment.gSEO靠我etId());System.out.println("流程部署名称:" + deployment.getName());} 流程部署完毕后,就可以开启一个流程实例。要注意,此处开启SEO靠我流程实例时,和之前不同,此处使用了流程变量,流程变量的值,与bpmn中设置了UEL表达式的地方是对应的。开启流程后,完成任务(推动节点)等操作就与之前的代码是一样的,这里就不再写出来了。 SEO靠我 //启动实例@Testpublic void testStartProcess() {//创建processEngineProcessEngine processEngine = ProcessESEO靠我ngines.getDefaultProcessEngine();//获取RunTimeServiceRuntimeService runtimeService = processEngine.getSEO靠我RuntimeService();//流程定义的keyString key = "myEvection";//流程变量的mapMap<String, Object> variables = new HSEO靠我ashMap<String, Object>();//设置流程变量Evection evection = new Evection();//出差2天。这记得bpmn中定义的${evection.numSEO靠我}吗?用于控制流程的执行逻辑evection.setNum(2d);//这里的值如果大于等于3,就会走不同的分支//通过evection.num来判断执行流程variables.put("evectiSEO靠我on", evection);//bpmn文件中,使用uel定义的任务负责人。使用流程变量动态设置负责人variables.put("assignee0", "李四");variables.put("SEO靠我assignee1", "王经理");variables.put("assignee2", "杨总经理");variables.put("assignee3", "张财务");//启动流程runtimSEO靠我eService.startProcessInstanceByKey(key, variables);} 接下来我们学习网关。网关是用来控制流程流向的重要组件,通常都会结合流程变量来SEO靠我使用。 使用网关可以更好地控制流程走势,其优势比单纯使用连线的condition条件来控制走势更为显著。网关有4种类型:排他网关ExclusiveGateWay,并行网关ParallelGatewaySEO靠我,包含网关InclusiveGateway和事件网关EventGateway,前三种网关比较常用,事件网关太过复杂,使用情况较少。下面分别介绍这几种网关:

注意: 排他网关只会选择一个为true的分支执SEO靠我行。如果有两个分支条件都为true,排他网关会选择id值(节点的id)较小的一条分支渠执行。如果从网关出去的线所有条件都不满足则系统抛出异常,排他网关的图片如下所示:

这个流程定义和刚才定义的出差流程是SEO靠我一样的,只不过引入了网关这个组件。具体的流程定义细节如下所示,先从右侧组件栏拖出组件,画出各个流程节点,并给本次流程定义id和Name赋值:

然后点击流程节点,依次给流程节点的Name和AssigneeSEO靠我属性赋值。此处的Assignee写死了,大家也可以使用流程变量,动态地设置节点负责人:

最后我们给连线添加判断条件来控制流程走势:

进行到这里,带网关的出差流程就定义完毕了。大家可以参考之前的代码,把定义SEO靠我的出差流程部署到数据库中,然后启动一个流程实例(不要忘记给evection.num赋值),并推动流程节点前进就可以了,此处就不做赘述了。 并行网关

并行网关允许将流程分成多条分支,也可以把多条分支汇聚到一SEO靠我起,并行网关的功能是基于进入和外出顺序流的:

fork分支:并行后的所有外出顺序流,为每个顺序流都创建一个并发分支。

join汇聚:所有到达并行网关,在此等待的进入分支,直到所有进入顺序流的分支都到达以后SEO靠我,流程才会通过汇聚网关。

注意:如果一个并行网关有多个进入和多个外出顺序流,它就同时具有分支和汇聚功能。这时,网关会先汇聚所有进入的顺序流,然后再切分成多个并行分支。与其他网关的主要区别是,并行网关不会SEO靠我解析条件。即使顺序流中定义了条件,也会被忽略。

包含网关

包含网关可以看做排他网关和并行网关的结合体。和排他网关一样,可以在外出顺序流上定义条件,包含网关会解析它们。但是主要区别在于包含网关可以选择多于一SEO靠我条顺序流,和并行网关一样。

包含网关的功能是基于进入和外出顺序流的:

分支:所有外出顺序流的条件都会被解析,结果为true的顺序流会以并行方式继续执行,会为每个顺序流创建一个分支。

汇聚:所有并行分支到达网SEO靠我关,会进入等待状态,直到每个包含流程token的进入顺序流的分支都到达。这是与并行网关的最大不同,换句话说,包含网关只会等待被选中执行了的进入顺序流。在汇聚之后,流程会穿过包含网关继续执行。 SEO靠我 结语:到这里我们就把activiti常用的功能介绍完毕了,还有一些其他的功能没有讲到,比如一个节点设置多个候选人,候选人认领、归还和交接任务等,这些功能在后期后进行完善。
“SEO靠我”的新闻页面文章、图片、音频、视频等稿件均为自媒体人、第三方机构发布或转载。如稿件涉及版权等问题,请与 我们联系删除或处理,客服邮箱:html5sh@163.com,稿件内容仅为传递更多信息之目的,不代表本网观点,亦不代表本网站赞同 其观点或证实其内容的真实性。

网站备案号:浙ICP备17034767号-2