1.程序入口
Bootstrap.java的main方法
關鍵語句:
public static void main(String args[]) {
if (daemon == null) {
// Don't set daemon until init() has completed
//創(chuàng)建對象
Bootstrap bootstrap = new Bootstrap();
try {
//初始化bootstrap
bootstrap.init();
} catch (Throwable t) {
handleThrowable(t);
t.printStackTrace();
return;
}
daemon = bootstrap;
} else {
// When running as a service the call to stop will be on a new
// thread so make sure the correct class loader is used to prevent
// a range of class not found exceptions.
Thread.currentThread().setContextClassLoader(daemon.catalinaLoader);
}
try {
String command = "start";
if (args.length > 0) {
command = args[args.length - 1];
}
if (command.equals("startd")) {
args[args.length - 1] = "start";
daemon.load(args);
daemon.start();
} else if (command.equals("stopd")) {
args[args.length - 1] = "stop";
daemon.stop();
} else if (command.equals("start")) {
daemon.setAwait(true);
//裝在參數(shù)
daemon.load(args);
//開始啟動
daemon.start();
if (null == daemon.getServer()) {
System.exit(1);
}
} else if (command.equals("stop")) {
daemon.stopServer(args);
} else if (command.equals("configtest")) {
daemon.load(args);
if (null == daemon.getServer()) {
System.exit(1);
}
System.exit(0);
} else {
log.warn("Bootstrap: command \"" + command + "\" does not exist.");
}
} catch (Throwable t) {
// Unwrap the Exception for clearer error reporting
if (t instanceof InvocationTargetException &&
t.getCause() != null) {
t = t.getCause();
}
handleThrowable(t);
t.printStackTrace();
System.exit(1);
}
}
2.程序分析
--------------------------設置環(huán)境變量----------------------------------
>Bootstrap下的靜態(tài)代碼塊;//定義Globals.CATALINA_HOME_PROP和Globals.CATALINA_BASE_PROP環(huán)境變量
>Bootstrap bootstrap = new Bootstrap();
--------------------------init()----------------------------------
>bootstrap.init();
>initClassLoaders();
>commonLoader = createClassLoader("common", null);
>CatalinaProperties.getProperty(name + ".loader");//裝載.loader文件
>loadProperties();//CatalinaProperties靜態(tài)代碼塊,主要是解析裝載/conf/catalina.properties文件
>ClassLoaderFactory.createClassLoader(repositories, parent);//創(chuàng)建類加載器
>return new URLClassLoader(array);//array是lib文件夾下的jar的url
--------------------------load()----------------------------------
>daemon.load(args);
>method.invoke(catalinaDaemon, param);//調(diào)用catalina的load方法
>Digester digester = createStartDigester(); //創(chuàng)建和執(zhí)行破殼器
>digester.addObjectCreate("Server","org.apache.catalina.core.StandardServer","className");//基于StandardServer創(chuàng)建Server對象
>digester.addSetProperties("Server");//設置屬性
>digester.addSetNext("Server","setServer","org.apache.catalina.Server");//執(zhí)行setServer方法
>digester.parse(inputSource); //使用破殼器解析server.xml,**重要**
--------------------------初始化容器----------------------------------
>getServer().init(); //初始化server
>LefecycleBase.initInternal();//調(diào)用基類的initInternal方法
>StanderServer.initInternal();//調(diào)用StanderServer的initInternal方法
>services[i].init(); //調(diào)用services的init方法
>LefecycleBase.initInternal();//調(diào)用基類的initInternal方法
>StanderService.initInternal();//調(diào)用StanderService的initInternal方法
>engine.init();//調(diào)用engine的init方法
>LefecycleBase.initInternal();//調(diào)用基類的initInternal方法
>StanderEngine.initInternal();//調(diào)用StanderEngine的initInternal方法
>super.initInternal();
>startStopExecutor = new ThreadPoolExecutor(getStartStopThreadsInternal(),getStartStopThreadsInternal(), 10, TimeUnit.SECONDS,startStopQueue,new StartStopThreadFactory(getName() + "-startStop-"));//創(chuàng)建線程池
--------------------------初始化executor----------------------------------
>executor.init();//執(zhí)行器初始化
--------------------------初始化mapperListener----------------------------------
>mapperListener.init();//映射監(jiān)聽器初始化
>LifecycleMBeanBase.initInternal();
--------------------------初始化connector----------------------------------
>connector.init();//連接器初始化
>Connector.initInternal();
>adapter = new CoyoteAdapter(this);//適配器
>protocolHandler.setAdapter(adapter);//協(xié)議適配器
>protocolHandler.init();
>AbstractHttp11Protocol.init();
>endpoint.init(); //端點初始化
--------------------------start()----------------------------------
>daemon.start();//啟動
>method.invoke(catalinaDaemon, (Object [])null); //調(diào)用catalina的start方法
>start();
>getServer().start();//啟動server
>LefecycleBase.start();//
>startInternal();//
>StandardServer.startInternal()//調(diào)用StandardServer啟動
>globalNamingResources.start();
>services[i].start();//啟動service
>LefecycleBase.start();
>startInternal();
>stanardservice.startInternal();//調(diào)用stanardservice啟動
--------------------------啟動engine----------------------------------
>engine.start();//啟動engine
>results.add(startStopExecutor.submit(new StartChild(children[i])));
>child.start();
>StandardHost.startInternal()
>setState(LifecycleState.STARTING);//ContainerBase.java
>fireLifecycleEvent(lifecycleEvent, data);
>lifecycleEvent()//HostConfig
>start();
>deployApps(); //部署webapp
--------------------------啟動executor----------------------------------
>executor.start();//啟動執(zhí)行器
--------------------------啟動connector----------------------------------
>connector.start();//啟動連接器
>lefcycleBase.start();
>Connector.startInternal();
>protocolHandler.start();//協(xié)議處理器啟動
>AbstractProtocol.start();
>endpoint.start();//端點啟動
>AbstractEndpoint.start();
>startInternal();
>NioEndpoint.startInternal();//NioEndpoint啟動
>pollerThread.start();//poller線程啟動
>poller.run();
>processKey(sk, attachment);//接收到請求進入此方法
>processSocket(attachment, SocketEvent.OPEN_READ, true);
>createSocketProcessor(socketWrapper, event);//創(chuàng)建SocketProcessor
>return new SocketProcessor(socketWrapper, event);
>SocketProcessorBase.run();
>SocketProcessor.doRun();//運行SocketProcessor
>state = getHandler().process(socketWrapper, SocketEvent.OPEN_READ);//
>state = processor.process(wrapper, status);
>state = service(socketWrapper);
>http11Processor.service();//http11Processor
>getAdapter().service(request, response);//
>CoyoteAdapter.service(request, response);//適配器執(zhí)行service方法
>postParseSuccess = postParseRequest(req, request, res, response);//解析請求
>connector.getService().getMapper().map(serverName, decodedURI,version, request.getMappingData());//請求路徑映射
>connector.getService().getContainer().getPipeline().getFirst().invoke(request, response);//調(diào)用第一個container的valve
>StandardEngineValve.invoke(request, response);
>host.getPipeline().getFirst().invoke(request, response);//調(diào)用host容器
>StandardHostValve.invoke(request, response);
>context.getPipeline().getFirst().invoke(request, response);//調(diào)用context容器
>StandardContextValve.invoke(request, response);
>wrapper.getPipeline().getFirst().invoke(request, response);//調(diào)用wrapper
>StandardWrapperValve.invoke(request, response);
>servlet = wrapper.allocate();
>ApplicationFilterChain filterChain =ApplicationFilterFactory.createFilterChain(request, wrapper, servlet);//創(chuàng)建過濾器鏈
>filterChain.doFilter(request.getRequest(), response.getResponse());
>internalDoFilter(request,response);
>filter.doFilter(request, response, this);
>chain.doFilter(request, response);
>internalDoFilter(request,response);
>servlet.service(request, response);//servlet執(zhí)行service方法
>filterChain.release();//釋放filterChain
>wrapper.deallocate(servlet);//釋放wrapper
--------------------------阻塞等待----------------------------------
>await();
>StandardServer.await();
>awaitSocket = new ServerSocket(port, 1,InetAddress.getByName(address));//port 8005
>socket = serverSocket.accept();//阻塞等待
>