How tomcat works 读书笔记十四 服务器组件和服务组件
来源:程序员人生 发布时间:2015-01-06 09:04:19 阅读次数:3016次
之前的项目还是有些问题的,例如
1 只能有1个连接器,只能处理http要求,没法添加另外1个连接器用来处理https。
2 对容器的关闭只能是粗鲁的关闭Bootstrap。
org.apache.catalina.Server接口的实例用来表示Catalina的全部servlet引擎。
我们使用Server就是由于,它用1种优雅的方式来启动/关闭全部系统。
下面是启动和停止机制是如何工作的。当
服务器启动的时候,它启动它内部的所有组件。然后无穷期的等待关闭命令,如果你想要关闭系统,发送1个关闭命令道指定端口便可。当
服务器收到正确的关闭指令后,它停止所有组件的服务。
服务器还使用了另外1个组件,即服务组件,它用来持有组件,例如容器或1个多个的连接器。服务组件将在本章的 service 小节中介绍。(注意有
服务器组件,也有服务组件,这两个是不1样的。)
Server接口中属性 shutdown 用来持有1个停止服务的指令。属性 port 则是
服务器等待关闭命令的端口。可以调用
服务器的 addService 方法将服务添加到
服务器。使用removeService 方法将服务删除。findServices 返回所有
服务器中所有的服务。
StandardServer类
StandardServer类是Server接口的标准实现。在这里,我们主要介绍它的4个方法。initialize(),start(),stop(),await();
我们1个1个来讲。
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();
}
}
我们能看到这里使用了1个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方法,stop4者者都是在Bootstrap里调用的。
当await方法履行终了后,就会调用
服务器的stop方法。
Service接口
org.apache.catalina.Service 接口用于表示服务。1个服务可以有1个容器和多个连接器。你可以添加多个连接器 ,并将它们跟容器相干联。
StandardService类
StandardService是Service接口的标准实现。
容器与连接器
1个 StandardService 实例包括两种组件:1个容器和多个连接器。多个连接器可使得 Tomcat 能服务于多个协议。1个协议用途处理 HTTP 要求,另外一个用于处理 HTTPS 要求。
StandardService 类用 container 变量来持有容器实例,用 connectors 数组来持有所有的连接器
private Container container = null;
private Connector connectors[] = new Connector[0];
要将1个容器跟1个服务相干联,可使用它的 setContainer 方法,
在setContainer中,会把container传递给每个connector。
synchronized (connectors) {
for (int i = 0; i < connectors.length; i++)
connectors[i].setContainer(this.container);
}
要给1个服务添加连接器,可使用 addConnector 方法。在添加连接器的同时也会初始化他们。
要删除1个连接器,可使用 removeConnector 方法。
与生命周期相干的方法
这里主要包括3个方法,initialize,start,stop。
initialize功能就是调用所以连接器的initialize方法。
start功能就是启动容器和若干个连接器。
stop功能就是关闭容器和若干个连接器。
服务组件的这3个方法都会在
服务器组件里相应的方法里被调用,而
服务器组件的这3个方法是在Bootstrap里调用的。
利用程序
这里主要是两个类,1个是 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信息 这里会1直循环
// 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.");
}
}
}
生活不易,码农辛苦
如果您觉得本网站对您的学习有所帮助,可以手机扫描二维码进行捐赠