用bpmn規(guī)范定義好一個(gè)流程得到流程定義文件后，需要把該文件部署到activiti的數(shù)據(jù)庫(kù)后，這個(gè)流程才可以使用。

activiti中和流程定義相關(guān)的操作都需要使用RepositoryService這個(gè)服務(wù)組件來(lái)進(jìn)行。

activiti中所有的服務(wù)組件都需要通過流程引擎對(duì)象來(lái)獲取

一、RepositoryService服務(wù)組件

這個(gè)組件中提供了一系列管理流程定義和流程部署的api,我們可以使用這個(gè)組件中的api來(lái)部署流程

1.1 RepositoryService實(shí)例對(duì)象的獲取

使用流程引擎對(duì)象的實(shí)例方法processEngine.getRepositoryService();來(lái)獲取RepositoryService

  @Test
  public void test1() {
    ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
    RepositoryService repositoryService = processEngine.getRepositoryService();
    System.out.println(repositoryService);
  }

二、流程部署信息的描述,Deployment對(duì)象

在講解如何部署流程前，我們先了解下activiti如何描述流程的部署信息。activiti用Deployment這個(gè)接口來(lái)描述流程的部署信息，并自己提供了實(shí)現(xiàn)類。對(duì)應(yīng)activiti數(shù)據(jù)庫(kù)中的一張表ACT_RE_DEPLOYMENT

三、流程的部署

activiti使用DeploymentBuilder這個(gè)類的對(duì)象來(lái)部署流程，從這個(gè)類的名字就可以看出它的功能，部署一個(gè)流程并返回描述這次部署信息的對(duì)象。

使用RepositoryService服務(wù)組件的對(duì)象來(lái)獲取DeploymentBuilder對(duì)象

DeploymentBuilder deploymentBuilder = repositoryService.createDeployment();

然后給這個(gè)deploymentBuilder添加要部署的流程文件的位置

deploymentBuilder.addClasspathResource("process/process.bpmn");

我這里是在resources目錄下創(chuàng)建了process/process.bpmn流程定義文件,所以添加了這個(gè)路徑

還可以為本次部署添加名稱和分類

deploymentBuilder.name("vacation-test").category("test");

最后執(zhí)行部署

Deployment deploy = deploymentBuilder.deploy();

觀察數(shù)據(jù)庫(kù)ACT_RE_DEPLOYMENT表，會(huì)發(fā)現(xiàn)多了一條部署記錄。

完整的代碼為

  @Test
  public void test1() {
    ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
    RepositoryService repositoryService = processEngine.getRepositoryService();
    DeploymentBuilder deploymentBuilder = repositoryService.createDeployment();
    deploymentBuilder.addClasspathResource("process/process.bpmn");
    deploymentBuilder.name("vacation-test").category("test");
    Deployment deploy = deploymentBuilder.deploy();
    System.out.println(deploy);
  }

注意，默認(rèn)情況下多次部署同一流程圖在表中會(huì)產(chǎn)生多條記錄，用部署時(shí)間字段用來(lái)做區(qū)分

3.1 過濾重復(fù)部署的問題

為了防止資源沒有發(fā)生變化而再次執(zhí)行部署方法產(chǎn)生的重復(fù)部署，可以調(diào)用DeploymentBuilder的enableDuplicateFiltering()方法，這里的過濾方式是先查詢部署表，得到表中已有的部署對(duì)象集合，如果發(fā)現(xiàn)有一條部署記錄與將要部署的對(duì)象相同，就不會(huì)重復(fù)部署。所以部署時(shí)設(shè)置的name,category,資源名稱和內(nèi)容，只要有一個(gè)不一樣就不會(huì)被過濾掉

deploymentBuilder.enableDuplicateFiltering();//設(shè)置過濾重復(fù)部署

四、部署信息的管理

activiti在DeploymentQuery這個(gè)接口中封裝了管理部署信息的api,并自己提供了實(shí)現(xiàn)類，通過repositoryService服務(wù)組件來(lái)獲取其實(shí)現(xiàn)類對(duì)象。

DeploymentQuery deploymentQuery = repositoryService.createDeploymentQuery();

4.1 查詢部署信息

