[Web Server]Tomcat调优之SpringBoot内嵌Tomcat源码分析

以springboot:2.3.12.RELEASE中内嵌的tomcat-embed-core:9.0.46为例，进行分析

1 概述

1.0 关键依赖包

• spring-boot-autoconfigure : 2.3.12.RELEASE
• spring-boot : 2.3.12.RELEASE
• spring-context : 5.2.15.RELEASE
• spring-webmvc : 5.2.15.RELEASE
• tomcat-embed-core:9.0.46
• tomcat-embed-jasper:9.0.46

1.1 内嵌 Web Server 的优势

我们在使用 springboot 开发 web 项目时，大多数时候采用的是内置的 Tomcat （当然也可配置支持内置的 jett y），内置 Tomcat 有什么好处呢？

• 方便微服务部署，减少繁杂的配置
• 方便项目启动，不需要单独下载web容器，如Tomcat，jetty等。

1.2 Web Server 的优化思路

针对目前的容器优化，可以从以下几点考虑：

• 1、线程数

首先，线程数是一个重点，每一次HTTP请求到达Web服务器，Web服务器都会创建一个线程来处理该请求，该参数决定了应用服务同时可以处理多少个HTTP请求。
比较重要的有两个：1) 初始线程数; 2) 最大线程数。

• 初始线程数：保障启动的时候，如果有大量用户访问，能够很稳定的接受请求。
• 最大线程数：用来保证系统的稳定性。

• 2、超时时间

超时时间：用来保障连接数不容易被压垮。
如果大批量的请求过来，延迟比较高，很容易把线程数用光，这时就需要提高超时时间。
这种情况在生产中是比较常见的 ，一旦网络不稳定，宁愿丢包也不能把服务器压垮。

• 3、JVM优化

1.3 Tomcat Web Server的核心配置参数

min-spare-threads

默认 10
最小备用线程数，tomcat启动时的初始化的线程数。

max-threads

默认 200
Tomcat可创建的最大的线程数，每一个线程处理一个请求；
超过这个请求数后，客户端请求只能排队，等有线程释放才能处理。
建议：这个配置数可以在服务器CUP核心数的 200~250 倍之间

accept-count

默认 100
当调用Web服务的HTTP请求数达到tomcat的最大线程数时，还有新的HTTP请求到来，这时tomcat会将该请求放在等待队列中
这个acceptCount就是指能够接受的最大等待数
如果等待队列也被放满了，这个时候再来新的请求就会被tomcat拒绝（connection refused）。

max-connections

这个参数是指在同一时间，tomcat能够接受的最大连接数。（最大线程数+排队数）
一般这个值要大于 (max-threads)+(accept-count)。

connection-timeout

1 默认值: 60S or 20S
2 参数定义: 与客户端建立连接后，Tomcat 等待客户端请求的时间。 如果客户端没有请求进来，等待一段时间后断开连接，释放线程。
3 备注说明: Tomcat 中 等效于 : socket.soTimeout (SO_TIMEOUT) => 即: 为 socket 调用 read() 等待读取的时间
4 入口类:

keepAliveTimeout

Tomcat 在关闭连接(Connector)之前，等待另一个请求的时间

• HTTP 1.0

http协议的早期是，每开启一个http链接，是要进行一次socket，也就是新启动一个TCP链接。

• HTTP 1.1

1 特性：长连接 (现主流浏览器的默认协议)
2 使用keep-alive可以改善这种状态，即在一次TCP连接中可以持续发送多份数据而不会断开连接。通过使用keep-alive机制，可以减少tcp连接建立次数。
3 如果浏览器支持keepalive的话，那么请求头中会有: Connection: Keep-Alive
4 对于keepalive的部分，主要集中在Connection属性当中，这个属性可以设置两个值：

• close （告诉WEB服务器或者代理服务器，在完成本次请求的响应后，断开连接，不要等待本次连接的后续请求了）。
• keepalive （告诉WEB服务器或者代理服务器，在完成本次请求的响应后，保持连接，等待本次连接的后续请求）。
  5 keep-alive与TIME_WAIT的关系?
• 使用http keep-alive，可以减少服务端TIME_WAIT数量(因为由服务端httpd守护进程主动关闭连接)。道理很简单，相较而言，启用keep-alive，建立的tcp连接更少了，自然要被关闭的tcp连接也相应更少了。
• 什么是TIME_WAIT呢？
  • 通信双方建立TCP连接后，主动关闭连接的一方就会进入TIME_WAIT状态。
  • 客户端主动关闭连接时，会发送最后一个ack后，然后会进入TIME_WAIT状态，再停留2个MSL时间，进入CLOSED状态。
• 那么这个TIME_WAIT到底有什么作用呢？主要原因：
  • a）可靠地实现TCP全双工连接的终止
  • b）允许老的重复分节在网络中消逝
    6 截止目前，我们讨论的是 http 1.1 request/response header 的 keep-alive 选项；而 tcp协议 也有keepalive的概念。

http keep-alive与tcp keep-alive，不是同一回事，意图不一样。

http keep-alive是为了让tcp活得更久一点，以便在同一个连接上传送多个http，提高socket的效率。

而tcp keep-alive是TCP的一种检测TCP连接状况的保鲜机制。

tcp keep-alive保鲜定时器，支持三个系统内核配置参数：
	echo 1800 > /proc/sys/net/ipv4/tcp_keepalive_time
	echo 15 > /proc/sys/net/ipv4/tcp_keepalive_intvl
	echo 5 > /proc/sys/net/ipv4/tcp_keepalive_probes
	
