一、组件详解

在Tomcat处理客户端请求过程中,这里面有三个组件概念他们都是线程,分别负责不同职责
(必须记清楚这三个线程组件

二、请求处理流程

1.总体流程图

在这里插入图片描述

2.Worker线程任务流程

在这里插入图片描述

三、源码跟踪

1.Tomcat启动线程组件

Tomcat启动时,如果默认使用NIO模式,先是执行了AbstractEndpoint.initServerSocket,通过 ServerSocketChannel.open() 打开一个 ServerSocket通道默认绑定到 8080 端口用于监听请求

说明:在Java语言的NIO中,类ServerSocketChannel就是用来处理TPC连接客户端,他的open方法就是用例建立一个TPC连接

在这里插入图片描述

然后Tomcat创建Worker 线程池、Acceptor线程、Poller线程:

AbstractEndpoint.createExecutor,用于创建 Worker 线程池,这个线程池是用来处理实际的请求的,把配置文件中的初始线程数10、最大线程数200等信息传进去,创建一个线程池executor

在这里插入图片描述

AbstractEndpoint.createExecutor.startAcceptorThread,他创建一个线程任务Acceptor,作为一个接收者,线程用来无限循环接受客户端发送过来的连接请求

在这里插入图片描述

NioEndpoint.startInternal,创建一个线程任务Poller,用于检测Acceptor接兽并处理成已就绪的 Socket。

在这里插入图片描述

2.Acceptor

Tomcat启动完成后,客户端发起一个请求

Acceptor的run方法,无限循环这里接受连接请求
假如启动客户端发起一个请求,这里就是第一时间捕获到)

在这里插入图片描述
点进去NioEndpoint.serverSocketAccept(因为使用NIO模式),可以看到我们熟悉的nioaccept方法,这是一个阻塞方法,会一直等待接收请求。

在这里插入图片描述

当Acceptor接收客户端的请求时,调用addEvent() 方法会将 Socket 添加到该 Poller 的 PollerEvent 队列中。并调用了NIO中selector.wakeup方法,唤醒了Poller。到此,这一次请求中 Acceptor 的任务就完成了。

在这里插入图片描述

3.Poller

接着到Poller 线程了,Poller 线程1秒阻塞一次等待有请求过来被唤醒后,每次请求先过AbstractEndpoint.processSocket

处理器缓存获取当前要被执行的任务,放进任务进程然后获取Worker线程组,将这个任务放进去。到此 Poller 的任务就完成了。

在这里插入图片描述

4.Worker

然后就是到Worker线程组了,这次请求的后续的所有操作都在这个线程中完成。Worker线程是一个阻塞队列,它继承自AbstractQueuedSynchronizer。worker 线程被创建以后就执行 ThreadPoolExecutor 的 runWorker() 方法,试图从 workQueue 中取待处理任务,但是一开始 workQueue 是空的,所以 worker 线程会阻塞workQueue.take() 方法。

在这里插入图片描述
当新任务添加到 workQueue后,workQueue.take() 阻塞就会结束,会返回一个 Runnable,通常是 SocketWrapperBase,然后 worker 线程调用 SocketWrapperBase的 run() 方法对 Socket 进行处理。

执行SocketWrapperBase.run

在这里插入图片描述

里面调用的是 doRun方法,他是抽象方法,根据当前Tomcat使用模式是NIO还是APR去选择执行不同的方法(默认是NIO执行NioEndpoint里的内部类SocketProcessor.doRun)

在这里插入图片描述
这个socket处理器先做TPC的三次握手

在这里插入图片描述

三次握手这里Tomcat作为服务端,是需要响应(执行)两次的,源码断点发现每次http请求这里都是执行两次

三次握手中该方法执行两次:

一次执行时event对象null,执行完是OPEN_READ,表示数据可供客户端读取

第二次执行时event对象是OPEN_READ,如果停用长连接,执行完返回的是CLOSE,关闭连接,否则不关闭
走到下面,他是获取协议处理器,并执行他的process方法

在这里插入图片描述

执行AbstractProtocol.process

可以看到他是获取的Http11Processor,因为默认用的协议http1.1

在这里插入图片描述
下面执行这个处理器process方法

在这里插入图片描述

跟进去AbstractProcessorLight.process,然后到了Http11Processor.serviceservice方法先是从当前请求request中,解析请求行、请求头、请求体,封装成Request对象

在这里插入图片描述

下面获取adapter(CoyoteAdaptor),调用service方法

在这里插入图片描述
执行CoyoteAdaptor.service

获取到Request和Response并封装

在这里插入图片描述

然后调用postParseRequest方法,在 Mapper 中查询 URL 的映射关系

在这里插入图片描述
下面把封装成的Request对象和响应的Response对象传递给Engine容器,然后获取他的管道,执行里面绑定的阀门value

在这里插入图片描述

顺序执行多个阀门,实现对应功能

在这里插入图片描述

最后执行到StandardWrapperValve.invoke

在这里插入图片描述
将Servlet封装到FilterChain过滤器链中

在这里插入图片描述

他是定位到ApplicationFilterChain.doFilter,里面先是执行了Tomcat内置过滤器

在这里插入图片描述
在这里插入图片描述

下面执行了servlet.service

在这里插入图片描述
然后这里就是调用我们熟悉的HttpServletservice方法,解析里面对应的doGet方法,或者doPost方法等等… ,也就是执行具体业务方法。

最后由Servlet将响应返回给了客户端

在这里插入图片描述


总结

欢迎指出我的错误

原文地址:https://blog.csdn.net/weixin_42132143/article/details/130155530

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任

如若转载,请注明出处:http://www.7code.cn/show_36350.html

如若内容造成侵权/违法违规/事实不符,请联系代码007邮箱suwngjj01@126.com进行投诉反馈,一经查实,立即删除

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注