springIOC源码接口分析(七):ApplicationEventPublisher

一定义方法

此接口主要是封装事件发布功能的接口,定义了两个方法:

    /**

     * 通知应用所有已注册且匹配的监听器此ApplicationEvent

     */

    default void publishEvent(ApplicationEvent event) {

        publishEvent((Object) event);

    }

    /**

     * 通知应用所有已注册且匹配的监听器此Event ，

     * 如果这个Event不是一个ApplicationEvent，则其被包裹于PayloadApplicationEvent

     */

    void publishEvent(Object event);

二 ApplicationEvent 事件抽象类

spring中ApplicationEvent +ApplicationListener 是观察者模式的一种实现。

public abstract class ApplicationEvent extends EventObject {

    /** use serialVersionUID from Spring 1.2 for interoperability. */

    private static final long serialVersionUID = 7099057708183571937L;

    /** 事件发生的系统时间 */

    private final long timestamp;

    // 构造器

    public ApplicationEvent(Object source) {//发生事件的对象

        super(source);

        this.timestamp = System.currentTimeMillis();

    }

    public final long getTimestamp() {

        return this.timestamp;

    }

}

ApplicationEvent类继承了EventObject类 ,构造器中的source都是父类的不需要序列化的属性,添加了自身的事件发生时间的属性

transient作用: https://www.cnblogs.com/chenpi/p/6185773.html

三 spring内置事件

spring里面有许多Event的实现,包括springBoot里面又新增了一些实现,下面是这些实现:

ApplicationEvent的实现主要分为三条线:

1 PayloadApplicationEvent,是可以使用泛型的事件,不用进行强转

2 ApplicationContextEvent以及其四个子类

ApplicationContextEvent是对应应用上下文的事件,主要有四个事件,分别是:

ContextRefreshedEvent 刷新
ContextClosedEvent 关闭
ContextStartedEvent 启动
ContextStoppedEvent 暂停

3 RequestHandledEvent,对应http服务事件,其实现类定义了一些http请求有关的参数,url,状态code等:

三 ApplicationListener 监听器接口

@FunctionalInterface

public interface ApplicationListener<E extends ApplicationEvent> extends EventListener {

    /**

     * Handle an application event.

     * @param event the event to respond to

     */

    void onApplicationEvent(E event);

}

ApplicationListener接口继承了EventListener 接口,java中所有的监听器都继承了这个接口猛兽jdk,util包下面的接口,接口接受ApplicationEvent的子类作为监听事件.
使用监听器一般有两种方式:

一实现ApplicationListener接口

比如spring内置的一个监听器:

二使用@EventListener注解的方式

注册了监听器之后,发布对应事件就会通过事件处理器管理类多播到对应的监听逻辑,即onApplicationEvent方法

四 ApplicationEventMulticaster 事件处理器管理类

ApplicationEventMulticaster接口定义了7个管理监听器的方法,只有一个实现类SimpleApplicationEventMulticaster,方法分别是:

    /**

     * 添加监听器,用来接收所有事件的通知

     */

    void addApplicationListener(ApplicationListener<?> listener);

    /**

     * 根据Bean名称添加监听器

     */

    void addApplicationListenerBean(String listenerBeanName);

    /**

     * 移除监听器

     */

    void removeApplicationListener(ApplicationListener<?> listener);

    /**

     * 根据名称移除监听器

     */

    void removeApplicationListenerBean(String listenerBeanName);

    /**

     * 移除所有监听器

     */

    void removeAllListeners();

    /**

     * 将事件广播到对应的监听器中

     */

    void multicastEvent(ApplicationEvent event);

    /**

     * 将事件广播到对应的监听器中

     */

    void multicastEvent(ApplicationEvent event, @Nullable ResolvableType eventType);

接下来看实现类中广播事件的方法:

    @Override

    public void multicastEvent(ApplicationEvent event) {

        multicastEvent(event, resolveDefaultEventType(event));//获取默认类型

    }

    @Override

    public void multicastEvent(final ApplicationEvent event, @Nullable ResolvableType eventType) {

        ResolvableType type = (eventType != null ? eventType : resolveDefaultEventType(event));

        //获取所有注册的监听器,并遍历

        for (final ApplicationListener<?> listener : getApplicationListeners(event, type)) {

            Executor executor = getTaskExecutor();

            if (executor != null) {

                executor.execute(() -> invokeListener(listener, event));

            }

            else {

                invokeListener(listener, event);//调用对应的监听器逻辑方法

            }

        }

    }

类中维护了一个Set,用来存放监听器,且监听事件都是异步线程池执行的.

巴特西

springIOC源码接口分析(七):ApplicationEventPublisher

一定义方法

二 ApplicationEvent 事件抽象类

三 spring内置事件

四 ApplicationEventMulticaster 事件处理器管理类

最新文章

热门文章

巴特西

springIOC源码接口分析(七):ApplicationEventPublisher

一 定义方法

二 ApplicationEvent 事件抽象类

三 spring内置事件

四 ApplicationEventMulticaster 事件处理器管理类

最新文章

热门文章

一定义方法