Spring学习(三十)-@EventListener监听事件

r囧r小猫 2024-02-19 16:11 63阅读 0赞

@EventListener：监听事件

@Target({ElementType.METHOD, ElementType.ANNOTATION_TYPE})
    @Retention(RetentionPolicy.RUNTIME)
    @Documented
    public @interface EventListener {
    
    	/**
    	 * Alias for {@link #classes}.
    	 */
    	@AliasFor("classes")
    	Class<?>[] value() default {};
    
    	/**
    	 *监听那个事件 如ApplicationEvent.class
    	 */
    	@AliasFor("value")
    	Class<?>[] classes() default {};
    
    	/**
    	 * Spring Expression Language (SpEL) attribute used for making the
    	 *根据条件监听事件
    	 */
    	String condition() default "";
    
    }

原理：使用EventListenerMethodProcessor处理器来解析方法上的@EventListener；

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzU0OTU3OA_size_16_color_FFFFFF_t_70][]

public interface SmartInitializingSingleton {
    
    	//单实例所有bean全部创建完成触发类似与容器刷新完成
    	void afterSingletonsInstantiated();
    
    }

调用位置：

@Override
    public void refresh() throws BeansException, IllegalStateException {
    	synchronized (this.startupShutdownMonitor) {
            。。。。。。。。。。。。。。
    	//初始化单实例bean
    	finishBeanFactoryInitialization(beanFactory);
    
    	// Last step: publish corresponding event.
    	finishRefresh();
    
    		。。。。。。。。。。
    	}
    }
    
    protected void finishBeanFactoryInitialization(ConfigurableListableBeanFactory beanFactory) {
    	。。。。。。。。。。。。。。
    	//初始化单实例bean
    	beanFactory.preInstantiateSingletons();
    }
    
    
    @Override
    public void preInstantiateSingletons() throws BeansException {
    	。。。。。。。。。。。。。。。。。。
    	//单实例bean初始化
    	getBean(beanName);
    	。。。。。。。。。。。。
    
    	// 获取所有创建好的单实例bean
    	for (String beanName : beanNames) {
    		Object singletonInstance = getSingleton(beanName);
    		//判断是否是SmartInitializingSingleton类型的；
    		if (singletonInstance instanceof SmartInitializingSingleton) {
    			final SmartInitializingSingleton smartSingleton = (SmartInitializingSingleton) singletonInstance;
    			if (System.getSecurityManager() != null) {
    				//权限验证
    				AccessController.doPrivileged(new PrivilegedAction<Object>() {
    					@Override
    					public Object run() {
    						smartSingleton.afterSingletonsInstantiated();
    						return null;
    					}
    				}, getAccessControlContext());
    			}
    			else {
    				//回调该方法
    				smartSingleton.afterSingletonsInstantiated();
    			}
    		}
    	}
    }

流程：

1）、ioc容器创建对象并refresh()；  
2）、finishBeanFactoryInitialization(beanFactory);初始化剩下的单实例bean；  
1）、先创建所有的单实例bean；getBean();  
2）、获取所有创建好的单实例bean，判断是否是SmartInitializingSingleton类型的；  
如果是就调用afterSingletonsInstantiated();

用法测试：

业务层：

@Service
    public class UserService {
    
    	@EventListener(classes={ApplicationEvent.class})
    	public void listen(ApplicationEvent event){
    		System.out.println("UserService。。监听到的事件："+event);
    	}
    
    }

配置类:

@ComponentScan("com.spring.ext")
    @Configuration
    public class ExtConfig {
    
    	
    
    }

测试类：

@Test
    	public void test01(){
    		AnnotationConfigApplicationContext applicationContext  = new AnnotationConfigApplicationContext(ExtConfig.class);
    		applicationContext.close();
    	}

结果：

![20190120015338968.png][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzU0OTU3OA_size_16_color_FFFFFF_t_70]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/55d267c5c8244e8ea10559043497798a.png
[20190120015338968.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/6e23cc709cdb48db8ed4e2751d62ab71.png