在Spring Boot内嵌Tomcat场景下修改参数

import org.apache.catalina.connector.Connector;
import org.apache.coyote.http11.Http11NioProtocol;
import org.springframework.boot.web.embedded.tomcat.TomcatServletWebServerFactory;
import org.springframework.boot.web.servlet.server.ServletWebServerFactory;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * Spring Boot 启动时配置内嵌 Tomcat 参数
 */
@Configuration
public class TomcatStartupConfig {

    @Bean
    public ServletWebServerFactory tomcatServerFactory() {
        TomcatServletWebServerFactory factory = new TomcatServletWebServerFactory();
        
        // 自定义 Connector 配置（核心：所有参数通过此方法设置）
        factory.addConnectorCustomizers((Connector connector) -> {
            // 强转为 NIO 协议处理器（Tomcat 默认 NIO 模型）
            Http11NioProtocol protocol = (Http11NioProtocol) connector.getProtocolHandler();

            // ========== 1. 线程池参数 ==========
            protocol.setMaxThreads(1000);        // 最大工作线程数（默认 200）
            protocol.setMinSpareThreads(80);     // 核心常驻线程数（默认 10）
            protocol.setAcceptCount(800);        // 请求等待队列长度（默认 100）
            protocol.setThreadPriority(5);       // 线程优先级（1-10，默认 5）

            // ========== 2. 连接管理参数 ==========
            protocol.setMaxConnections(30000);   // 最大并发连接数（NIO 模式默认 10000）
            protocol.setConnectionTimeout(30000); // 连接超时（ms，默认 20000）
            protocol.setKeepAliveTimeout(20000); // 长连接空闲超时（ms，默认 60000）
            protocol.setMaxKeepAliveRequests(1000); // 单个长连接最大请求数（默认 100）

            // ========== 3. 基础/编码参数 ==========
            connector.setPort(8080);             // 监听端口（默认 8080）
            connector.setURIEncoding("UTF-8");   // URI 编码（默认 ISO-8859-1）
            connector.setEnableLookups(false);   // 关闭 IP 反向解析（提升性能）

            // ========== 4. 压缩参数（优化传输） ==========
            connector.setCompression("on");      // 开启 HTTP 压缩
            connector.setCompressionMinSize(2048); // 触发压缩的最小响应大小（字节）
            connector.setCompressibleMimeTypes("text/html,text/xml,text/css,application/json"); // 可压缩的 MIME 类型

            // ========== 5. 限流参数（安全防护） ==========
            protocol.setLimitRequestLine(8192);  // 请求行最大长度（URL 上限，默认 8192）
            protocol.setLimitRequestParams(2000); // 请求参数最大个数（默认 1000）
        });

        return factory;
    }
}

import org.apache.catalina.connector.Connector;
import org.apache.coyote.http11.Http11NioProtocol;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.web.embedded.tomcat.TomcatWebServer;
import org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;

import java.util.HashMap;
import java.util.Map;

/**
 * Spring Boot 运行时动态修改内嵌 Tomcat 参数
 */
@RestController
public class TomcatDynamicConfigController {

    @Autowired
    private ServletWebServerApplicationContext applicationContext;

    /**
     * 动态修改指定参数（按需传入，非空则修改）
     * @param paramMap 格式：{"maxThreads": 1200, "acceptCount": 1000}
     * @return 修改结果（包含修改后的值）
     */
    @PostMapping("/tomcat/updateParams")
    public Map<String, Object> updateTomcatParams(@RequestBody Map<String, Object> paramMap) {
        Map<String, Object> result = new HashMap<>();
        try {
            // 1. 获取 Tomcat 核心实例
            TomcatWebServer tomcatWebServer = (TomcatWebServer) applicationContext.getWebServer();
            org.apache.catalina.Service service = tomcatWebServer.getTomcat().getService();
            // 获取默认的 HTTP Connector（8080 端口）
            Connector connector = service.getConnectors()[0];
            Http11NioProtocol protocol = (Http11NioProtocol) connector.getProtocolHandler();

            // 2. 按需修改参数（参数合法性校验）
            Map<String, Object> updatedParams = new HashMap<>();
            // 最大工作线程数
            if (paramMap.containsKey("maxThreads")) {
                int maxThreads = Integer.parseInt(paramMap.get("maxThreads").toString());
                if (maxThreads < protocol.getMinSpareThreads()) {
                    throw new IllegalArgumentException("maxThreads 不能小于 minSpareThreads（当前：" + protocol.getMinSpareThreads() + "）");
                }
                protocol.setMaxThreads(maxThreads);
                updatedParams.put("maxThreads", protocol.getMaxThreads());
            }
            // 请求等待队列长度
            if (paramMap.containsKey("acceptCount")) {
                int acceptCount = Integer.parseInt(paramMap.get("acceptCount").toString());
                if (acceptCount < 0) throw new IllegalArgumentException("acceptCount 不能为负数");
                protocol.setAcceptCount(acceptCount);
                updatedParams.put("acceptCount", protocol.getAcceptCount());
            }
            // 连接超时
            if (paramMap.containsKey("connectionTimeout")) {
                int timeout = Integer.parseInt(paramMap.get("connectionTimeout").toString());
                protocol.setConnectionTimeout(timeout);
                updatedParams.put("connectionTimeout", protocol.getConnectionTimeout() + "ms");
            }
            // URI 编码（Connector 层级）
            if (paramMap.containsKey("URIEncoding")) {
                String encoding = paramMap.get("URIEncoding").toString();
                connector.setURIEncoding(encoding);
                updatedParams.put("URIEncoding", connector.getURIEncoding());
            }

            // 3. 返回结果
            result.put("status", "success");
            result.put("updatedParams", updatedParams);
            result.put("msg", "参数修改成功，立即生效（端口需重启应用）");

        } catch (IllegalArgumentException e) {
            result.put("status", "fail");
            result.put("error", "参数校验失败：" + e.getMessage());
        } catch (Exception e) {
            result.put("status", "fail");
            result.put("error", "修改失败：" + e.getMessage());
            e.printStackTrace();
        }
        return result;
    }
}

curl -X POST "http://localhost:8080/tomcat/updateParams" \
-H "Content-Type: application/json" \
-d '{
  "maxThreads": 1200,
  "acceptCount": 1000,
  "connectionTimeout": 30000
}'

{
  "status": "success",
  "updatedParams": {
    "maxThreads": 1200,
    "acceptCount": 1000,
    "connectionTimeout": "30000ms"
  },
  "msg": "参数修改成功，立即生效（端口需重启应用）"
}