Activiti6.0学习实践（6）-核心api:RepositoryService 存储服务

一时失言乱红尘 2023-07-03 10:45 19阅读 0赞

通过前面的学习，我们了解到activiti是通过 activiti.cfg.xml获取到 ProcessEnigneConfiguration对象，这个对象负责管理流程引擎的配置相关信息，通过这个配置管理对象，我们可以创建出ProcessEnigne流程引擎对象。通过流程引擎对象我们可以得到各种服务对象，如：

1.  repositoryService(流程存储服务)
2.  runtimeService（管理运行时）
3.  TaskService（管理流程中的任务）
4.  IdentityService（管理权限）
5.  FormService(管理表单)，
6.  Historyservice(运行结束的查询功能)
7.  ManagementService（流程引擎基础管理）
8.  DynamicBpmService（动态管理流程-6.0新增的服务）

# 1、RepositoryService #

流程存储服务RepositoryService主要的功能如下：

1.  管理流程定义文件xml和静态资源的服务
2.  对特定流程的暂停和激活
3.  流程定义启动权限管理
4.  部署文件构造器DeploymentBuilder
5.  部署文件查询器DeploymentQuery
6.  流程定义查询对象ProcessDefinition
7.  流程定义的java格式BpmnModel

## 1.1 创建新的module ##

在idea中通过前面的acitivi脚手架创一个新的module

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Nzb2xv_size_16_color_FFFFFF_t_70][]

创建完成后如下图所示：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Nzb2xv_size_16_color_FFFFFF_t_70 1][]

## 1.2 创建一个RepositoryService的测试类 ##

接着我们在test目录下创建一个测试类

![20200205174608481.png][]

先建立一下这个类的雏形

package com.study.activiti.coreapi;
    
    import org.activiti.engine.RepositoryService;
    import org.activiti.engine.test.ActivitiRule;
    import org.junit.Rule;
    import org.junit.Test;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    
    /**
     * Describe:
     *
     * @author cwqsolo
     * @date 2020/01/31
     */
    public class RerostoryServiceTest {
    
        private static final Logger logger = LoggerFactory.getLogger(RerostoryServiceTest.class);
    
        @Rule
        public ActivitiRule  activitiRule = new ActivitiRule();
    
        @Test
        public void  test(){
            RepositoryService repositoryService = activitiRule.getRepositoryService();
        }
    
    
    }

我们可以通过ctrl+repositoryService来查看一下这个核心api提供的接口，如下图，这些接口就是提供了前面说的主要功能。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Nzb2xv_size_16_color_FFFFFF_t_70 2][]

## 1.3 完善测试代码 ##

下面对于一次部署多个流程定义文件进行测试代码的补充

在上述代码中，通过一次部署两个流程定义文件，然后将流程定义内容打印出来，执行情况如下：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Nzb2xv_size_16_color_FFFFFF_t_70 3][]

## 1.4 流程的挂起和重新启动 ##

存储服务提供了流程的挂起和重新启动的接口代码如下：

@Test
    @org.activiti.engine.test.Deployment(resources = {"my-process.bpmn20.xml"})
    public void testSuspend() {
        RepositoryService repositoryService = activitiRule.getRepositoryService();
        ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery().singleResult();
        logger.info("processDefinition.id={}", processDefinition.getId());
    
        //将流程定义挂起，这个时候如果去启动会报告异常
        repositoryService.suspendProcessDefinitionById(processDefinition.getId());
    
        try {
            logger.info("开始启动");
            activitiRule.getRuntimeService().startProcessInstanceById(processDefinition.getId());
            logger.info("启动成功");
        } catch (Exception e) {
            logger.info("启动失败");
            logger.info(e.getMessage(),e);
        }
        //重新激活，并启动，这个时候可以启动成功
        repositoryService.activateProcessDefinitionById(processDefinition.getId());
        try {
            logger.info("重新激活，并开始启动");
            activitiRule.getRuntimeService().startProcessInstanceById(processDefinition.getId());
            logger.info("启动成功");
        } catch (Exception e) {
            logger.info("启动失败");
            logger.info(e.getMessage(),e);
        }
    
    
    }

执行日志如下：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Nzb2xv_size_16_color_FFFFFF_t_70 4][]

![20200205174618404.png][]

## 1.5 多次部署的情况 ##

接着我们可以对两个流程定义文件，进行多次部署，代码如下：

