Activiti使用

時間  2019-12-20
標籤 activiti 使用 简体版
原文   原文鏈接

Activiti是一個開源的工做流引擎，它實現了BPMN 2.0規範，能夠發佈設計好的流程定義，並經過api進行流程調度。java

Activiti 做爲一個聽從 Apache 許可的工做流和業務流程管理開源平臺，其核心是基於 Java 的超快速、超穩定的 BPMN2.0 流程引擎，強調流程服務的可嵌入性和可擴展性，同時更增強調面向業務人員。mysql

Activiti 流程引擎重點關注在系統開發的易用性和輕量性上。每一項 BPM 業務功能 Activiti 流程引擎都以服務的形式提供給開發人員。經過使用這些服務，開發人員可以構建出功能豐富、輕便且高效的 BPM 應用程序。git

核心組件介紹

1. 關鍵對象

  1. Deployment：流程部署對象，部署一個流程時建立。
  2. ProcessDefinitions：流程定義，部署成功後自動建立。
  3. ProcessInstances：流程實例，啓動流程時建立。
  4. Task：任務，在Activiti中的Task僅指有角色參與的任務，即定義中的UserTask。
  5. Execution：執行計劃，流程實例和流程執行中的全部節點都是Execution，如UserTask、ServiceTask等。

2. 服務接口

  1. ProcessEngine：流程引擎的抽象，經過它咱們能夠得到咱們須要的一切服務。
  2. RepositoryService：Activiti中每個不一樣版本的業務流程的定義都須要使用一些定義文件，部署文件和支持數據(例如BPMN2.0 XML文件，表單定義文件，流程定義圖像文件等)，這些文件都存儲在Activiti內建的Repository中。RepositoryService提供了對 repository的存取服務。
  3. RuntimeService：在Activiti中，每當一個流程定義被啓動一次以後，都會生成一個相應的流程對象實例。RuntimeService提供了啓動流程、查詢流程實例、設置獲取流程實例變量等功能。此外它還提供了對流程部署，流程定義和流程實例的存取服務。
  4. TaskService: 在Activiti中業務流程定義中的每個執行節點被稱爲一個Task，對流程中的數據存取，狀態變動等操做均須要在Task中完成。TaskService提供了對用戶Task 和Form相關的操做。它提供了運行時任務查詢、領取、完成、刪除以及變量設置等功能。
  5. IdentityService: Activiti中內置了用戶以及組管理的功能，必須使用這些用戶和組的信息才能獲取到相應的Task。IdentityService提供了對Activiti 系統中的用戶和組的管理功能。
  6. ManagementService: ManagementService提供了對Activiti流程引擎的管理和維護功能，這些功能不在工做流驅動的應用程序中使用，主要用於Activiti系統的平常維護。
  7. HistoryService: HistoryService用於獲取正在運行或已經完成的流程實例的信息，與RuntimeService中獲取的流程信息不一樣，歷史信息包含已經持久化存儲的永久信息，並已經被針對查詢優化。

如今至少要知道有這些對象和接口。並結合Activiti Api這一章節來看，你就會對部署流程、啓動流程、執行任務等操做有一個基本的概念。以後編寫一個簡單的單元測試，主要爲了測試activiti.cfg.xml配置的是否正確，流程是否能夠被部署便可。github

至於與Spring的集成，必定要熟悉基於Spring配置Activiti，以及事務的處理。web

官方demo使用（activiti-explorer）

activiti工做流歷史版本下載，更改版本號後在瀏覽器地址欄回車便可spring

https://github.com/Activiti/Activiti/releases/download/activiti-5.16.3/activiti-5.16.3.zipsql

下載後解壓獲得：數據庫

 

初始化數據庫（本文采用的mysql數據庫）apache

\wars\activiti-explorer.war解壓到tomcat的webapps下，並修改\activiti-explorer\WEB-INF\classes中的db.properties：segmentfault

#db=h2
#jdbc.driver=org.h2.Driver
#jdbc.url=jdbc:h2:mem:activiti;DB_CLOSE_DELAY=1000
#jdbc.username=sa
#jdbc.password=