@Test
  public void test2() {
    ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
    RepositoryService repositoryService = processEngine.getRepositoryService();
    DeploymentQuery deploymentQuery = repositoryService.createDeploymentQuery();
    //根據(jù)deploymentId查詢
    String deploymentId="4201";
    Deployment singleResult = deploymentQuery.deploymentId(deploymentId)
        .deploymentName("vacation-test").singleResult();
    System.out.println(singleResult);
  }

查詢時(shí)，先給deploymentQuery對(duì)象拼接查詢條件,這里支持鏈?zhǔn)骄幊蹋纫粋€(gè)個(gè)的拼接查詢條件，最后這個(gè)

singleResult()方法執(zhí)行查詢，返回一個(gè)結(jié)果；如果根據(jù)設(shè)定的條件返回多個(gè)結(jié)果，調(diào)用singleResult()就會(huì)拋出異常，這時(shí)需要調(diào)用返回多個(gè)結(jié)果的查詢方法list()

4.2 刪除部署信息

因?yàn)椴渴鹦畔⒈砼c其他表有外鍵關(guān)聯(lián)，所以直接刪除部署表中的數(shù)據(jù)是刪不掉的，需要調(diào)用RepositoryService中的刪除方法來(lái)刪除

  @Test
  public void test3() {
    ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
    RepositoryService repositoryService = processEngine.getRepositoryService();
    String deploymentId="4201";
    boolean cascade=true;
    repositoryService.deleteDeployment(deploymentId, cascade);
  }

其中第2個(gè)參數(shù)cascade表示是否級(jí)聯(lián)刪除其他表的數(shù)據(jù)，直接給true就可以

五、流程定義及其管理

5.1 流程定義信息的描述

一個(gè)流程文件部署成功后，不僅會(huì)在部署表中記錄部署信息，同時(shí)也會(huì)在流程定義表act_re_procdef中添加一條流程定義信息，描述被部署的流程文件所定義的流程。

注意其中的這個(gè)KEY_字段對(duì)應(yīng)的就是流程定義文件中的process節(jié)點(diǎn)的id，activiti開啟流程時(shí)要使用這個(gè)字段。

<process id="process" isExecutable="true">
  <startEvent id="sid-26F630F1-0761-4247-8383-F63F913A310E"></startEvent>
  <userTask id="usertask1" name="apply vecation" activiti:assignee="kermit"></userTask>
  <sequenceFlow id="sid-85398367-B674-473A-B7AC-268635F0DF5D" sourceRef="sid-26F630F1-0761-4247-8383-F63F913A310E" targetRef="usertask1"></sequenceFlow>
  <userTask id="usertask2" name="manager agree" activiti:assignee="kermit"></userTask>
  <sequenceFlow id="sid-5372C6B1-7359-40AB-B0A4-3FF06F20790E" sourceRef="usertask1" targetRef="usertask2"></sequenceFlow>
  <endEvent id="sid-F621C8EF-13A5-4A49-BD5B-708BFB066576"></endEvent>
  <sequenceFlow id="sid-BCF9087D-36F4-4EDE-BD88-013AC74AB93A" sourceRef="usertask2" targetRef="sid-F621C8EF-13A5-4A49-BD5B-708BFB066576"></sequenceFlow>
 </process>

和部署信息一樣，activiti也有一個(gè)接口來(lái)描述這張表的信息,ProcessDefinition,并自己提供了實(shí)現(xiàn)類

5.2 流程定義信息的管理

activiti提供了ProcessDefinitionQuery這個(gè)接口，在其中封裝了流程定義信息查詢相關(guān)的api。查詢對(duì)象的獲取和使用與DeploymentQuery類似。

  @Test
  public void test1() {
    ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
    RepositoryService repositoryService = processEngine.getRepositoryService();
    ProcessDefinitionQuery processDefinitionQuery = repositoryService.createProcessDefinitionQuery();
    String processDefinitionKey="process";
    List<ProcessDefinition> list = processDefinitionQuery.processDefinitionKey(processDefinitionKey).list();
    for (ProcessDefinition processDefinition : list) {
      System.out.println(processDefinition);
    }
  }

六、總結(jié)

本文介紹了如何部署流程定義文件,以及對(duì)部署后生成的部署信息和流程定義信息的管理。

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

最新評(píng)論