activiti学习笔记(四) 配置器

activiti配置器

activiti配置器的作用

       一般在构建流程实例的时候, 会进行初始化,配置器就是可以在获取了流程配置实例,以及初始化之后可以进行一些额外的配置

activiti配置器的机制

allConfigurators集合添加

       在ProcessEngineConfigurationImpl这个类中调用init方法中initConfigurators方法,将所有流程配置器添加到allConfigurators这个集合,流程配置器有两种获取形式,第一种是直接通过bean方式注入到configurators遍历添加到allConfigurators集合,第二种是通过调用spi模式,加载到allConfigurators集合。最后将所有的按照照priority的大小进行排序

public void initConfigurators() {


    //一个list集合,存放所有ProcessEngineConfigurator
    allConfigurators = new ArrayList<ProcessEngineConfigurator>();

    //遍历Configurators将其添加到allConfigurators这个集合
    if (configurators != null) {
      for (ProcessEngineConfigurator configurator : configurators) {
        allConfigurators.add(configurator);
      }
    }

    //获取当前类加载器
    if (enableConfiguratorServiceLoader) {
      ClassLoader classLoader = getClassLoader();
      if (classLoader == null) {
        classLoader = ReflectUtil.getClassLoader();
      }

      //利用spi模式加载ProcessEngineConfigurator所有实现类 将其添加到allConfigurators集合
      ServiceLoader<ProcessEngineConfigurator> configuratorServiceLoader = ServiceLoader.load(ProcessEngineConfigurator.class, classLoader);
      int nrOfServiceLoadedConfigurators = 0;
      for (ProcessEngineConfigurator configurator : configuratorServiceLoader) {
        allConfigurators.add(configurator);
        nrOfServiceLoadedConfigurators++;
      }

      if (nrOfServiceLoadedConfigurators > 0) {
        log.info("Found {} auto-discoverable Process Engine Configurator{}", nrOfServiceLoadedConfigurators++, nrOfServiceLoadedConfigurators > 1 ? "s" : "");
      }

      //将allConfigurators进行排序,按照priority1的从大到小
      if (!allConfigurators.isEmpty()) {
        Collections.sort(allConfigurators, new Comparator<ProcessEngineConfigurator>() {
          @Override
          public int compare(ProcessEngineConfigurator configurator1, ProcessEngineConfigurator configurator2) {
            int priority1 = configurator1.getPriority();
            int priority2 = configurator2.getPriority();

            if (priority1 < priority2) {
              return -1;
            } else if (priority1 > priority2) {
              return 1;
            }
            return 0;
          }
        });

        // Execute the configurators
        log.info("Found {} Process Engine Configurators in total:", allConfigurators.size());
        for (ProcessEngineConfigurator configurator : allConfigurators) {
          log.info("{} (priority:{})", configurator.getClass(), configurator.getPriority());
        }

      }

    }
  }

初始化调用方法

在ProcessEngineConfigurationImpl调用init方法中configuratorsBeforeInit方法,它会遍历所有的allConfigurators,并调用其中的beforeInit

  /**调用所有配置器的beforeInit方法*/
  public void configuratorsBeforeInit() {
    for (ProcessEngineConfigurator configurator : allConfigurators) {
      log.info("Executing beforeInit() of {} (priority:{})", configurator.getClass(), configurator.getPriority());
      configurator.beforeInit(this);
    }
  }

初始化后配置方法调用

在ProcessEngineConfigurationImpl调用init方法中configuratorsAfterInit方法,它会遍历所有的allConfigurators,并调用其中的configure

 /**调用所有配置的configure方法*/
  public void configuratorsAfterInit() {
    for (ProcessEngineConfigurator configurator : allConfigurators) {
      log.info("Executing configure() of {} (priority:{})", configurator.getClass(), configurator.getPriority());
      configurator.configure(this);
    }
  }

activiti配置器的接口类

public interface ProcessEngineConfigurator {

  /**init方法的第二个方法调用,第一个是获取所有ProcessEngineConfigurator(当前接口的实例) 在初始化前做一些操作*/
  void beforeInit(ProcessEngineConfigurationImpl processEngineConfiguration);

  /**init方法的最后一个调用,在初始化后可以做一些配置*/
  void configure(ProcessEngineConfigurationImpl processEngineConfiguration);

  /**使用实例时,首先按照priority进行裴谞,如果你有实例之间的依赖性,自己定义优先级序*/
  int getPriority();

}

activiti的bean方式配置文件

