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();
}
}
至此,一个缓冲池轻松实现了。
分享到:
相关推荐
4. **源码分析** 解压“jakarta-tomcat-connectors-jk2-2.0.4-src”后,我们可以深入研究JK2的源代码结构,包括核心的模块、协议处理器、连接器实现等。通过阅读源码,开发者可以了解其实现原理,自定义配置,甚至...
- **Buffer Pool**: 缓冲池技术用于减少内存分配和释放的开销。 7. **故障排查与调试** - **日志系统**: Tomcat的日志系统可以帮助开发者跟踪和定位问题,源码中包含了丰富的日志输出选项。 - **JMX(Java ...
《深度剖析Tomcat》这本书是理解Apache Tomcat工作原理的重要参考资料。Tomcat是一款开源的Java Servlet容器,广泛用于部署Web应用程序。...书中的案例和源码分析能帮助开发者解决实际问题,提高工作效率。
源码分析可以让你深入了解Tomcat的工作流程,例如如何解析HTTP请求,如何调度线程处理请求,以及Servlet的加载过程等。通过阅读源码,开发者可以更好地定位和解决问题,提升系统性能,甚至参与到Tomcat的开发和贡献...
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...
NIOEventLoopGroup源码分析 NIOEventLoopGroup是Netty中用于处理基于NIO的事件循环的类。它继承自`MultithreadEventLoopGroup`,该类负责管理一组`EventLoop`实例,每个`EventLoop`实例都包含了对特定`Channel`的I...
Java数据压缩与传输实例 1个目标文件 摘要:Java源码,文件操作,数据压缩,文件传输 Java数据压缩与传输实例,可以学习一下实例化套按字、得到文件输入流、压缩输入流、文件输出流、实例化缓冲区、写入数据到文件、...
模板中会定义了一系列监控项,包括但不限于SQL查询执行时间、连接数、磁盘I/O、InnoDB缓冲池状态等。通过导入这个模板到Zabbix服务器,可以快速地为MySQL实例设置全面的监控。 综上所述,要实现“zbbix 监控mysql的...
1. **Nginx作为前端服务器:** 负责处理静态文件请求和转发动态请求到后端的Tomcat服务器。 2. **Tomcat作为后端服务器:** 负责处理动态内容,如JSP页面、Servlet等。 3. **配置Nginx:** 在Nginx中配置location块...
这涉及到SQL查询、数据操作以及数据库连接池的使用,如C3P0或DBCP。 5. **用户认证与授权**:尽管描述没有明确提及,但一个成熟的网络电台可能包含用户登录注册系统,涉及用户身份验证和权限控制,如基于session的...
wait是Object类的方法,对此对象调用wait方法导致本线程放弃对象锁,进入等待此对象的等待锁定池,只有针对此对象发出notify方法(或notifyAll)后本线程才进入对象锁定池准备获得对象锁进入运行状态。 17、...