ApplicationContextAware+Spring 观察者模式

青旅半醒 2022-01-25 15:14 249阅读 0赞

在某些特殊的情况下，Bean需要实现某个功能，但该功能必须借助于Spring容器才能实现，此时就必须让该Bean先获取Spring容器，然后借助于Spring容器实现该功能。为了让Bean获取它所在的Spring容器，可以让该Bean实现ApplicationContextAware接口.因为Spring容器启动时候会检测容器中的所有Bean，如果发现某个Bean实现了ApplicationContextAware接口，Spring容器会在创建该Bean之后，自动调用该Bean的setApplicationContextAware()方法，调用该方法时，会将容器本身作为参数传给该方法——该方法中的实现部分将Spring传入的参数（容器本身）赋给该类对象的applicationContext实例变量，因此接下来可以通过该applicationContext实例变量来访问容器本身。看下面应用场景

**例如获取Spring容器中实现了IListener接口得所有bean**，**applicationContext.getBeansOfType(IListener.class);**

getBeansOfType 该方法返回一个map类型的实例，map中的key为bean的名字，key对应的内容为bean的实例。可以把这个map当成自定义得SpringContextHolder得一个属性，然后在其他bean中注入SpringContextHolder即可使用map中得bean，我这里是获取**IListener**实现类 ,根据类上的注解注册不同的事件。

1.自定义SpringContextHolder  实现ApplicationContextAware 接口，提供getMap()方法获取map.

package com.summer.eventListener;
    
    import java.util.Map;
    
    import org.springframework.context.ApplicationContext;
    import org.springframework.context.ApplicationContextAware;
    import org.springframework.context.annotation.Lazy;
    import org.springframework.stereotype.Component;
    
    @Component("mySpringContextHolder")
    @Lazy(false)
    public class SpringContextHolder implements ApplicationContextAware {
    	private static ApplicationContext applicationContext = null;
    
        //定义map接收所有Liestener类型的类
    	private Map<String, IListener> map;
    
    	/**
    	 * 获取静态变量中的ApplicationContext.
    	 */
    	public static ApplicationContext getApplicationContext() {
    		return applicationContext;
    	}
    
    	/**
    	 * 从静态变量applicationContext中得到Bean, 自动转型为所赋值对象的类型.
    	 */
    	@SuppressWarnings("unchecked")
    	public static <T> T getBean(String name) {
    		return (T) applicationContext.getBean(name);
    	}
    
    	/**
    	 * 从静态变量applicationContext中得到Bean, 自动转型为所赋值对象的类型.
    	 */
    	public static <T> T getBean(Class<T> requiredType) {
    		return applicationContext.getBean(requiredType);
    	}
    
    	/**
    	 * 清除SpringContextHolder中的ApplicationContext为Null.
    	 */
    	public static void clearHolder() {
    		applicationContext = null;
    	}
    
    	/**
    	 * 实现ApplicationContextAware接口, 注入Context到静态变量中.
    	 */
    	@Override
    	public void setApplicationContext(ApplicationContext applicationContext) {
    		SpringContextHolder.applicationContext = applicationContext;
    		//根据接口类型返回相应的所有bean
    		map = applicationContext.getBeansOfType(IListener.class);
    		System.out.println("mySpringContextHolder+++++++++");
    		
    		
    	}
    	
    	public Map<String, IListener> getMap(){
    		return 	map;
    	}
    
    }

2.初始化事件监听器，根据注解的属性值注册不同的事件

package com.summer.eventListener;
    
    import java.util.Map;
    
    import javax.annotation.PostConstruct;
    
    import org.apache.log4j.Logger;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.context.annotation.Lazy;
    import org.springframework.stereotype.Service;
    
    
    
    
    @Service
    @Lazy(false)
    public class InitRegistListeners {
    	@Autowired
    	private EventHub eventHub;
    	@Autowired
    	private SpringContextHolder mySpringContextHolder;
    
    	private static Logger logger = Logger.getLogger(InitRegistListeners.class);
    
    	@PostConstruct
    	public void registListener() {
    		logger.info("##############开始注册监听器###############");
            //从spring容器中获取IListener所有实现类
    		Map<String, IListener> map = mySpringContextHolder.getMap();
    		for (Map.Entry<String, IListener> obj : map.entrySet()) {
    			IListener listener = obj.getValue();
                //获取指定实现类的class对象
    			Class<? extends IListener> class1 = listener.getClass();
                //获取class对象上的标注的注解EventListener的对象
    			EventListener annotation = class1.getAnnotation(EventListener.class);			
    			if (null != annotation) {
    				try {
                        //根据注解的属性值注册事件    
    					for (String type : annotation.value()) {
    						eventHub.registListener(type, listener);
    						logger.info("监听器" + obj.getKey() + "注册成功，监听事件:" + type + "---" + listener);
    					}
    				} catch (Exception e) {
    					logger.error(listener + "监听器注册失败", e);
    				}
    			}
    		}
    	}
    }