tomcat各组件生命周期控制

buser

了解tomcat的同学们都知道，apache搞的模块化开发，如tomcat就定义了一大堆的组件， 各个组件负责的责任不同，但是我们的这些组件的生命周期是怎么进行控制的呢，接下来就分析一下如果实现此功能（GOF的观察者模式）的，好了，不费话了，

第一：tomcat定义了一个生命周期的接口
Lifecycle.java接口中定义了几个方法
public void start() throws LifecycleException;
public void stop() throws LifecycleException;
//以上二个方法主要是在组件启动或者停止的时候被调用，
public void addLifecycleListener(LifecycleListener listener);
public LifecycleListener[] findLifecycleListeners();
public void removeLifecycleListener(LifecycleListener listener);
//以上二个方法主要是观察者的注册、移除、事件变更通知
第二：每个组件都实现了此接口并且实现了这些方法
如：Server组件、Service组件、Connector组件、各个Container容器等
第三：使用LifecycleSupport.java类来进行注册组件变更事件的观察者管理
此类的实例在每一个组件中都保持它的一个实例
private LifecycleSupport lifecycle = new LifecycleSupport(this);
每有注册、移除、事件变更通知时使用此属性调用来管理
在此类中定义了一个private LifecycleListener listeners[] = new LifecycleListener[0];数组在对观察都进行管理的
eg:当某个观察者想注册Server组件的话，调用过程如下：
StandardServer.java类中
public void addLifecycleListener(LifecycleListener listener) {
lifecycle.addLifecycleListener(listener);
}
LifecycleSupport.java类中的处理如下：
public void addLifecycleListener(LifecycleListener listener) {
synchronized (listenersLock) {
LifecycleListener results[] =
new LifecycleListener[listeners.length + 1];
for (int i = 0; i < listeners.length; i++)
results = listeners;
results[listeners.length] = listener;
listeners = results;
}
}
//以此类推，移除某个观察者也是这样的，下来看一看组件事件变更通知吧，
public void start() throws LifecycleException {
// Validate and update our current component state
if (started) {
log.debug(sm.getString("standardServer.start.started"));
return;
}
// Notify our interested LifecycleListeners
lifecycle.fireLifecycleEvent(BEFORE_START_EVENT, null);
lifecycle.fireLifecycleEvent(START_EVENT, null);//启动事件变更通知
在LifecycleSupport.java中处理变更事件如下：
public void fireLifecycleEvent(String type, Object data) {
LifecycleEvent event = new LifecycleEvent(lifecycle, type, data);
LifecycleListener interested[] = listeners;
for (int i = 0; i < interested.length; i++)
interested.lifecycleEvent(event);
}
///还有如stop事件等
public void stop() throws LifecycleException {
// Validate and update our current component state
if (!started)
return;
// Notify our interested LifecycleListeners
lifecycle.fireLifecycleEvent(BEFORE_STOP_EVENT, null);
lifecycle.fireLifecycleEvent(STOP_EVENT, null);
public void fireLifecycleEvent(String type, Object data) {
LifecycleEvent event = new LifecycleEvent(lifecycle, type, data);
LifecycleListener interested[] = listeners;
for (int i = 0; i < interested.length; i++)
interested.lifecycleEvent(event);
}
注意对组件进行了一个封闭成一个事件进行后续的处理，
public void fireLifecycleEvent(String type, Object data) {
LifecycleEvent event = new LifecycleEvent(lifecycle, type, data);//这里的继承关系可以查看一下源码
LifecycleListener interested[] = listeners;
for (int i = 0; i < interested.length; i++)
interested.lifecycleEvent(event);
}
看看这东东，对开闭原则守的，软件重用非常的好，观察者到此结束……