Spring中的ApplicationListener的使用详解案例（观察者模式）

﹏ヽ暗。殇╰゛Y 2022-05-15 13:54 194阅读 0赞

1、ApplicationContext  
Spring的核心，Context我们通常解释为上下文环境。ApplicationContext则是应用的容器。 Spring把Bean（object）放在容器中，需要用就通过get方法取出来。在ApplicationContext接口的众多实现类中，有3个是我们经常用到的（见表1-1），并且使用这3个实现类也基本能满足我们Java EE应用开发中的绝大部分需求。

表1-1 ApplicationContext接口的常用实现类介绍

<table> 
 <tbody> 
 <tr> 
 <td style="width:219px;"> 类 名 称 </td> 
 <td style="width:630px;"> 功 能 描 述 </td> 
 </tr> 
 <tr> 
 <td style="width:219px;"> ClassPathXmlApplicationContext </td> 
 <td style="width:630px;"> 从类路径ClassPath中寻找指定的XML配置文件，找到并装载完成ApplicationContext的实例化工作。例如：&nbsp;//装载单个配置文件实例化ApplicationContext容器 ApplicationContext cxt = new ClassPathXmlApplicationContext("applicationContext.xml"); //装载多个配置文件实例化ApplicationContext容器 String[] configs = {"bean1.xml","bean2.xml","bean3.xml"}; ApplicationContext cxt = new ClassPathXmlApplicationContext(configs); </td> 
 </tr> 
 <tr> 
 <td style="width:219px;"> FileSystemXmlApplicationContext </td> 
 <td style="width:630px;"> 从指定的文件系统路径中寻找指定的XML配置文件，找到并装载完成ApplicationContext的实例化工作。例如：//装载单个配置文件实例化ApplicationContext容器 ApplicationContext cxt = new FileSystemXMLApplicationContext("beans.xml"); //装载多个配置文件实例化ApplicationContext容器 String[] configs = {"c:/beans1.xml","c:/beans2.xml"}; ApplicationContext cxt = new FileSystemXmlApplicationContext(configs); </td> 
 </tr> 
 <tr> 
 <td style="width:219px;"> XmlWebApplicationContext </td> 
 <td style="width:630px;"> 从Web应用中寻找指定的XML配置文件，找到并装载完成ApplicationContext的实例化工作。这是为Web工程量身定制的，使用WebApplicationContextUtils类的getRequiredWebApplicationContext方法可在JSP与Servlet中取得IoC容器的引用 </td> 
 </tr> 
 </tbody> 
</table>

2、ApplicationEvent

是个抽象类，里面只有一个构造函数和一个长整型的timestamp。其源码如下：

public abstract class ApplicationEvent extends EventObject {
    
    	/** use serialVersionUID from Spring 1.2 for interoperability */
    	private static final long serialVersionUID = 7099057708183571937L;
    
    	/** System time when the event happened */
    	private final long timestamp;
    
    	/**
    	 * Create a new ApplicationEvent.
    	 * @param source the object on which the event initially occurred (never {@code null})
    	 */
    	public ApplicationEvent(Object source) {
    		super(source);
    		this.timestamp = System.currentTimeMillis();
    	}
    
    	/**
    	 * Return the system time in milliseconds when the event happened.
    	 */
    	public final long getTimestamp() {
    		return this.timestamp;
    	}
    }

3、ApplicationListener

是一个接口，里面只有一个onApplicationEvent方法。如果在上下文中部署一个实现了ApplicationListener接口的bean,那么每当在一个ApplicationEvent发布到 ApplicationContext时，调用ApplicationContext.publishEvent()方法，这个bean得到通知。类似于Oberver设计模式。

其源码如下：

public interface ApplicationListener<E extends ApplicationEvent> extends EventListener {
 	/**
 	 * Handle an application event.
 	 * @param event the event to respond to
 	 */
 	void onApplicationEvent(E event);
 
 }

好了，这里简单介绍下我的使用方式吧。

首先创建一个自己的回调的类CallBackInfoEvent 去继承ApplicationEvent：

public class CallBackInfoEvent extends ApplicationEvent {
    
        /**
         * Create a new ApplicationEvent.
         *
         * @param source the object on which the event initially occurred (never {@code null})
         */
        public CallBackInfoEvent(RiskCallBackInput input) {
            super(input);
        }
    }

然后创建ApplicationListener的一个实现类MyListener ：

@Component
 public class MyListener implements ApplicationListener<CallBackInfoEvent> {
 
 private static final Logger logger = LoggerFactory.getLogger(HuluReportListener.class);
 
 /**
 * Handle an application event.
 *
 * @param event the event to respond to
 */
 @Override
 public void onApplicationEvent(CallBackInfoEvent event) {
 RiskCallBackInput input = (RiskCallBackInput) event.getSource();
 if (StringUtils.equals(input.getType(), “1”)) {
 //TODO 处理业务逻辑增删改查
 }
 }
 }

最后在你的业务service中通过调用以下代码是发布通知事件：

@Autowired
    private ApplicationContext context;
    
    
    
    //TODO 业务逻辑
    context.publishEvent(new CallBackInfoEvent(Object object));

ok了。