activiti学习笔记(三) 监听生命周期

activiti监听生命周期

activiti生命周期的作用

生命周期的作用是在构建processEngine实例时候或者关闭的时候调用对应处理方法,比如我在启动实例的时候,可以对实例做一些预处理

activiti的接口类

public interface ProcessEngineLifecycleListener {

  /**实体引擎实例化的时候调用该方法*/
  void onProcessEngineBuilt(ProcessEngine processEngine);

  /**实体引擎关闭的时候调用该方法*/
  void onProcessEngineClosed(ProcessEngine processEngine);
}

activiti的生命周期的实现

       首先通过bean进行实例化,再注入到当前bean,具体监听则是在构建实例和关闭实例的时候

   构建实例:会调用监听类的onProcessEngineBuilt方法

  /**
   * @author 郑小康
   *
   * 1.注入流程配置实例的一些变量到当前实例
   *
   * 2.FIXME:未知
   *
   * 3.注册当前流程实例
   *
   * 4.FIXME:未知
   *
   * 5.调用监听方法,这也是这里需要描述的核心(不是本方法的核心)
   * */
  public ProcessEngineImpl(ProcessEngineConfigurationImpl processEngineConfiguration) {
    this.processEngineConfiguration = processEngineConfiguration;
    this.name = processEngineConfiguration.getProcessEngineName();
    this.repositoryService = processEngineConfiguration.getRepositoryService();
    this.runtimeService = processEngineConfiguration.getRuntimeService();
    this.historicDataService = processEngineConfiguration.getHistoryService();
    this.identityService = processEngineConfiguration.getIdentityService();
    this.taskService = processEngineConfiguration.getTaskService();
    this.formService = processEngineConfiguration.getFormService();
    this.managementService = processEngineConfiguration.getManagementService();
    this.dynamicBpmnService = processEngineConfiguration.getDynamicBpmnService();
    this.asyncExecutor = processEngineConfiguration.getAsyncExecutor();
    this.commandExecutor = processEngineConfiguration.getCommandExecutor();
    this.sessionFactories = processEngineConfiguration.getSessionFactories();
    this.transactionContextFactory = processEngineConfiguration.getTransactionContextFactory();
    this.formEngineRepositoryService = processEngineConfiguration.getFormEngineRepositoryService();
    this.formEngineFormService = processEngineConfiguration.getFormEngineFormService();

    if (processEngineConfiguration.isUsingRelationalDatabase() && processEngineConfiguration.getDatabaseSchemaUpdate() != null) {
      commandExecutor.execute(processEngineConfiguration.getSchemaCommandConfig(), new SchemaOperationsProcessEngineBuild());
    }

    if (name == null) {
      log.info("default activiti ProcessEngine created");
    } else {
      log.info("ProcessEngine {} created", name);
    }

    ProcessEngines.registerProcessEngine(this);

    if (asyncExecutor != null && asyncExecutor.isAutoActivate()) {
      asyncExecutor.start();
    }

    //流程引擎实例化监听方法
    if (processEngineConfiguration.getProcessEngineLifecycleListener() != null) {
      processEngineConfiguration.getProcessEngineLifecycleListener().onProcessEngineBuilt(this);
    }

    processEngineConfiguration.getEventDispatcher().dispatchEvent(ActivitiEventBuilder.createGlobalEvent(ActivitiEventType.ENGINE_CREATED));
  }

   关闭实例会调用onProcessEngineClosed方法

 public void close() {
    ProcessEngines.unregister(this);
    if (asyncExecutor != null && asyncExecutor.isActive()) {
      asyncExecutor.shutdown();
    }

    commandExecutor.execute(processEngineConfiguration.getSchemaCommandConfig(), new SchemaOperationProcessEngineClose());

    //流程引擎关闭触发监听方法
    if (processEngineConfiguration.getProcessEngineLifecycleListener() != null) {
      processEngineConfiguration.getProcessEngineLifecycleListener().onProcessEngineClosed(this);
    }
    
    processEngineConfiguration.getEventDispatcher().dispatchEvent(ActivitiEventBuilder.createGlobalEvent(ActivitiEventType.ENGINE_CLOSED));
  }

activiti生命周期的使用

