activiti学习笔记(六) 监听器

activiti全局监听器

全局监听器主要使用的场景就是监控这个流程的启动和结束。流程开始的时候可以监控,流程结束的时候也可以监控

监听器的接口

public interface ActivitiEventListener {

  /**当时间被执行时调用该方法*/
  void onEvent(ActivitiEvent event);

 /**
  * @author 郑小康
  * 这个是onEvent执行失败之后进行的处理
  *
  * 如果是true则返回onEvent执行失败的异常
  *
  * 如果是false则忽略这个异常
  * */
  boolean isFailOnException();
}

初始化所有监听器

将所有全局监听器和类型监听器给加入到当前eventListeners里面,这里只是初始化过程

/**
   * @author 郑小康
   *
   * 事件监听器分为两种
   *
   * 1.如果eventDispatcher为空,则实例化ActivitiEventDispatcherImpl
   *
   * 2.设置eventDispatcher的状态为enableEventDispatcher,其值为true 默认支持事件转发
   *
   * 3.遍历当前流程实例所有的eventListeners监听器,将其添加到eventDispatcher
   *
   * 4.遍历所有typedEventListeners 以entry为key进行添加
   *   在cfg.xml文件定义:
   *    <property name="typedEventListeners">
   *      <map>
   *           <entry key="JOB_EXECUTION_SUCCESS,JOB_EXECUTION_FAILURE" >
   *               <list>
   *                  <bean class="org.activiti.engine.example.MyJobEventListener" />
   *                </list>
   *           </entry>
   *     </map>
   *   </property>
   * */
  public void initEventDispatcher() {
    if (this.eventDispatcher == null) {
      this.eventDispatcher = new ActivitiEventDispatcherImpl();
    }

    this.eventDispatcher.setEnabled(enableEventDispatcher);

    if (eventListeners != null) {
      for (ActivitiEventListener listenerToAdd : eventListeners) {
        this.eventDispatcher.addEventListener(listenerToAdd);
      }
    }

    if (typedEventListeners != null) {
      for (Entry<String, List<ActivitiEventListener>> listenersToAdd : typedEventListeners.entrySet()) {
        // Extract types from the given string
        ActivitiEventType[] types = ActivitiEventType.getTypesFromString(listenersToAdd.getKey());

        for (ActivitiEventListener listenerToAdd : listenersToAdd.getValue()) {
          this.eventDispatcher.addEventListener(listenerToAdd, types);
        }
      }
    }

  }

初始化监听器配置过程

   其实在流程实例中注入相对应的属性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="processEngine1" name="processEngineConfiguration"
		class="org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration">
		<property name="dataSource" ref="dataSource" />
		<property name="databaseSchemaUpdate" value="true" />
		<property name="eventListeners">
			<list>
				<bean class="com.event.MyEventListener" />
			</list>
		</property>
	</bean>

</beans>

监听器在流程实例启动时候的应用

       在构建流程实例的时候,会构建一个流程实例,在器最后会构建一个引擎启动时间,调用所有监听器的onEvent 方法

public ProcessEngineImpl(ProcessEngineConfigurationImpl processEngineConfiguration) {
     .......
    //调用时间转发器,构建一个事件实例ActivitiEvent类型为ENGINE_CREATED,然后进行事件转发
    processEngineConfiguration.getEventDispatcher().dispatchEvent(ActivitiEventBuilder.createGlobalEvent(ActivitiEventType.ENGINE_CREATED));
  }
/**
   * 1.enabled判断,默认为true进行事件转发
   *
   * 2.FIXME:尚未理解
   * */
  @Override
  public void dispatchEvent(ActivitiEvent event) {
    if (enabled) {
      eventSupport.dispatchEvent(event);
    }

    if (event.getType() == ActivitiEventType.ENTITY_DELETED && event instanceof ActivitiEntityEvent) {
      ActivitiEntityEvent entityEvent = (ActivitiEntityEvent) event;
      if (entityEvent.getEntity() instanceof ProcessDefinition) {
        // process definition deleted event doesn't need to be dispatched to event listeners
        return;
      }
    }
    

    CommandContext commandContext = Context.getCommandContext();
    if (commandContext != null) {
      BpmnModel bpmnModel = extractBpmnModelFromEvent(event);
      if (bpmnModel != null) {
        ((ActivitiEventSupport) bpmnModel.getEventSupport()).dispatchEvent(event);
      }
    }
    
  }
 /**
   * @author  郑小康
   *
   * 1.对当前转化的事件做非空校验
   *
   * 2.转化所有全局事件监听器
   *
   * 3.获取跟当前事件类型相同的事件监听器,并进行事件转化进行执行
   *
   * */
  public void dispatchEvent(ActivitiEvent event) {
    if (event == null) {
      throw new ActivitiIllegalArgumentException("Event cannot be null.");
    }

    if (event.getType() == null) {
      throw new ActivitiIllegalArgumentException("Event type cannot be null.");
    }

    //执行所有全局事件监听器
    if (!eventListeners.isEmpty()) {
      for (ActivitiEventListener listener : eventListeners) {
        dispatchEvent(event, listener);
      }
    }

    //获取跟当前事件类型相同的事件监听器,并进行事件转化进行执行
    List<ActivitiEventListener> typed = typedListeners.get(event.getType());
    if (typed != null && !typed.isEmpty()) {
      for (ActivitiEventListener listener : typed) {
        dispatchEvent(event, listener);
      }
    }
  }

