前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >tomcat请求分析(2)Socket转换为内部请求

tomcat请求分析(2)Socket转换为内部请求

作者头像
平凡的学生族
发布2019-05-25 09:29:23
7010
发布2019-05-25 09:29:23
举报
文章被收录于专栏:后端技术

参考

http://www.iocoder.cn/Tomcat/yuliu/A-request-analysis-2-Socket-is-converted-to-an-internal-request-object/

理解请求信息

请求信息包括以下三条

  • 请求行(request line) 例如GET /images/logo.gif HTTP/1.1,表示从/images目录下请求logo.gif这个文件。
  • 请求头(request header),空行 例如Accept-Language: en
  • 其他消息体

这里以请求行数据的解析为例,在 Http 协议中该行内容格式为:

代码语言:javascript
复制
Request-Line = Method SP Request-URI SP HTTP-Version CRLF

步骤总结

  1. Accepter接收新的socket连接后,创建SocketProcessor交给线程池运行。
  2. 后者在run内调用AbstractProtocol.AbstractConnectionHandler.process
  3. 然后进一步调用AbstractHttp11Processor.process,在此调用getInputBuffer().parseRequestLine(keptAlive)getInputBuffer().parseHeaders())来解析请求行和请求头部。
  4. InternalInputBuffer.parseRequestLinefill填充缓冲区,然后读取缓冲区来解析请求行。如果当前缓冲读完了,还不够解析,则继续调用fill读取,如下: do { // 缓冲区读完了还不够这部分解析的,需要继续读取。 if (pos >= lastValid) { if (!fill()) throw new EOFException(sm.getString("iib.eof.error")); // 没解析完读取流就见底了,报错 } ... chr = buf[pos++]; } while ((chr == Constants.CR) || (chr == Constants.LF));
  5. 请求头的最大长度是8192,在Http11Processor的构造函数中inputBuffer = new InternalInputBuffer(request, headerBufferSize);,提供的headerBufferSize就是最大长度。自行跟踪代码(全文搜索"ctrl+shift+f")可知道是8192)
  6. 请求内容的具体处理在adapter.service(request, response);,下篇文章讲解。

总结

BIO中,Accepter在接收新的socket连接后,创建新的线程,加入线程池来执行。每个连接(socket)对应一个线程,想必效率有限,也不适合高并发。

最大支持连接数

跟踪代码可知,AbstractEndpoint.createExecutor中:

代码语言:javascript
复制
executor = new ThreadPoolExecutor(getMinSpareThreads(), getMaxThreads(), 60, TimeUnit.SECONDS,taskqueue, tf);

其中getMaxThreads()最终调用:

代码语言:javascript
复制
 protected int getMaxThreadsExecutor(boolean useExecutor) {
        if (useExecutor && executor != null) {
            if (executor instanceof java.util.concurrent.ThreadPoolExecutor) {
                return ((java.util.concurrent.ThreadPoolExecutor)executor).getMaximumPoolSize();
            } else if (executor instanceof ResizableExecutor) {
                return ((ResizableExecutor)executor).getMaxThreads();
            } else {
                return -1;
            }
        } else {
            return maxThreads;
        }
    }

在executor没创建时,调用return maxThreads;。其中maxThreads在初始化时为200,因此线程池最大只能保持200个线程,支持的连接数应当也小于这个。在executor创建后,调用的是return ((java.util.concurrent.ThreadPoolExecutor)executor).getMaximumPoolSize();,如果没变化(暂时没验证何时会使该值变化)则依旧是200。

本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2019.04.11 ,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 参考
  • 理解请求信息
  • 步骤总结
  • 总结
  • 最大支持连接数
相关产品与服务
Elasticsearch Service
腾讯云 Elasticsearch Service(ES)是云端全托管海量数据检索分析服务,拥有高性能自研内核,集成X-Pack。ES 支持通过自治索引、存算分离、集群巡检等特性轻松管理集群,也支持免运维、自动弹性、按需使用的 Serverless 模式。使用 ES 您可以高效构建信息检索、日志分析、运维监控等服务,它独特的向量检索还可助您构建基于语义、图像的AI深度应用。
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档