db=mysql
jdbc.driver=com.mysql.jdbc.Driver
jdbc.url=jdbc:mysql://127.0.0.1/activititest?useUnicode=true&characterEncoding=utf8
jdbc.username=root
jdbc.password=123456

訪問首頁，打開瀏覽器輸入http://localhost:8080/activiti-explore，使用用戶kermit，密碼kermit登陸

 

 

 

 

使用idea進行activiti工做流開發

1.安裝IDEA中編輯Activiti流程的插件actiBPM，安裝完成後重啓IDEA

2.新建一個maven工程，pom.xml文件內容爲：

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

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.xuan</groupId>
    <artifactId>testactiviti</artifactId>
    <version>1.0-SNAPSHOT</version>

    <name>testactiviti</name>
    <!-- FIXME change it to the project's website -->
    <url>http://www.example.com</url>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <maven.compiler.source>1.7</maven.compiler.source>
        <maven.compiler.target>1.7</maven.compiler.target>
    </properties>

    <dependencies>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.11</version>
            <!--<scope>test</scope>-->
        </dependency>
        <!--- Activiti依賴導入 -->
        <dependency>
            <groupId>org.activiti</groupId>
            <artifactId>activiti-spring</artifactId>
            <version>5.22.0</version>
        </dependency>
        <dependency>
            <groupId>org.activiti</groupId>
            <artifactId>activiti-engine</artifactId>
            <version>5.22.0</version>
            <exclusions>
                <exclusion>
                    <artifactId>slf4j-api</artifactId>
                    <groupId>org.slf4j</groupId>
                </exclusion>
                <exclusion>
                    <artifactId>spring-beans</artifactId>
                    <groupId>org.springframework</groupId>
                </exclusion>
                <exclusion>
                    <artifactId>jackson-core-asl</artifactId>
                    <groupId>org.codehaus.jackson</groupId>
                </exclusion>
                <exclusion>
                    <artifactId>commons-lang3</artifactId>
                    <groupId>org.apache.commons</groupId>
                </exclusion>
                <exclusion>
                    <artifactId>commons-lang3</artifactId>
                    <groupId>org.apache.commons</groupId>
                </exclusion>
            </exclusions>
        </dependency>
        <!--MySQL 驅動包，若是是其餘庫的話須要換驅動包-->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>8.0.15</version>
        </dependency>
    </dependencies>
</project>

建立資源文件夾resource，並把目錄設置爲Test Resources Root

目錄結構爲

 

在resource目錄中新建activiti.cfg.xml：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">
    <bean id="processEngineConfiguration" class="org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration">
        <property name="jdbcDriver" value="com.mysql.jdbc.Driver"></property>
        <property name="jdbcUrl"
                  value="jdbc:mysql://localhost:3306/testactiviti?useUnicode=true&amp;characterEncoding=utf8&amp;serverTimezone=GMT%2B8"></property>
        <property name="jdbcUsername" value="root"></property>
        <property name="jdbcPassword" value="123456"></property>
        <property name="databaseSchemaUpdate" value="true"></property>
    </bean>
</beans>

在resources下面新建一個WorkTest.bpmn文件:

 

新建以後頁面會變成以下圖所示這樣，中間是畫布，右邊是一些元素，左邊是每一個元素的一些詳細信息，直接拖拽右邊的元素就能夠畫流程了。

畫完流程圖以後能夠更改整個流程的name和元素的name，assignee，

可是畫圖以後，沒有鏈接圖標怎麼辦呢
把鼠標放在開頭的那個圖標上，此時光標的形狀改變了。 拖到另外一個上面，鏈接成功了。
怎麼鏈接成功的呢？ 把鼠標放到圖標的正中心，而後會看到光標變成了「扇子類型」的樣子（黑白相間）。只要看到變成這個樣子，就能夠拖動到另外一個圖標中，進行鏈接了

我這裏畫的一個很簡單的流程圖，只用到了startEvent、endEvent和userTask。個人流程是作的訂單的審批。如圖：

