除了修改参数，Spring Boot内嵌Tomcat还有哪些常见的运行时动态调整需求

核心调整维度

一、连接 / 线程池精细化管控（高频）

1. 动态调整线程池核心参数（进阶）

• 需求：高峰期临时调高核心线程数、空闲线程销毁时间，低峰期调低以节省资源；
• 实现：基于前文的参数修改逻辑，扩展更多线程池参数：
  java

  运行

  // 动态调整核心常驻线程数
  if (paramMap.containsKey("minSpareThreads")) {
      int min = Integer.parseInt(paramMap.get("minSpareThreads").toString());
      if (min > protocol.getMaxThreads()) {
          throw new IllegalArgumentException("minSpareThreads 不能大于 maxThreads");
      }
      protocol.setMinSpareThreads(min);
  }
  // 动态调整空闲线程销毁时间（ms）
  if (paramMap.containsKey("maxIdleTime")) {
      protocol.setMaxIdleTime(Integer.parseInt(paramMap.get("maxIdleTime").toString()));
  }
  

2. 动态限制最大连接数（防过载）

• 需求：防止突发流量打满服务器，动态调整 maxConnections（NIO 模式默认 10000），超出后拒绝新连接；
• 实现：
  java

  运行

  if (paramMap.containsKey("maxConnections")) {
      int maxConn = Integer.parseInt(paramMap.get("maxConnections").toString());
      protocol.setMaxConnections(maxConn); // 修改后立即生效
  }
  

3. 动态关闭 / 开启长连接（应急）

• 需求：长连接过多导致连接池耗尽时，临时关闭长连接，强制短连接；
• 实现：修改 maxKeepAliveRequests 为 1（禁用长连接）：
  java

  运行

  // 关闭长连接：单个连接仅处理1个请求后断开
  protocol.setMaxKeepAliveRequests(1);
  // 恢复长连接：设置为默认值100
  protocol.setMaxKeepAliveRequests(100);
  

二、请求过滤 / 限流（生产必备）

1. 动态添加 / 移除请求拦截器

• 需求：应急时拦截特定路径 / IP 的请求（如封禁恶意 IP、临时下线接口）；
• 实现：通过 Spring 的 HandlerInterceptor 结合动态配置（如内存缓存 / 配置中心）：
  java

  运行

  // 1. 定义动态拦截器
  @Component
  public class DynamicRequestInterceptor implements HandlerInterceptor {
      // 动态维护封禁IP列表（可从配置中心/接口更新）
      private volatile Set<String> blockedIps = new HashSet<>();
  
      @Override
      public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
          String ip = request.getRemoteAddr();
          if (blockedIps.contains(ip)) {
              response.setStatus(403);
              return false;
          }
          return true;
      }
  
      // 提供接口更新封禁IP
      public void updateBlockedIps(Set<String> newIps) {
          this.blockedIps = newIps;
      }
  }
  
  // 2. 注册拦截器（Spring Boot 启动时）
  @Configuration
  public class WebConfig implements WebMvcConfigurer {
      @Autowired
      private DynamicRequestInterceptor interceptor;
  
      @Override
      public void addInterceptors(InterceptorRegistry registry) {
          registry.addInterceptor(interceptor).addPathPatterns("/**");
      }
  }
  
  // 3. 提供接口动态更新封禁IP
  @PostMapping("/tomcat/updateBlockedIps")
  public void updateBlockedIps(@RequestBody Set<String> ips) {
      interceptor.updateBlockedIps(ips);
  }
  

2. 动态限流（基于 QPS / 接口）

• 需求：对特定接口设置 QPS 上限，超出后返回限流提示；
• 实现：结合 RateLimiter（Guava）+ 动态配置：
  java

  运行

  @Component
  public class DynamicRateLimitInterceptor implements HandlerInterceptor {
      // 动态维护接口限流规则：key=接口路径，value=RateLimiter
      private volatile Map<String, RateLimiter> rateLimitMap = new HashMap<>();
  
      @Override
      public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
          String path = request.getRequestURI();
          if (rateLimitMap.containsKey(path) && !rateLimitMap.get(path).tryAcquire()) {
              response.setStatus(429);
              response.getWriter().write("请求过于频繁，请稍后重试");
              return false;
          }
          return true;
      }
  
      // 动态更新限流规则（如 /api/test 限流 100 QPS）
      public void updateRateLimit(String path, double qps) {
          rateLimitMap.put(path, RateLimiter.create(qps));
      }
  }
  

三、日志 / 监控动态调整（运维刚需）

1. 动态调整 Tomcat 日志级别

• 需求：排查问题时临时调高 Tomcat 日志级别（如 DEBUG），排查完成后调回 INFO；
• 实现：通过 LoggingSystem 动态修改日志级别：
  java

  运行

  @Autowired
  private LoggingSystem loggingSystem;
  
  @PostMapping("/tomcat/updateLogLevel")
  public void updateLogLevel(@RequestParam String level) {
      // 调整 Tomcat 核心包日志级别
      loggingSystem.setLogLevel("org.apache.tomcat", LogLevel.valueOf(level.toUpperCase()));
      // 调整 Tomcat 线程池日志级别
      loggingSystem.setLogLevel("org.apache.tomcat.util.threads", LogLevel.valueOf(level.toUpperCase()));
  }
  