<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="dataSource" class="com.alibaba.druid.pool.DruidDataSource">
		<property name="driverClassName">
			<value>com.mysql.jdbc.Driver</value>
		</property>
		<property name="url">
			<value>jdbc:mysql://127.0.0.1:3306/activiti?useUnicode=true&characterEncoding=UTF-8
			</value>
		</property>
		<property name="username">
			<value>root</value>
		</property>
		<property name="password" value="fadp" />
	</bean>

	<bean id="processEngineConfigurator1" class="com.activiti_study.ch7.processEngineConfigurator1"></bean>
	<bean id="processEngineConfigurator2"  class="com.activiti_study.ch7.processEngineConfigurator2"></bean>

	<bean id="processEngineConfiguration"
		class="org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration">
		<property name="dataSource" ref="dataSource" />
		<property name="processEngineName" value="shareniu" />
		<property name="configurators">
		
		<list>
		  <ref bean="processEngineConfigurator1"/>
		  <ref bean="processEngineConfigurator2"/>
		</list>
		</property>
	</bean>
</beans>

activiti的实现类

public class processEngineConfigurator1 extends AbstractProcessEngineConfigurator{
	@Override
	public void beforeInit(
			ProcessEngineConfigurationImpl processEngineConfiguration) {
		System.out.println("1:beforeInit ");
		processEngineConfiguration.setDatabaseSchemaUpdate("true");
	}
	@Override
	public void configure(
			ProcessEngineConfigurationImpl processEngineConfiguration) {
		System.out.println("1:configure ");
		String databaseSchemaUpdate = processEngineConfiguration.getDatabaseSchemaUpdate();
		System.out.println(databaseSchemaUpdate+"-----------------");
	}
}
public class processEngineConfigurator2 extends AbstractProcessEngineConfigurator{
	@Override
	public void beforeInit(
			ProcessEngineConfigurationImpl processEngineConfiguration) {
		System.out.println("2:beforeInit ");
		processEngineConfiguration.setDatabaseSchemaUpdate("true");
	}
	@Override
	public void configure(
			ProcessEngineConfigurationImpl processEngineConfiguration) {
		System.out.println("2:configure ");
		String databaseSchemaUpdate = processEngineConfiguration.getDatabaseSchemaUpdate();
		System.out.println(databaseSchemaUpdate+"-----------------");
	}
}

activit配置器的测试代码

public class App {
	@Test
	public void getProcessEngine() {
		ProcessEngineConfiguration pec = ProcessEngineConfiguration.createProcessEngineConfigurationFromResource("com/activiti_study/ch7/activiti1.cfg.xml");
		ProcessEngine pe1 = pec.buildProcessEngine();
	}
}

activiti配置器的测试结果

1:beforeInit 
2:beforeInit 
1:configure 
true-----------------
2:configure 
true-----------------

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏帘卷西风的专栏

关于mysql自增id的获取和重置

转载请注明出处:帘卷西风的专栏(http://blog.csdn.net/ljxfblog)

832
来自专栏静晴轩

Lua代码片段收集

Lua实现闭包 --[[@Func :实现闭包 @Desc : 当一个函数内部嵌套另一个函数定义时,内部的函数体可以访问外部的函数的局部变量,这种特征...

2785
来自专栏Java成神之路

HQL语句大全

Hibernate配备了一种非常强大的查询语言,这种语言看上去很像SQL。但是不要被语法结构 上的相似所迷惑,HQL是非常有意识的被设计为完全面向对象的查询,它...

975
来自专栏Golang语言社区

Golang的iota问题

通常人们认为iota就是0,其实并非如此。 确切的说,当iota在紧跟着关键字const的第一行出现时,iota为0,在第二行出现时,iota为1,以此类推;当...

36611
来自专栏cs

研究生的一份试题的几道题节选

首先祝朋友考研成功,勇往直前,我是不考研的,所以完全以提高能力,使用为主,不在意细节。小伙伴让我帮忙看了一下试卷,故截取了几道题目。 c我是真的应了那句话,从入...

3378
来自专栏任浩强的运维生涯

mongodb高级应用

一、  高级查询 查询操作符 条件操作符:db.collection.find({“field”:{$gt/$lt/$gte/$lte/$eq/$ne:valu...

34410
来自专栏python3

习题10:那是什么?

    I'm tabbed in. I'm split on a line. I'm \ a \ cat. I'll do a list:     * Ca...

421
来自专栏calmound

cocos2d-x 3.0 Node与Node层级结构

节点解释: 节点是场景图的基本元素。场景图的基本元素必须是节点对象或者是节点对象的子类。 其中主要可以看到Layer、MenuItem、Scene、Sprite...

2665
来自专栏小樱的经验随笔

C++STL vector详解(杂谈)

介绍 这篇文章的目的是为了介绍std::vector,如何恰当地使用它们的成员函数等操作。本文中还讨论了条件函数和函数指针在迭代算法中使用,如在remove_i...

3449
来自专栏magicsoar

一个C++bug引入的许多知识

一、前言     假设我们有一个Car类,用了表示一个车,它有id,名字,牌照等许多东西,还有一个表示车的部件CarPart。     但出于某方面的考虑,我们...

1899

扫码关注云+社区