Tomcat源碼分析(二)

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();//阻塞等待
>
?著作權歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點,簡書系信息發(fā)布平臺,僅提供信息存儲服務。

相關閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容