2. 动态开启 / 关闭请求日志

• 需求：临时开启 Tomcat 访问日志（记录所有请求的 URL/IP/ 响应时间），排查问题后关闭；
• 实现：通过 Tomcat 的 AccessLogValve 动态配置：
  java

  运行

  @PostMapping("/tomcat/toggleAccessLog")
  public void toggleAccessLog(@RequestParam boolean enable) {
      TomcatWebServer tomcatWebServer = (TomcatWebServer) applicationContext.getWebServer();
      // 获取 Tomcat 的 Engine 实例
      Engine engine = (Engine) tomcatWebServer.getTomcat().getService().getContainer();
      for (Container host : engine.findChildren()) {
          for (Container context : host.findChildren()) {
              // 获取 AccessLogValve（Tomcat 访问日志阀门）
              AccessLogValve accessLogValve = (AccessLogValve) context.findValve("AccessLogValve");
              if (accessLogValve != null) {
                  accessLogValve.setEnabled(enable); // 动态开启/关闭
              }
          }
      }
  }
  

四、故障应急调整（高优先级）

1. 动态暂停 / 恢复接收新请求

• 需求：服务出现异常（如数据库宕机）时，临时暂停接收新请求，恢复后重新开放；
• 实现：通过 Tomcat 的 Connector 动态启停：
  java

  运行

  @PostMapping("/tomcat/toggleConnector")
  public void toggleConnector(@RequestParam boolean enable) {
      TomcatWebServer tomcatWebServer = (TomcatWebServer) applicationContext.getWebServer();
      Connector connector = tomcatWebServer.getTomcat().getService().getConnectors()[0];
      if (enable) {
          connector.start(); // 恢复接收请求
      } else {
          connector.pause(); // 暂停接收新请求（已有请求继续处理）
          // 若需完全停止：connector.stop();
      }
  }
  

2. 动态调整超时时间（应急）

• 需求：下游服务响应慢时，临时调大 Tomcat 的请求读取超时时间，避免大量超时异常；
• 实现：
  java

  运行

  // 动态调整 Socket 读取超时时间（ms）
  protocol.setSoTimeout(Integer.parseInt(paramMap.get("soTimeout").toString()));
  // 动态调整异步请求超时时间
  request.setAttribute(RequestDispatcher.ASYNC_TIMEOUT, 30000L);
  

五、资源限制与性能优化（进阶）

1. 动态调整压缩策略

• 需求：高峰期关闭压缩（减少 CPU 消耗），低峰期开启压缩（减少带宽）；
• 实现：
  java

  运行

  @PostMapping("/tomcat/updateCompression")
  public void updateCompression(@RequestParam String mode) {
      Connector connector = tomcatWebServer.getTomcat().getService().getConnectors()[0];
      connector.setCompression(mode); // on/off/force
      // 动态调整压缩最小字节数
      connector.setCompressionMinSize(Integer.parseInt(paramMap.get("compressionMinSize").toString()));
  }
  

2. 动态调整 SSL 配置（HTTPS 场景）

• 需求：SSL 证书过期前，动态更新证书（无需重启应用）；
• 实现：通过 Tomcat 的 SSLHostConfig 动态更新证书：
  java

  运行

  @PostMapping("/tomcat/updateSslConfig")
  public void updateSslConfig(@RequestBody Map<String, String> sslParams) {
      Connector connector = tomcatWebServer.getTomcat().getService().getConnectors()[0];
      SSLHostConfig sslHostConfig = connector.findSslHostConfigs()[0];
      // 动态更新证书路径
      sslHostConfig.setCertificateFile(sslParams.get("certPath"));
      sslHostConfig.setCertificateKeyFile(sslParams.get("keyPath"));
      // 重新加载 SSL 配置
      connector.reloadSslHostConfigs();
  }
  

六、扩展：动态添加自定义 Valve（Tomcat 阀门）

• 需求：临时添加自定义逻辑（如请求耗时统计、参数校验），无需重启应用；
• 实现：Tomcat 的 Valve 类似过滤器，可动态添加：
  java

  运行

  // 1. 定义自定义 Valve
  public class CustomTimeValve extends ValveBase {
      @Override
      public void invoke(Request request, Response response) throws IOException, ServletException {
          long start = System.currentTimeMillis();
          getNext().invoke(request, response);
          long cost = System.currentTimeMillis() - start;
          System.out.println("请求 " + request.getRequestURI() + " 耗时：" + cost + "ms");
      }
  }
  
  // 2. 动态添加 Valve
  @PostMapping("/tomcat/addCustomValve")
  public void addCustomValve() {
      TomcatWebServer tomcatWebServer = (TomcatWebServer) applicationContext.getWebServer();
      Context context = (Context) tomcatWebServer.getTomcat().getHost().findChildren()[0];
      context.getPipeline().addValve(new CustomTimeValve()); // 动态添加
  }
  

总结（核心调整需求清单）