`
michael.softtech
  • 浏览: 208430 次
  • 性别: Icon_minigender_1
  • 来自: 上海
文章分类
社区版块
存档分类
最新评论

tomcat 源码分析之--请求接受以及缓冲池

阅读更多

tomcat  从接受请求到处理的流程大概如下:

 

首先配置文件中的connector都对应一个Connector类,这个类根据配置信息确定对应的

ProtocalHandler(处理connector配置对应的协议).

 

public void start() throws LifecycleException {
	    if( !initialized )
	        initialize();
	
	    // Validate and update our current state
	    if (started ) {
	        if(log.isInfoEnabled())
	            log.info(sm.getString("coyoteConnector.alreadyStarted"));
	        return;
	    }
	    lifecycle.fireLifecycleEvent(START_EVENT, null);
	    started = true;
	
	    // We can't register earlier - the JMX registration of this happens
	    // in Server.start callback
	    if ( this.oname != null ) {
	        // We are registred - register the adapter as well.
	        try {
	            Registry.getRegistry(null, null).registerComponent
	                (protocolHandler, createObjectName(this.domain,"ProtocolHandler"), null);
	        } catch (Exception ex) {
	            log.error(sm.getString
	                      ("coyoteConnector.protocolRegistrationFailed"), ex);
	        }
	    } else {
	        if(log.isInfoEnabled())
	            log.info(sm.getString
	                 ("coyoteConnector.cannotRegisterProtocol"));
	    }
	
	    try {
	        protocolHandler.start();
	    } catch (Exception e) {
	        String errPrefix = "";
	        if(this.service != null) {
	            errPrefix += "service.getName(): \"" + this.service.getName() + "\"; ";
	        }
	
	        throw new LifecycleException
	            (errPrefix + " " + sm.getString
	             ("coyoteConnector.protocolHandlerStartFailed", e));
	    }
	
	    if( this.domain != null ) {
	        mapperListener.setDomain( domain );
	        //mapperListener.setEngine( service.getContainer().getName() );
	        mapperListener.init();
	        try {
	            ObjectName mapperOname = createObjectName(this.domain,"Mapper");
	            if (log.isDebugEnabled())
	                log.debug(sm.getString(
	                        "coyoteConnector.MapperRegistration", mapperOname));
	            Registry.getRegistry(null, null).registerComponent
	                (mapper, mapperOname, "Mapper");
	        } catch (Exception ex) {
	            log.error(sm.getString
	                    ("coyoteConnector.protocolRegistrationFailed"), ex);
	        }
	    }
	}

 

   抛开其他代码,注意上面方法里面的这一句:protocolHandler.start();
   比如http1.1协议对应的ProtocalHandler是:Http11Protocol。

   而这个ProtocalHanler依靠一个对应的EndPoint对象来处理请求,http11protocal的start方法代码

  如下:

 

  

public void start() throws Exception {
        if (this.domain != null) {
            try {
                tpOname = new ObjectName
                    (domain + ":" + "type=ThreadPool,name=" + getName());
                Registry.getRegistry(null, null)
                    .registerComponent(endpoint, tpOname, null );
            } catch (Exception e) {
                log.error("Can't register endpoint");
            }
            rgOname=new ObjectName
                (domain + ":type=GlobalRequestProcessor,name=" + getName());
            Registry.getRegistry(null, null).registerComponent
                ( cHandler.global, rgOname, null );
        }

        try {
            endpoint.start();
        } catch (Exception ex) {
            log.error(sm.getString("http11protocol.endpoint.starterror"), ex);
            throw ex;
        }
        if (log.isInfoEnabled())
            log.info(sm.getString("http11protocol.start", getName()));
    }

 

    注意其中的代码:        endpoint.start();

   Endpoint是对应的protocalhandler的工具类,每个endpoinst都监听一个对应的ServerSocket并且处理请求,start方法代码如下:

  

public void start()
        throws Exception {
        // Initialize socket if not done before
        if (!initialized) {
            init();
        }
        if (!running) {
            running = true;
            paused = false;

            // Create worker collection
            if (executor == null) {
                workers = new WorkerStack(maxThreads);
            }

            // Start acceptor threads
            for (int i = 0; i < acceptorThreadCount; i++) {
                Thread acceptorThread = new Thread(new Acceptor(), getName() + "-Acceptor-" + i);
                acceptorThread.setPriority(threadPriority);
                acceptorThread.setDaemon(daemon);
                acceptorThread.start();
            }
        }
    }

 

   很容易看出,其实tomcat的请求监听也不是单线程的,有多个线程在进行监听。那么每个监听线程在监听到socket请求之后做什么工作呢?就是处理socket.这是通过调用Endpoint的processSocket方法实现的:

 

  protected boolean processSocket(Socket socket) {
        try {
            if (executor == null) {
                getWorkerThread().assign(socket);
            } else {
                executor.execute(new SocketProcessor(socket));
            }
        } catch (Throwable t) {
            // This means we got an OOM or similar creating a thread, or that
            // the pool and its queue are full
            log.error(sm.getString("endpoint.process.fail"), t);
            return false;
        }
        return true;
    }

    

    如果在  配置文件里面定义了一个executor,那么就使用此executor.否则使用默认的Worker缓冲池。下面就来分析一下worker缓冲池的实现:

    worker是存放在WorkerStack里面的,WorkerStack维护了一个worker数组。当endpoint里面需要worker线程的时候,会调用如下方法:

  

protected Worker createWorkerThread() {

        synchronized (workers) {
            if (workers.size() > 0) {
                curThreadsBusy++;
                return workers.pop();
            }
            if ((maxThreads > 0) && (curThreads < maxThreads)) {
                curThreadsBusy++;
                if (curThreadsBusy == maxThreads) {
                    log.info(sm.getString("endpoint.info.maxThreads",
                            Integer.toString(maxThreads), address,
                            Integer.toString(port)));
                }
                return (newWorkerThread());
            } else {
                if (maxThreads < 0) {
                    curThreadsBusy++;
                    return (newWorkerThread());
                } else {
                    return (null);
                }
            }
        }

    }

   

   这个方法不多说了,一看就差不多明白大概原理。但是可能还有一点疑问:新增的worker如何放到WorkerStack里面呢? 这个就要看一下Worker的实现了:worker运行最后有一句代码:recycleWorkerThread。

 

  

    protected void recycleWorkerThread(Worker workerThread) {
        synchronized (workers) {
            workers.push(workerThread);
            curThreadsBusy--;
            workers.notify();
        }
    }

  

至此,一个缓冲池轻松实现了。

      

0
1
分享到:
评论

相关推荐

    jakarta-tomcat-connectors-jk2-src-current.tar.gz

    4. **源码分析** 解压“jakarta-tomcat-connectors-jk2-2.0.4-src”后,我们可以深入研究JK2的源代码结构,包括核心的模块、协议处理器、连接器实现等。通过阅读源码,开发者可以了解其实现原理,自定义配置,甚至...

    tomcat源码研读笔记中的tomcat源码

    - **Buffer Pool**: 缓冲池技术用于减少内存分配和释放的开销。 7. **故障排查与调试** - **日志系统**: Tomcat的日志系统可以帮助开发者跟踪和定位问题,源码中包含了丰富的日志输出选项。 - **JMX(Java ...

    how tomcat work

    《深度剖析Tomcat》这本书是理解Apache Tomcat工作原理的重要参考资料。Tomcat是一款开源的Java Servlet容器,广泛用于部署Web应用程序。...书中的案例和源码分析能帮助开发者解决实际问题,提高工作效率。

    How Tomcat Works 中文版/英文版 + 源码

    源码分析可以让你深入了解Tomcat的工作流程,例如如何解析HTTP请求,如何调度线程处理请求,以及Servlet的加载过程等。通过阅读源码,开发者可以更好地定位和解决问题,提升系统性能,甚至参与到Tomcat的开发和贡献...

    tocamt7.0源码

    8. **性能优化**:Tomcat源码中包含了多线程、连接池、缓冲区等优化策略,这些都是提升服务器性能的关键。 在深入研究源码时,建议配合官方文档、相关教程和社区讨论,以辅助理解和解决问题。同时,通过阅读源码,...

    开涛高可用高并发-亿级流量核心技术

    12.2.2 HttpClient连接池源码分析 240 12.2.3 HttpClient 4.2.3配置 241 12.2.4 问题示例 243 12.3 线程池 244 12.3.1 Java线程池 245 12.3.2 Tomcat线程池配置 248 13 异步并发实战 250 13.1 同步阻塞调用 251 13.2...

    Netty面试题(2022最新版)

    NIOEventLoopGroup源码分析 NIOEventLoopGroup是Netty中用于处理基于NIO的事件循环的类。它继承自`MultithreadEventLoopGroup`,该类负责管理一组`EventLoop`实例,每个`EventLoop`实例都包含了对特定`Channel`的I...

    JAVA上百实例源码以及开源项目源代码

    Java数据压缩与传输实例 1个目标文件 摘要:Java源码,文件操作,数据压缩,文件传输 Java数据压缩与传输实例,可以学习一下实例化套按字、得到文件输入流、压缩输入流、文件输出流、实例化缓冲区、写入数据到文件、...

    zbbix 监控mysql的脚本

    模板中会定义了一系列监控项,包括但不限于SQL查询执行时间、连接数、磁盘I/O、InnoDB缓冲池状态等。通过导入这个模板到Zabbix服务器,可以快速地为MySQL实例设置全面的监控。 综上所述,要实现“zbbix 监控mysql的...

    架构师实战Nginx构建高性能WEB服务器

    1. **Nginx作为前端服务器:** 负责处理静态文件请求和转发动态请求到后端的Tomcat服务器。 2. **Tomcat作为后端服务器:** 负责处理动态内容,如JSP页面、Servlet等。 3. **配置Nginx:** 在Nginx中配置location块...

    [影音娱乐]彩森视频网络电台DQUS版_dqus.zip

    这涉及到SQL查询、数据操作以及数据库连接池的使用,如C3P0或DBCP。 5. **用户认证与授权**:尽管描述没有明确提及,但一个成熟的网络电台可能包含用户登录注册系统,涉及用户身份验证和权限控制,如基于session的...

    超级有影响力霸气的Java面试题大全文档

    wait是Object类的方法,对此对象调用wait方法导致本线程放弃对象锁,进入等待此对象的等待锁定池,只有针对此对象发出notify方法(或notifyAll)后本线程才进入对象锁定池准备获得对象锁进入运行状态。 17、...

Global site tag (gtag.js) - Google Analytics