keepalive是TCP保鲜定时器，当网络两端建立了TCP连接之后，闲置idle（双方没有任何数据流发送往来）了tcp_keepalive_time后，服务器内核就会尝试向客户端发送侦测包，来判断TCP连接状况(有可能客户端崩溃、强制关闭了应用、主机不可达等等)。如果没有收到对方的回答(ack包)，则会在 tcp_keepalive_intvl后再次尝试发送侦测包，直到收到对对方的ack,如果一直没有收到对方的ack,一共会尝试 tcp_keepalive_probes次，每次的间隔时间在这里分别是15s, 30s, 45s, 60s, 75s。如果尝试tcp_keepalive_probes,依然没有收到对方的ack包，则会丢弃该TCP连接。TCP连接默认闲置时间是2小时，一般设置为30分钟足够了。
总结一下，实际上tcp keep-alive是一个协议级别的心跳检测实现，当超过规定的时间，tcp就断开，而这边是讨论的http的keepalive，描述的http高层多次tcp链接共享，根本不是一个网络层级的东西，一定注意不要混淆。

1.4 springboot --> tomcat

spring-boot-autoconfigure : 2.3.12.RELEASE

-> org.springframework.boot.autoconfigure.web.embedded.EmbeddedWebServerFactoryCustomizerAutoConfiguration
    @ConditionalOnClass({Tomcat.class, UpgradeProtocol.class})
    public static class TomcatWebServerFactoryCustomizerConfiguration { [*]
        @Bean
        public TomcatWebServerFactoryCustomizer tomcatWebServerFactoryCustomizer(Environment environment, ServerProperties serverProperties){
            return new TomcatWebServerFactoryCustomizer(environment, serverProperties);
        }
    }
    
-> org.springframework.boot.autoconfigure.web.embedded.TomcatWebServerFactoryCustomizer
    + 关系: public class TomcatWebServerFactoryCustomizer implements WebServerFactoryCustomizer<ConfigurableTomcatWebServerFactory>, Ordered { /** ... **/ }
    + 属性:
        private final Environment environment;
        private final org.springframework.boot.autoconfigure.web.ServerProperties serverProperties; [*]
    + 方法:
        public void customize(ConfigurableTomcatWebServerFactory factory) { 
            ServerProperties properties = this.serverProperties;
            ServerProperties.Tomcat tomcatProperties = properties.getTomcat();
                --> Tomcat { // 内部类
                    private final Threads threads = new Threads();
                    ...
                    private int maxConnections;
                    private int acceptCount;
                    ...
                    private Duration connectionTimeout;
                    ...
                    private Charset uriEncoding;
                    --> Threads { // 内部类
                        private int max = 200;
                        private int minSpare = 10;
                    }
                }
            PropertyMapper propertyMapper = PropertyMapper.get();
            
            ServerProperties.Tomcat.Threads threadProperties = tomcatProperties.getThreads();
            ...
            propertyMapper.from(threadProperties::getMax).when(this::isPositive).to((maxThreads) -> {
                this.customizeMaxThreads(factory, threadProperties.getMax());
            });
            ...
            propertyMapper.from(threadProperties::getMinSpare).when(this::isPositive).to((minSpareThreads) -> {
                this.customizeMinThreads(factory, minSpareThreads);
            });
            ...
            propertyMapper.from(tomcatProperties::getMaxHttpFormPostSize).asInt(DataSize::toBytes).when((maxHttpFormPostSize) -> {
                return maxHttpFormPostSize != 0;
            }).to((maxHttpFormPostSize) -> {
                this.customizeMaxHttpFormPostSize(factory, maxHttpFormPostSize);
            });
            ...
            propertyMapper.from(tomcatProperties::getAccesslog).when(ServerProperties.Tomcat.Accesslog::isEnabled).to((enabled) -> {
                this.customizeAccessLog(factory);
            });
            ...
            propertyMapper.from(tomcatProperties::getUriEncoding).whenNonNull().to(factory::setUriEncoding);
            ...
            propertyMapper.from(tomcatProperties::getConnectionTimeout).whenNonNull().to((connectionTimeout) -> {
                this.customizeConnectionTimeout(factory, connectionTimeout);
            });
            ...
            propertyMapper.from(tomcatProperties::getMaxConnections).when(this::isPositive).to((maxConnections) -> {
                this.customizeMaxConnections(factory, maxConnections);
            });
            ...
            propertyMapper.from(tomcatProperties::getAcceptCount).when(this::isPositive).to((acceptCount) -> {
                this.customizeAcceptCount(factory, acceptCount);
            });
        }
        
        private void customizeAcceptCount(ConfigurableTomcatWebServerFactory factory, int acceptCount) {
            factory.addConnectorCustomizers(new TomcatConnectorCustomizer[]{(connector) -> {
                ProtocolHandler handler = connector.getProtocolHandler();
                if (handler instanceof AbstractProtocol) {
                    AbstractProtocol<?> protocol = (AbstractProtocol)handler;
                    protocol.setAcceptCount(acceptCount);
                }
    
            }});
        }
        ...
        private void customizeMaxConnections(ConfigurableTomcatWebServerFactory factory, int maxConnections) {
            factory.addConnectorCustomizers(new TomcatConnectorCustomizer[]{(connector) -> {
                ProtocolHandler handler = connector.getProtocolHandler();
                if (handler instanceof AbstractProtocol) {
                    AbstractProtocol<?> protocol = (AbstractProtocol)handler;
                    protocol.setMaxConnections(maxConnections);
                }
    
            }});
        }
        ...

X 参考文献

• 使用Tomcat设置Session - CSDN