Spring注解驱动之@EventListener注解使用方式

概述

之前我们说过可以通过实现ApplicationListener接口来监听处理事件。

其实还有一种注解方式来监听处理事件。即使用@EventListener注解，通过该注解就可以在方法上监听事件了。

这样普通的业务逻辑组件中就可以直接使用这个注解来监听事件了，无需实现ApplicationListener接口了，确实比较方便，但是其原理是和ApplicationListener接口一样的，也可以自定义一个多波器实现异步监听事件，定义方法与之前一致。spring注解驱动之ApplicationListener异步处理事件

@EventListener注解的用法

首先，编写一个普通的业务逻辑组件，例如UserService，并在该组件上标注一个@Service注解。

我们只需要简单的在该方法上标注一个@EventListener注解，就可以让方法来监听事件了。可以通过注解的classes属性来指定需要监听的事件。

例如，我们可以让listen方法监听ApplicationEvent及其子事件。

最后我们在参数的位置上写一个ApplicationEvent参数来接收事件，参数值是在Spring框架调用的时候自动赋值的。

package com.meimeixia.ext;
import org.springframework.context.ApplicationEvent;
import org.springframework.context.event.EventListener;
import org.springframework.stereotype.Service;
@Service
public class UserService {
	
	// 一些其他的方法...
	@EventListener(classes=ApplicationEvent.class)
	public void listen(ApplicationEvent event) {
		System.out.println("UserService...监听到的事件：" + event);
	}
}

写个测试用例。

package com.meimeixia.test;
import org.junit.Test;
import org.springframework.context.ApplicationEvent;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;
import com.meimeixia.ext.ExtConfig;
public class iocTest_Ext {
	
	@Test
	public void test01() {
		AnnotationConfigApplicationContext applicationContext = new AnnotationConfigApplicationContext(ExtConfig.class);
		
		// 发布一个事件
		applicationContext.publishEvent(new ApplicationEvent(new String("我发布的事件")) {
		});
		
		// 关闭容器
		applicationContext.close();
	}
}

你会发现Eclipse控制台打印出了如下内容，可以清晰地看到，不仅我们之前编写的监听器（例如MyApplicationListener）收到了事件，而且UserService组件也收到了事件。

也就是说，每一个都能正确地收到事件。

@EventListener注解的原理

我们可以点进去@EventListener这个注解里面去看一看，如下图所示，可以看到这个注解上面有一大堆的描述，从描述中我们可以猜到这个注解的内部工作原理。

描述中有一个醒目的字眼，即参考EventListenerMethodProcessor。意思可能是说，如果你想搞清楚@EventListener注解的内部工作原理，那么可以参考EventListenerMethodProcessor这个类。

EventListenerMethodProcessor是一个处理器，其作用是来解析方法上的@EventListener注解的。

这也就是说，Spring会使用EventListenerMethodProcessor来解析方法上的@EventListener注解。

因此，搞清楚这个处理器是怎样工作的，就搞清楚了@EventListener注解的内部工作原理。

仔细看一下SmartInitializingSingleton接口中afterSingletonsInstantiated方法上面的描述信息，不难看出该方法是在所有的单实例bean已经全部被创建完了以后才会被执行。

在介绍SmartInitializingSingleton接口的时候，我们也能从描述信息中知道，在所有的单实例bean已经全部被创建完成以后才会触发该接口。紧接着下面一段的描述还说了，该接口的调用时机有点类似于ContextRefreshedEvent事件，即在容器刷新完成以后，便会回调该接口。也就是说，这个时候容器已经创建完了。

如果所有的单实例bean都已经创建完了，也就是说下面这一步都执行完了，那么说明IOC容器已经创建完成了。

紧接着便会来调用finishRefresh方法，容器已经创建完了，此时就会来发布容器已经刷新完成的事件。

这就呼应了开头的那句话，即SmartInitializingSingleton接口的调用时机有点类似于ContextRefreshedEvent事件，即在容器刷新完成以后，便会回调该接口。

以上为个人经验，希望能给大家一个参考，也希望大家多多支持。