@Test
    public void test() {
        RepositoryService repositoryService = activitiRule.getRepositoryService();
    
        //创建一个流程部署对象,并部署两个流程定义文件
        DeploymentBuilder deployment = repositoryService.createDeployment();
        deployment.name("测试部署资源")
                .addClasspathResource("comm2Level.bpmn20.xml")
                .addClasspathResource("my-process.bpmn20.xml");
        //创建部署对象
        Deployment deploy = deployment.deploy();
        logger.info("deploy ={}", deploy);
    
        //创建第二个流程部署对象,并部署两个流程定义文件
        DeploymentBuilder deployment2 = repositoryService.createDeployment();
        deployment2.name("测试部署资源2")
                .addClasspathResource("comm2Level.bpmn20.xml")
                .addClasspathResource("my-process.bpmn20.xml");
        //创建部署对象
        Deployment deploy2 = deployment2.deploy();
        logger.info("deploy ={}", deploy2);
    
        //创建一个部署查询对象
        DeploymentQuery deploymentQuery = repositoryService.createDeploymentQuery();
        //因为是一次部署，所以可以用 singleResult
        //Deployment deployment1 = deploymentQuery.deploymentId(deploy.getId()).singleResult();
        //因为部署了两次，所以代码上要做相应变化，返回list
        List<Deployment> deployments = deploymentQuery.orderByDeploymenTime().asc().listPage(0, 100);
    
        //遍历deployments-- 用iter方式
        for (Deployment deployment1 : deployments) {
            logger.info("deployment = {}", deployment1);
        }
    
        logger.info("deploymentlist size = {}", deployments.size());
    
    
        //查询流程定义
        List<ProcessDefinition> processDefinitions = repositoryService.createProcessDefinitionQuery()
                //.deploymentId(deploy.getId())
                .orderByProcessDefinitionKey().asc()
                .listPage(0, 100);
    
        for (ProcessDefinition processDefinition : processDefinitions) {
            logger.info("processDefinition = {}， version = {}, key={}, id={}", processDefinition,
                    processDefinition.getVersion(),
                    processDefinition.getKey(),
                    processDefinition.getId());
        }
    
    
    }

执行日志如下：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Nzb2xv_size_16_color_FFFFFF_t_70 4][]

## 1.6 指定流程执行的用户和用户组 ##

存储服务提供了指定流程的执行用户和用户组的接口

下面是测试代码中的相关测试函数

//测

@Test
    @org.activiti.engine.test.Deployment(resources = {"my-process.bpmn20.xml"})
    public void testCandiateStarter() {
        RepositoryService repositoryService = activitiRule.getRepositoryService();
        ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery().singleResult();
        logger.info("processDefinition.id={}", processDefinition.getId());
    
        //创建流程和用户，用户组关系
        repositoryService.addCandidateStarterUser(processDefinition.getId(), "user");
        repositoryService.addCandidateStarterGroup(processDefinition.getId(), "groupadmin");
    
        //获取用户组关系信息
        List<IdentityLink> identityLinksForProcessDefinition
                = repositoryService.getIdentityLinksForProcessDefinition(processDefinition.getId());
    
        for (IdentityLink identityLink : identityLinksForProcessDefinition) {
            logger.info("identityLink = {}", identityLink);
    
        }
    
        //删除流程和用户组关系
        repositoryService.deleteCandidateStarterGroup(processDefinition.getId(), "groupadmin");
        repositoryService.deleteCandidateStarterUser(processDefinition.getId(), "user");
    
    
    }

试指定用户组来启动

执行的情况如下

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Nzb2xv_size_16_color_FFFFFF_t_70 5][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Nzb2xv_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20200205174618411.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Nzb2xv,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Nzb2xv_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20200205174613876.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Nzb2xv,size_16,color_FFFFFF,t_70
[20200205174608481.png]: https://img-blog.csdnimg.cn/20200205174608481.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Nzb2xv_size_16_color_FFFFFF_t_70 2]: https://img-blog.csdnimg.cn/20200205174608600.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Nzb2xv,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Nzb2xv_size_16_color_FFFFFF_t_70 3]: https://img-blog.csdnimg.cn/20200205174618412.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Nzb2xv,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Nzb2xv_size_16_color_FFFFFF_t_70 4]: https://img-blog.csdnimg.cn/20200205174618459.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Nzb2xv,size_16,color_FFFFFF,t_70
[20200205174618404.png]: https://img-blog.csdnimg.cn/20200205174618404.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Nzb2xv_size_16_color_FFFFFF_t_70 5]: https://img-blog.csdnimg.cn/20200205174618455.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Nzb2xv,size_16,color_FFFFFF,t_70