畫完圖後，可是並無生成png圖片，這個時候重命名剛纔建立的文件，把後綴改爲xml，而後右鍵

 

這個時候發現顯示的時候有亂碼：

 

解決方法：

找到idea安裝目錄bin目錄下以下圖所示兩個文件，用編輯器打開，在文件末尾添加 -Dfile.encoding=UTF-8 ，而後重啓idea，再打開流程圖就會發現中文已經能夠正常顯示了。

 

 解決問題後，把xml文件從新改爲bpmn格式，和png圖片一塊兒壓縮成zip包進行部署。

1.建立須要的表格

Activiti提供使用代碼或者配置文件的方式來配置數據庫的信息，新建MyActiviti.java來生成數據庫信息：

public class MyActiviti {
    @Test
    public void creatTable() {
        ProcessEngine processEngine = ProcessEngineConfiguration.createProcessEngineConfigurationFromResource("activiti.cfg.xml").buildProcessEngine();
        System.out.println("processEngine:"+ processEngine);
    }

    @Test
    public void creatTable2() {
        ProcessEngineConfiguration processEngineConfiguration = ProcessEngineConfiguration.createStandaloneProcessEngineConfiguration();
        //鏈接數據庫配置
        processEngineConfiguration.setJdbcDriver("com.mysql.jdbc.Driver");
        processEngineConfiguration.setJdbcUrl("jdbc:mysql://localhost:3306/activiti?useUnicode=true&characterEncoding=utf8&serverTimezone=GMT%2B8");
        processEngineConfiguration.setJdbcUsername("root");
        processEngineConfiguration.setJdbcPassword("123456");

        /**
         public static final String DB_SCHEMA_UPDATE_FALSE = "false";//不能自動建立表，須要表存在
         public static final String DB_SCHEMA_UPDATE_CREATE_DROP = "create-drop";//先刪除表再建立表
         public static final String DB_SCHEMA_UPDATE_TRUE = "true";//若是表不存在，自動建立表
         */
        processEngineConfiguration.setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_CREATE_DROP);
        //工做流的核心對象，ProcessEngine對象
        ProcessEngine processEngine = processEngineConfiguration.buildProcessEngine();
        System.out.println("processEngine:"+ processEngine);
    }
}

運行這個類的creatTable或creatTable2以後，自動幫咱們把對應的數據庫表建立起來，有些說23-25張表都是有可能的，我這裏是生成了25張表。

全部的表都以ACT_開頭。 第二部分是表示表的用途的兩個字母標識。 用途也和服務的API對應。

  • ACT_RE_*: 'RE'表示repository。 這個前綴的表包含了流程定義和流程靜態資源 （圖片，規則，等等）。
  • ACT_RU_*: 'RU'表示runtime。 這些運行時的表，包含流程實例，任務，變量，異步任務，等運行中的數據。 Activiti只在流程實例執行過程當中保存這些數據， 在流程結束時就會刪除這些記錄。 這樣運行時表能夠一直很小速度很快。
  • ACT_ID_*: 'ID'表示identity。 這些表包含身份信息，好比用戶，組等等。
  • ACT_HI_*: 'HI'表示history。 這些表包含歷史數據，好比歷史流程實例， 變量，任務等等。
  • ACT_GE_*: 通用數據， 用於不一樣場景下，如存放資源文件。

每一個表和字段的具體含義能夠參考：http://www.javashuo.com/article/p-bhlvlsex-hy.html

2.部署流程