测试

        @Test
	public void getDefaultProcessEngine() {
		ProcessEngineConfiguration pec = ProcessEngineConfiguration.createProcessEngineConfigurationFromResource("com/event/activiti.cfg.xml");
		ProcessEngine pe1 = pec.buildProcessEngine();
	}

测试结果

Event received: ENGINE_CREATED

       其中还有一种动态加载监听器的过程,通过第一个流程实例获取监听器的集合,进行添加,在第二个流程实例中就可以这样用了,为什么是这样呢,因为spring获取bean是单例模式,监听器引用类型指向的是同一个变量,使用过程如下:

        @Before
	public void init() {
		processEngine = ProcessEngineConfiguration
				.createProcessEngineConfigurationFromResource(
						"com/activiti_study/ch24/activiti1.cfg.xml")
				.buildProcessEngine();
		repositoryService = processEngine.getRepositoryService();
		activitiEventDispatcher = ((ProcessEngineConfigurationImpl) processEngine
				.getProcessEngineConfiguration()).getEventDispatcher();
	}
        @Test
	public void testAddEventListener() {
		ShareniuTaskEventListener2 shareniuTaskEventListener2 = new ShareniuTaskEventListener2();
		activitiEventDispatcher.addEventListener(shareniuTaskEventListener2);
		ProcessEngine pe = ProcessEngines.getDefaultProcessEngine();
		System.out.println(pe);

		processEngine = ProcessEngineConfiguration
				.createProcessEngineConfigurationFromResource(
						"com/activiti_study/ch24/activiti1.cfg.xml")
				.buildProcessEngine();
	}

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

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏ascii0x03的安全笔记

PHP防止SQL注入的方法

菜鸟今天刚刚学习PHP和SQL方面的内容,感觉坑比较深,做一下简单的记录,欢迎批评交流。 主要有两种思路一种是过滤,一种是使用占位符,据说第二种可以根本解决SQ...

28110
来自专栏飞雪无情的博客

Android Gradle实用技巧(三) | 批量控制生成的APK文件名

在讲批量修改APK文件名之前,我们讲一下关于Android Gradle插件集成的Task任务问题。普通的Java工程比较简单,因为它有一个有限的任务集合,而且...

491
来自专栏李成熙heyli

requirejs 源码简析

requirejs 算是几年前一个比较经典的模块加载方案(AMD的代表)。虽然不曾用过,但它对 webpack, rollup 这些后起之秀有不少借鉴的意义...

23410
来自专栏SHERlocked93的前端小站

Vue源码阅读 - 依赖收集原理

vue已是目前国内前端web端三分天下之一,同时也作为本人主要技术栈之一,在日常使用中知其然也好奇着所以然,另外最近的社区涌现了一大票vue源码阅读类的文章,在...

742
来自专栏嵌入式程序猿

SAE J1939 协议简介(二)

在简单介绍完J1939协议后,今天我们来讲讲J1939的数据链路层,熟悉数据链路层是开发任何一种协议软件的基础,数据链路层中的协议数据单元(PDU)格式...

3899
来自专栏竹清助手

NodeJS错误处理最佳实践

NodeJS的错误处理让人痛苦,在很长的一段时间里,大量的错误被放任不管。但是要想建立一个健壮的Node.js程序就必须正确的处理这些错误,而且这并不难学。如果...

743
来自专栏QQ会员技术团队的专栏

剖析Vue原理&实现双向绑定MVVM

本文能帮你做什么? 1、了解vue的双向数据绑定原理以及核心代码模块 2、缓解好奇心的同时了解如何实现双向绑定 为了便于说明原理与实现,本文相关代码主要摘自vu...

1.2K7
来自专栏Kotlin源码阅读

Kotlin源码阅读——system模块

在kotlin的源码目录里,每个模块都有相应的md文件,做以说明。在kotlin最主要的stdlin/src目录下有一个Module.md:

1013
来自专栏QQ音乐技术团队的专栏

Unity Android Plugin开发指南

本文将介绍如何在Unity工程中使用Android或者Java的库,包括: 如何在Unity项目中使用Android Plugin Unity-Android相...

7787
来自专栏无所事事者爱嘲笑

ionic2 处理android硬件返回按钮

1124

扫码关注云+社区