spring aop maven Spring AOP + Maven 项目如何配置虚拟线程，解决高并发线程耗尽

3.3 第2步：开启虚拟线程（核心配置）

Boot 3.x开启虚拟线程有两种方式，按需选择，推荐方式1（全局生效，无侵入）：

方式1：配置文件开启（推荐，全局生效）

在.yml中添加1行配置，即可将的所有任务执行器（包括Web服务器线程池）替换为虚拟线程，无需修改任何代码：

spring:
  # 核心配置：开启虚拟线程，全局生效
  threads:
    virtual:
      enabled: true
  # 数据库配置（示例，可根据业务调整）
  datasource:
    url: jdbc:mysql://localhost:3306/virtual_thread?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=UTC
    username: root
    password: 123456
    driver-class-name: com.mysql.cj.jdbc.Driver
  jpa:
    hibernate:
      ddl-auto: update
    show-sql: true
# 日志配置：打印线程信息，方便验证虚拟线程是否生效
logging:
  level:
    com.example.springbootvirtualthread: debug
    org.springframework.web: info

方式2：手动配置线程池（灵活控制，针对性生效）

如果不想全局开启虚拟线程，可手动配置虚拟线程池，仅对特定业务（如异步任务、接口调用）生效，代码如下：

package com.example.springbootvirtualthread.config;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import java.util.concurrent.Executor;
@Configuration
@EnableAsync // 开启异步支持
public class VirtualThreadConfig {
    /**
     * 配置虚拟线程池
     */
    @Bean(name = "virtualThreadPool")
    public Executor virtualThreadPool() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        // 核心：设置线程工厂为虚拟线程工厂
        executor.setThreadFactory(Thread.ofVirtual().factory());
        // 无需设置核心线程数、最大线程数（虚拟线程可无限扩展）
        executor.setCorePoolSize(0); // 虚拟线程池核心线程数设为0即可
        executor.setMaxPoolSize(Integer.MAX_VALUE); // 最大线程数无限制
        executor.setQueueCapacity(Integer.MAX_VALUE); // 队列容量无限制
        executor.setThreadNamePrefix("virtual-thread-"); // 线程名前缀，方便排查
        return executor;
    }
}

使用方式：在需要使用虚拟线程的方法上添加@Async注解，指定线程池：

// 在业务方法上添加注解，使用虚拟线程池
@Async("virtualThreadPool")
public void doAsyncTask() {
    // 业务逻辑（如数据库查询、HTTP调用）
    log.info("当前线程：{}，是否为虚拟线程：{}", 
             Thread.currentThread().getName(),
             Thread.currentThread().isVirtual());
}

3.4 第3步：编写测试接口（验证虚拟线程）

编写一个模拟IO阻塞的接口（模拟数据库查询、HTTP调用），验证虚拟线程是否生效，同时对比传统线程和虚拟线程的性能差异：

3.4.1 控制层（）

package com.example.springbootvirtualthread.controller;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.concurrent.TimeUnit;
@RestController
@RequestMapping("/api/test")
@Slf4j
public class TestController {
    /**
     * 模拟IO密集型接口（模拟数据库查询，阻塞50ms）
     */
    @GetMapping("/io-task")
    public String ioTask() throws InterruptedException {
        // 模拟IO阻塞（如数据库查询、Redis调用）
        TimeUnit.MILLISECONDS.sleep(50);
        
        // 打印当前线程信息，验证是否为虚拟线程
        Thread currentThread = Thread.currentThread();
        log.debug("当前线程名：{}，是否为虚拟线程：{}，线程ID：{}",
                 currentThread.getName(),
                 currentThread.isVirtual(),
                 currentThread.getId());
        
        return "IO任务执行完成，线程信息：" + currentThread.getName();
    }
    /**
     * 模拟CPU密集型接口（大量计算）
     */
    @GetMapping("/cpu-task")
    public String cpuTask() {
        // 模拟CPU密集型操作（循环计算）
        long sum = 0;
        for (long i = 0; i < 100000000; i++) {
            sum += i;
        }
        
        Thread currentThread = Thread.currentThread();
        log.debug("CPU任务执行完成，当前线程：{}，是否为虚拟线程：{}",
                 currentThread.getName(),
                 currentThread.isVirtual());
        
        return "CPU任务执行完成，计算结果：" + sum;
    }
}

3.4.2 启动类（无需额外配置）

package com.example.springbootvirtualthread;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class SpringBootVirtualThreadApplication {
    public static void main(String[] args) {
        SpringApplication.run(SpringBootVirtualThreadApplication.class, args);
        log.info("Spring Boot 3.x虚拟线程应用启动成功！");
    }
}

3.5 测试验证：虚拟线程是否生效？

启动应用后，通过浏览器或调用接口，观察日志输出，即可验证虚拟线程是否生效：

3.5.1 基础验证（接口调用）

调用接口：

:8080/api/test/io-task，观察日志输出：

当前线程名：virtual-thread-1，是否为虚拟线程：true，线程ID：25
当前线程名：virtual-thread-2，是否为虚拟线程：true，线程ID：26

日志中“是否为虚拟线程：true”，说明虚拟线程已成功生效，且线程名前缀为-（自动生成）。

3.5.2 高并发压测（性能对比）

用进行高并发压测，对比“开启虚拟线程”和“未开启虚拟线程”的性能差异，压测场景：IO密集型接口（阻塞50ms），压测10000并发，持续60秒。

压测结果对比（关键指标）

结论：开启虚拟线程后，QPS提升9倍，平均响应时间下降89%，CPU占用率下降68%，超时率为0，彻底解决高并发线程耗尽问题！

虚拟线程实战避坑指南

虽然虚拟线程用法简单，但在生产环境中，还有几个关键细节需要注意，否则可能出现性能瓶颈或异常，这4个避坑点一定要记牢：

4.1 避坑点1：不要混用虚拟线程和传统线程池

如果全局开启了虚拟线程，就不要手动创建传统线程池（如），否则会导致虚拟线程被阻塞，无法发挥其优势。

错误示例：在虚拟线程接口中，手动创建传统线程池执行任务，会导致虚拟线程等待传统线程，线程利用率大幅下降。

4.2 避坑点2：IO密集型场景才用虚拟线程

如前所述，虚拟线程在CPU密集型场景中性能提升不明显，甚至可能因为JVM调度开销，导致性能下降。

建议：CPU密集型任务（如复杂计算），使用传统线程池，核心线程数设置为CPU核心数（如8核CPU设置为8）；IO密集型任务，使用虚拟线程。

4.3 避坑点3：控制虚拟线程数量，避免内存溢出

虽然虚拟线程轻量，但也不是无限创建，当虚拟线程数量达到百万级以上时，依然会占用大量内存，导致OOM。

解决方案：通过限流（如）控制并发请求数，避免虚拟线程数量无限增长；同时监控JVM内存，根据实际情况调整。

4.4 避坑点4：生产环境JDK版本选择

推荐使用JDK 21（正式版，稳定无bug），避免使用JDK 19/20（预览版，存在部分兼容性问题）；如果必须使用JDK 17，需确保版本在17.0.8以上，修复了虚拟线程的部分bug。

4.5 进阶优化：虚拟线程监控

生产环境中，需要监控虚拟线程的数量、状态、执行时间，方便排查问题，可通过 Boot 集成监控：

配置.yml，开启线程监控端点：

management:
  endpoints:
    web:
      exposure:
        include: threads,health,info # 开启线程监控端点
  endpoint:
    threads:
      enabled: true # 开启线程监控