建表成功以後就能夠開始部署流程了，部署以後就能夠在act_re_procdef表中看到對相應的流程信息.

    @Test
    public void deploy() {
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
        RepositoryService repositoryService = processEngine.getRepositoryService();
        DeploymentBuilder builder = repositoryService.createDeployment();//建立一個部署的構建器
        builder.addClasspathResource("WorkTest.bpmn");//從類路徑中添加資源,一次只能添加一個資源
        builder.name("訂單審批");
        builder.category("辦公類別");
        Deployment deploy = builder.deploy();

        System.out.println("部署的id" + deploy.getId());
        System.out.println("部署的名稱" + deploy.getName());
    }
    //查詢流程
    @Test
    public void queryProcdef() {
        RepositoryService repositoryService = processEngine.getRepositoryService();
        //建立查詢對象
        ProcessDefinitionQuery query = repositoryService.createProcessDefinitionQuery();
        //添加查詢條件
        //query.processDefinitionKey("myProcess_2");//經過key獲取
        // .processDefinitionName("My process")//經過name獲取
        query.orderByProcessDefinitionId().asc();//根據ID排序
        //執行查詢獲取流程定義明細
        List<ProcessDefinition> pds = query.list();
        for (ProcessDefinition pd : pds) {
            System.out.println("ID:" + pd.getId() + ",NAME:" + pd.getName() + ",KEY:" + pd.getKey() + ",VERSION:" + pd.getVersion() + ",RESOURCE_NAME:" + pd.getResourceName() + ",DGRM_RESOURCE_NAME:" + pd.getDiagramResourceName());
        }
    }

 

3.執行工做流

    @Test
    public void startProcess() {
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
        //指定執行咱們剛纔部署的工做流程，就是bomn文件定義的流程ID或者名稱
        String processDefiKey = "myProcess_1";
        //取運行時服務
        RuntimeService runtimeService = processEngine.getRuntimeService();
        //取得流程實例
        ProcessInstance pi = runtimeService.startProcessInstanceByKey(processDefiKey);//經過流程定義的key 來執行流程
        System.out.println("流程實例id:" + pi.getId());//流程實例id
        System.out.println("流程定義id:" + pi.getProcessDefinitionId());//輸出流程定義的id
    }

啓動流程以後就會有相應的任務產生，存在act_ru_task表中，能夠查看任務節點

4.查詢信息

    @Test
    public void queryTask() {
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
        TaskService taskService = processEngine.getTaskService();
        //processInstanceId,就是act_ru_task的PROC_INST_ID_
        String processInstanceId = "12501";
        List<Task> tasks = taskService.createTaskQuery().processInstanceId(processInstanceId).list();

        //首次運行的時候這個沒有輸出，由於第一次運行的時候掃描act_ru_task的表裏面是空的，但第一次運行完成以後裏面會添加一條記錄，以後每次運行裏面都會添加一條記錄
        for (Task task : tasks) {
            System.out.println("taskId:" + task.getId() +
                    ",taskName:" + task.getName() +
                    ",assignee:" + task.getAssignee() +
                    ",createTime:" + task.getCreateTime());
        }
    }

也能夠根據其它各類條件進行查詢

    //查詢流程定義明細
    @Test
    public void queryProcdef() {
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
        RepositoryService repositoryService = processEngine.getRepositoryService();
        //建立查詢對象
        ProcessDefinitionQuery query = repositoryService.createProcessDefinitionQuery();
        //添加查詢條件
        query.processDefinitionKey("myProcess_1");//經過key獲取
        // .processDefinitionName("My process")//經過name獲取
        // .orderByProcessDefinitionId()//根據ID排序
        //執行查詢獲取流程定義明細
        List<ProcessDefinition> pds = query.list();
        for (ProcessDefinition pd : pds) {
            System.out.println("ID:" + pd.getId() + ",NAME:" + pd.getName() + ",KEY:" + pd.getKey() + ",VERSION:" + pd.getVersion() + ",RESOURCE_NAME:" + pd.getResourceName() + ",DGRM_RESOURCE_NAME:" + pd.getDiagramResourceName());
        }
    }

5.處理任務

    //完成任務
    @Test
    public void compileTask(){
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
        String taskId="12504";//任務id，act_ru_task的ID_
        processEngine.getTaskService().complete(taskId);
        System.out.println("當前任務執行完畢");
    }

其它還有刪除流程等各類操做，能夠參考http://www.javashuo.com/article/p-pfhgbmjv-cv.html

相關文章
相關標籤/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公眾號
   歡迎關注本站公眾號,獲取更多信息
聯繫我們 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程