上面是生命周期的源码实现介绍,下面就讲述一下怎样使用

第一步:实现ProcessEngineLifecycleListener这个接口

public class processEngineLifecycleListener implements ProcessEngineLifecycleListener{

	public void onProcessEngineBuilt(ProcessEngine processEngine) {
		System.out.println("流程引擎生命周期监听器开始了....");
		ProcessEngineConfiguration pec = processEngine.getProcessEngineConfiguration();
		String activityFontName = pec.getActivityFontName();
		System.out.println(activityFontName);
	}

	public void onProcessEngineClosed(ProcessEngine processEngine) {
		
	}

}

第二步:配置当前processEngineLifecycleListener这个bean并将其注入processEngineConfiguration里面

<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="processEngineLifecycleListener"
		class="com.activiti_study.ch6.processEngineLifecycleListener"></bean>


	<bean id="processEngine1" name="processEngineConfiguration"
		class="org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration">
		<property name="dataSource" ref="dataSource" />
		<property name="databaseSchemaUpdate" value="true" />
		<property name="processEngineLifecycleListener" ref="processEngineLifecycleListener"></property>
	</bean>
</beans>

第三步:具体实现

        @Test
	public void getDefaultProcessEngine() throws FileNotFoundException {
		ProcessEngineConfiguration processEngineConfiguration = ProcessEngineConfiguration.createProcessEngineConfigurationFromResource("com/activiti_study/ch6/activiti1.cfg.xml","processEngineConfiguration");
		ProcessEngine pe = processEngineConfiguration.buildProcessEngine();
		System.out.println(pe+"========");
	}
流程引擎生命周期监听器开始了....
Arial
org.activiti.engine.impl.ProcessEngineImpl@4b29d1d2========

      从显示结果可以看出在调用buildProcessEngine方法的时候调用了ProcessEngineLifecycleListener继承类的onProcessEngineBuilt方法

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

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏HTML5学堂

开发图片预加载框架

HTML5学堂:在此前的一篇文章当中,我们讲解了图片预加载,对图片预加载的知识以及原理等内容均进行了一些讲解。对于我们开发人员来说,几乎每个移动端的项目(专题类...

31711
来自专栏大数据

使用Apache Flink进行批处理入门教程

原文地址:https://dzone.com/articles/getting-started-with-batch-processing-using-apac...

1.7K3
来自专栏逆向技术

常见注入手法第四讲,SetWindowsHookEx全局钩子注入.以及注入QQ32位实战.

钩子回调根据SetWindowsHookEx参数1来设定的.比如如果我们设置WH_CBT 那么我们设置的回调函数就是CBT回调. 具体查询MSDN

1781
来自专栏贾老师の博客

Bash Style Guide

962
来自专栏GreenLeaves

四、CLR执行程序集中代码和IL代码简介

三、加载公共语言运行时中介绍了在安装了.Net Framework中加载公共语言运行时,公共语言运行时加载程序集的过程.以及通过vs stdio设置源码编译的目...

2788
来自专栏非典型程序猿

从源码透析gRPC调用原理

gRPC是如何work的,清楚的理解其调用逻辑,对于我们更好、更深入的使用gRPC很有必要。因此我们必须深度解析下gRPC的实现逻辑,在本文中,将分别从客户端和...

5037
来自专栏Java技术分享

第九章:Shiro的Web——深入浅出学Shiro细粒度权限开发框架

Shiro可以和普通web集成的,但考虑到现在的应用基本都会使用spring,所以就不去讲最基本的web集成了。跟Spring集成的方式前面已经讲过了。

1768
来自专栏十月梦想

不同函数间的数据传递

        小程序不想mvc的框架一样,获取dom进行操作,只是依靠数据绑定,数据有限原则进行数据传输.

592
来自专栏ImportSource

Spring Boot处理REST API错误的正确姿势

如何正确的处理API的返回信息,让返回的错误信息提供更多的含义是一个非常值得做的功能。 默认一般返回的都是难以理解的堆栈信息,然而这些信息也许对于API的客户...

47213
来自专栏光变

Java Code Review 指南

Java代码俯身指南,主要为Java开发人员提供代码复审参考,快捷有效提出修改意见。

844

扫码关注云+社区