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

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 Services for (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 state if (started) throw new LifecycleException (sm.getString("standardServer.start.started")); // Notify our interested LifecycleListeners ... started = true; // Start our defined Services synchronized (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 state if (!started) throw new LifecycleException (sm.getString("standardServer.stop.notStarted")); // Notify our interested LifecycleListeners ... started = false; // Stop our defined Services for (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 method service.setContainer(engine); //容器并没有直接和连接器关联,而是和服务组件关联 // Start the new server if (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 server if (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 class int 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."); } }}

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。