How tomcat works 读书笔记十四服务器组件和服务组件

之前的项目还是有些问题的,例如
1 只能有一个连接器,只能处理http请求,无法添加另外一个连接器用来处理https。
2 对容器的关闭只能是粗暴的关闭Bootstrap。

服务器组件

org.apache.catalina.Server接口的实例用来表示Catalina的整个servlet引擎。
我们使用Server就是因为,它用一种优雅的方式来启动/关闭整个系统。
下面是启动和停止机制是如何工作的。当服务器启动的时候，它启动它内部的所有组件。然后无限期的等待关闭命令，如果你想要关闭系统，发送一个关闭命令道指定端口即可。当服务器收到正确的关闭指令后，它停止所有组件的服务。
服务器还使用了另外一个组件，即服务组件，它用来持有组件，例如容器或者一个多个的连接器。服务组件将在本章的 service 小节中介绍。(注意有服务器组件,也有服务组件,这两个是不一样的。)
Server接口中属性 shutdown 用来持有一个停止服务的指令。属性 port 则是服务器等待关闭命令的端口。可以调用服务器的 addService 方法将服务添加到服务器。使用removeService 方法将服务删除。findServices 返回所有服务器中所有的服务。

StandardServer类

StandardServer类是Server接口的标准实现。在这里,我们主要介绍它的四个方法。initialize(),start(),stop(),await();
我们一个一个来说。

initialize方法

    public void initialize() throws LifecycleException {if (initialized)throw new LifecycleException (sm.getString("standardServer.initialize.initialized"));initialized = true;// Initialize our defined Servicesfor (int i = 0; i < services.length; i++) {services[i].initialize();}}

我们能看到这里使用了一个initialized来标识服务器是否已经初始化,同时初始化它所包含的服务组件。
另外在stop中,initialized并没有更改,因此如果服务器先初始化,再关闭,等再次初始化的时候会抛出异常。

start方法

public void start() throws LifecycleException {// Validate and update our current component stateif (started)throw new LifecycleException(sm.getString("standardServer.start.started"));// Notify our interested LifecycleListeners...started = true;// Start our defined Servicessynchronized (services) {for (int i = 0; i < services.length; i++) {if (services[i] instanceof Lifecycle)((Lifecycle) services[i]).start();}}// Notify our interested LifecycleListeners...}

和初始化干的事情差不多,循环启动它所关联的服务组件。另外在stop方法中,started会被置为false。

stop方法

public void stop() throws LifecycleException {// Validate and update our current component stateif (!started)throw new LifecycleException(sm.getString("standardServer.stop.notStarted"));// Notify our interested LifecycleListeners...started = false;// Stop our defined Servicesfor (int i = 0; i < services.length; i++) {if (services[i] instanceof Lifecycle)((Lifecycle) services[i]).stop();}// Notify our interested LifecycleListeners...}

关闭所有的服务组件。

await方法

这里不再贴出代码,await做的事就是监听8005端口,如果用户给8005端口发来"SHUTDOWN"就关闭serverSocket,然后await方法就执行完了。

现在再说说initialize方法,start方法,await方法,stop四者者都是在Bootstrap里调用的。
当await方法执行完毕后,就会调用服务器的stop方法。

Service接口

org.apache.catalina.Service 接口用于表示服务。一个服务可以有一个容器和多个连接器。你可以添加多个连接器，并将它们跟容器相关联。

StandardService类

StandardService是Service接口的标准实现。

容器与连接器

一个 StandardService 实例包括两种组件：一个容器和多个连接器。多个连接器可以使得 Tomcat 能服务于多个协议。一个协议用处处理 HTTP 请求，另一个用于处理 HTTPS 请求。
StandardService 类用 container 变量来持有容器实例，用 connectors 数组来持有所有的连接器

private Container container = null;
private Connector connectors[] = new Connector[0];

要将一个容器跟一个服务相关联，可以使用它的 setContainer 方法，
在setContainer中,会把container传递给每一个connector。

        synchronized (connectors) {for (int i = 0; i < connectors.length; i++)connectors[i].setContainer(this.container);}

要给一个服务添加连接器，可以使用 addConnector 方法。在添加连接器的同时也会初始化他们。
要删除一个连接器，可以使用 removeConnector 方法。

与生命周期相关的方法

这里主要包含三个方法,initialize,start,stop。
initialize功能就是调用所以连接器的initialize方法。
start功能就是启动容器和若干个连接器。
stop功能就是关闭容器和若干个连接器。
服务组件的这三个方法都会在服务器组件里相应的方法里被调用,而服务器组件的这三个方法是在Bootstrap里调用的。

应用程序

这里主要是两个类,一个是 Bootstrap 启动程序，另一个是 Stopper 类用来停止它。

Bootstrap类

public static void main(String args[]){
......Service service = new StandardService();service.setName("Stand-alone Service");Server server = new StandardServer();server.addService(service);      //把服务组件添加到服务器组件里service.addConnector(connector); //把连接器关联到服务组件里//StandardService class's setContainer will call all its connector's setContainer methodservice.setContainer(engine);    //容器并没有直接和连接器关联,而是和服务组件关联// Start the new serverif (server instanceof Lifecycle) {try {server.initialize();         //调用initialize,start,await方法((Lifecycle) server).start();//这里会调用服务组件的start,来调用连接器与容器的start//连接器会在8080上等待消息....server.await();              //除非在8005端口收到了SHUTDOWN信息 这里会一直循环// the program waits until the await method returns,// i.e. until a shutdown command is received.}catch (LifecycleException e) {e.printStackTrace(System.out);}}// Shut down the serverif (server instanceof Lifecycle) {try {((Lifecycle) server).stop();  //收到了SHUTDOWM信息,关闭服务器组件}catch (LifecycleException e) {e.printStackTrace(System.out);}}}

Stopper类

public class Stopper {public static void main(String[] args) {// the following code is taken from the Stop method of// the org.apache.catalina.startup.Catalina classint port = 8005;try {Socket socket = new Socket("127.0.0.1", port);OutputStream stream = socket.getOutputStream();String shutdown = "SHUTDOWN";for (int i = 0; i < shutdown.length(); i++)stream.write(shutdown.charAt(i));stream.flush();stream.close();socket.close();System.out.println("The server was successfully shut down.");}catch (IOException e) {System.out.println("Error. The server has not been started.");}}
}