Listener

佚名 6年前 (2019-04-22) 随笔 791人围观抢沙发百度已收录

Listener

接口

public interface EventListener {}

public interface ServletContextListener extends EventListener {
    // 初始化
    void contextInitialized(ServletContextEvent sce);
    // 销毁
    void contextDestroyed(ServletContextEvent sce);
}

Listener注入

org.apache.catalina.core.StandardContext

private String applicationListeners[] = new String[0];
@Override
public void addApplicationListener(String listener) {
    synchronized (applicationListenersLock) {
        String results[] = new String[applicationListeners.length + 1];
        for (int i = 0; i < applicationListeners.length; i++) {
            if (listener.equals(applicationListeners[i])) {
                return;
            }
            results[i] = applicationListeners[i];
        }
        results[applicationListeners.length] = listener;
        applicationListeners = results;
    }
    fireContainerEvent("addApplicationListener", listener);
}

@Override
protected synchronized void startInternal() throws LifecycleException {
    // 准备好环境
    // Configure and call application event listeners
    if (ok) {
        if (!listenerStart()) {
            ok = false;
        }
    }
}

public boolean listenerStart() {
    String listeners[] = findApplicationListeners();
    Object results[] = new Object[listeners.length];
    boolean ok = true;
    for (int i = 0; i < results.length; i++) {
        try {
            String listener = listeners[i];
            // 通过反射实例化 listener
            results[i] = getInstanceManager().newInstance(listener);
        } catch (Throwable t) {
            ok = false;
        }
    }
    if (!ok) {
        return false;
    }

    // 对 listener 进行分类
    ArrayList<Object> eventListeners = new ArrayList<>();
    ArrayList<Object> lifecycleListeners = new ArrayList<>();
    for (int i = 0; i < results.length; i++) {
        if ((results[i] instanceof ServletContextAttributeListener)
            || (results[i] instanceof ServletRequestAttributeListener)
            || (results[i] instanceof ServletRequestListener)
            || (results[i] instanceof HttpSessionIdListener)
            || (results[i] instanceof HttpSessionAttributeListener)) {
            eventListeners.add(results[i]);
        }
        if ((results[i] instanceof ServletContextListener)
            || (results[i] instanceof HttpSessionListener)) {
            lifecycleListeners.add(results[i]);
        }
    }

    // 监听器实例可能已通过 ServletContextInitializers 和其他代码通过可插拔API
    // 直接添加到此Context。
    for (Object eventListener: getApplicationEventListeners()) {
        eventListeners.add(eventListener);
    }
    // 重新设置 listener
    setApplicationEventListeners(eventListeners.toArray());
    for (Object lifecycleListener: getApplicationLifecycleListeners()) {
        lifecycleListeners.add(lifecycleListener);
        if (lifecycleListener instanceof ServletContextListener) {
            noPluggabilityListeners.add(lifecycleListener);
        }
    }
    setApplicationLifecycleListeners(lifecycleListeners.toArray());

    // 确保 context 不为 null
    getServletContext();
    context.setNewServletContextListenerAllowed(false);
    // 获取 应用程序生命周期监听器
    Object instances[] = getApplicationLifecycleListeners();
    if (instances == null || instances.length == 0) {
        return ok;
    }

    ServletContextEvent event = new ServletContextEvent(getServletContext());
    ServletContextEvent tldEvent = null;
    if (noPluggabilityListeners.size() > 0) {
        noPluggabilityServletContext = new NoPluggabilityServletContext(getServletContext());
        tldEvent = new ServletContextEvent(noPluggabilityServletContext);
    }
    for (int i = 0; i < instances.length; i++) {
        if (!(instances[i] instanceof ServletContextListener))
            continue;
        ServletContextListener listener =
            (ServletContextListener) instances[i];
        try {
            fireContainerEvent("beforeContextInitialized", listener);
            // 调用 Listener.contextInitialized 方法
            if (noPluggabilityListeners.contains(listener)) {
                listener.contextInitialized(tldEvent);
            } else {
                listener.contextInitialized(event);
            }
            fireContainerEvent("afterContextInitialized", listener);
        } catch (Throwable t) {
            fireContainerEvent("afterContextInitialized", listener);
            ok = false;
        }
    }
    return (ok);
}

整合Spring

<listener>
    <listener-class>
        org.springframework.web.context.ContextLoaderListener
    </listener-class>
</listener>

public class ContextLoaderListener extends ContextLoader implements ServletContextListener {

    /**
     * Initialize the root web application context.
     */
    @Override
    public void contextInitialized(ServletContextEvent event) {
        initWebApplicationContext(event.getServletContext());
    }

    /**
     * Close the root web application context.
     */
    @Override
    public void contextDestroyed(ServletContextEvent event) {
        closeWebApplicationContext(event.getServletContext());
        ContextCleanupListener.cleanupAttributes(event.getServletContext());
    }

}