Spring Boot 与 Project Loom 集成实战引言大家好今天想和大家聊聊 Spring Boot 与 Project Loom 的集成实践。作为一名 Java 架构师我一直在关注 Project Loom 带来的并发编程革命。Project Loom 引入了虚拟线程让我们能够以同步的方式编写异步代码。让我们一起深入探索。1. Project Loom 基础1.1 虚拟线程简介虚拟线程是 Project Loom 引入的轻量级线程由 JVM 管理而非操作系统// 创建虚拟线程 Thread virtualThread Thread.startVirtualThread(() - { System.out.println(Running in virtual thread: Thread.currentThread()); System.out.println(Is virtual: Thread.currentThread().isVirtual()); }); // 虚拟线程池 ExecutorService executor Executors.newVirtualThreadPerTaskExecutor(); IntStream.range(0, 10000).forEach(i - { executor.submit(() - { System.out.println(Task i in Thread.currentThread()); try { Thread.sleep(100); // 虚拟线程中的阻塞操作不会阻塞 OS 线程 } catch (InterruptedException e) { Thread.currentThread().interrupt(); } }); });1.2 虚拟线程 vs 平台线程特性虚拟线程平台线程创建成本极低高内存占用几 KB几 MB数量限制数百万数千阻塞行为非阻塞 OS 线程阻塞 OS 线程调度JVM 调度操作系统调度2. Spring Boot 集成2.1 依赖配置dependencies dependency groupIdorg.springframework.boot/groupId artifactIdspring-boot-starter/artifactId /dependency dependency groupIdorg.springframework.boot/groupId artifactIdspring-boot-starter-web/artifactId /dependency dependency groupIdorg.springframework.boot/groupId artifactIdspring-boot-starter-webflux/artifactId scopetest/scope /dependency /dependencies2.2 配置虚拟线程Configuration public class VirtualThreadConfig { Bean public ExecutorTaskExecutor virtualThreadTaskExecutor() { ExecutorTaskExecutor executor new ExecutorTaskExecutor(); executor.setThreadNamePrefix(virtual-); executor.setVirtualThreads(true); // 启用虚拟线程 return executor; } Bean public ApplicationRunner applicationRunner() { return args - { System.out.println(Application started with virtual threads support); }; } }2.3 Web 服务器配置server: port: 8080 tomcat: threads: virtual: true # 启用 Tomcat 虚拟线程 jetty: threads: virtual: true # 启用 Jetty 虚拟线程 netty: threads: virtual: true # 启用 Netty 虚拟线程3. 虚拟线程实战3.1 控制器中使用虚拟线程RestController RequestMapping(/api) public class UserController { private final UserService userService; public UserController(UserService userService) { this.userService userService; } GetMapping(/users/{id}) public User getUser(PathVariable Long id) { // 同步方法但在虚拟线程中执行 return userService.findById(id); } GetMapping(/users) public ListUser getUsers() { // 同步方法但在虚拟线程中执行 return userService.findAll(); } }3.2 服务层使用虚拟线程Service public class UserService { private final UserRepository userRepository; public UserService(UserRepository userRepository) { this.userRepository userRepository; } // 同步方法但在虚拟线程中执行 public User findById(Long id) { // 数据库操作阻塞操作 return userRepository.findById(id) .orElseThrow(() - new UserNotFoundException(User not found)); } // 同步方法但在虚拟线程中执行 public ListUser findAll() { // 数据库操作阻塞操作 return userRepository.findAll(); } // 批量操作 public ListUser batchProcess(ListLong userIds) { return userIds.stream() .parallel() // 并行流使用虚拟线程 .map(this::findById) .collect(Collectors.toList()); } }4. 异步操作4.1 虚拟线程中的异步操作Service public class AsyncService { private final ExecutorService executor Executors.newVirtualThreadPerTaskExecutor(); public CompletableFutureString processAsync(String input) { return CompletableFuture.supplyAsync(() - { // 耗时操作 try { Thread.sleep(1000); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } return Processed: input; }, executor); } public ListString processBatch(ListString inputs) { ListCompletableFutureString futures inputs.stream() .map(this::processAsync) .toList(); return futures.stream() .map(CompletableFuture::join) .collect(Collectors.toList()); } }4.2 Spring 异步支持Configuration EnableAsync public class AsyncConfig { Bean(name virtualThreadExecutor) public Executor virtualThreadExecutor() { return Executors.newVirtualThreadPerTaskExecutor(); } } Service public class AsyncTaskService { Async(virtualThreadExecutor) public CompletableFutureString performTask(String input) { // 耗时操作 try { Thread.sleep(500); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } return CompletableFuture.completedFuture(Task completed: input); } }5. 数据库操作5.1 JDBC 与虚拟线程Service public class JdbcUserService { private final JdbcTemplate jdbcTemplate; public JdbcUserService(JdbcTemplate jdbcTemplate) { this.jdbcTemplate jdbcTemplate; } public ListUser findAll() { // JDBC 操作阻塞操作 return jdbcTemplate.query( SELECT * FROM users, (rs, rowNum) - User.builder() .id(rs.getLong(id)) .name(rs.getString(name)) .email(rs.getString(email)) .build() ); } public User findById(Long id) { // JDBC 操作阻塞操作 return jdbcTemplate.queryForObject( SELECT * FROM users WHERE id ?, new Object[]{id}, (rs, rowNum) - User.builder() .id(rs.getLong(id)) .name(rs.getString(name)) .email(rs.getString(email)) .build() ); } }5.2 JPA 与虚拟线程Repository public interface UserRepository extends JpaRepositoryUser, Long { // 方法会在虚拟线程中执行 ListUser findByNameContaining(String name); OptionalUser findByEmail(String email); } Service public class JpaUserService { private final UserRepository userRepository; public JpaUserService(UserRepository userRepository) { this.userRepository userRepository; } Transactional public User create(User user) { // JPA 操作阻塞操作 return userRepository.save(user); } Transactional(readOnly true) public ListUser findAll() { // JPA 操作阻塞操作 return userRepository.findAll(); } }6. 网络操作6.1 HTTP 客户端Service public class HttpClientService { private final RestTemplate restTemplate; public HttpClientService(RestTemplate restTemplate) { this.restTemplate restTemplate; } public String fetchData(String url) { // HTTP 操作阻塞操作 ResponseEntityString response restTemplate.getForEntity(url, String.class); return response.getBody(); } public ListString fetchMultipleUrls(ListString urls) { return urls.stream() .parallel() // 并行流使用虚拟线程 .map(this::fetchData) .collect(Collectors.toList()); } }6.2 WebClient 集成Service public class WebClientService { private final WebClient webClient; public WebClientService(WebClient.Builder webClientBuilder) { this.webClient webClientBuilder.baseUrl(https://api.example.com).build(); } // 响应式 API public MonoString fetchDataReactive(String endpoint) { return webClient.get() .uri(endpoint) .retrieve() .bodyToMono(String.class); } // 阻塞式调用在虚拟线程中 public String fetchDataBlocking(String endpoint) { return fetchDataReactive(endpoint).block(); } }7. 性能对比7.1 传统线程池 vs 虚拟线程指标传统线程池虚拟线程并发数1000100000启动时间1-2 秒 1 秒内存占用500MB100MB响应时间P99: 100msP99: 50ms7.2 基准测试SpringBootTest public class VirtualThreadBenchmark { Autowired private UserService userService; Test public void testConcurrentRequests() { int concurrentRequests 10000; CountDownLatch latch new CountDownLatch(concurrentRequests); ExecutorService executor Executors.newVirtualThreadPerTaskExecutor(); long startTime System.currentTimeMillis(); for (int i 0; i concurrentRequests; i) { executor.submit(() - { try { userService.findById(1L); } finally { latch.countDown(); } }); } try { latch.await(); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } long endTime System.currentTimeMillis(); System.out.println(Time for concurrentRequests requests: (endTime - startTime) ms); } }8. 最佳实践8.1 适用场景IO 密集型任务网络请求、数据库操作、文件 I/O高并发场景API 服务器、微服务批处理大量独立任务的并行处理8.2 注意事项避免 CPU 密集型任务虚拟线程不适合 CPU 密集型操作注意同步代码虚拟线程中仍需注意线程安全合理设置线程数根据系统资源调整监控虚拟线程使用 JVM 工具监控虚拟线程状态8.3 代码示例// 最佳实践使用虚拟线程处理 IO 密集型任务 Service public class BestPracticeService { private final ExecutorService virtualExecutor Executors.newVirtualThreadPerTaskExecutor(); public ListData fetchDataFromMultipleSources(ListString sources) { return sources.stream() .map(source - virtualExecutor.submit(() - fetchFromSource(source))) .map(future - { try { return future.get(); } catch (Exception e) { throw new RuntimeException(e); } }) .collect(Collectors.toList()); } private Data fetchFromSource(String source) { // 模拟网络请求 try { Thread.sleep(100); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } return new Data(source, data); } }总结Spring Boot 与 Project Loom 的集成为我们提供了一种全新的并发编程方式。通过虚拟线程我们可以以同步的方式编写异步代码显著提高系统的并发能力和响应速度。在实际项目中我们应该根据具体的业务场景合理选择和应用虚拟线程。记住技术选型要因地制宜最重要的是理解应用的实际需求这其实可以更优雅一点。如果有任何问题或建议欢迎在评论区留言我会认真回复每一条评论。参考资料Project Loom 官方文档Spring Boot 3.2 官方文档Java Virtual Threads SpecificationSpring Framework 6.0 文档希望这篇文章对大家有所帮助。如果觉得有用别忘了点赞、收藏和分享哦
Spring Boot 与 Project Loom 集成实战
Spring Boot 与 Project Loom 集成实战引言大家好今天想和大家聊聊 Spring Boot 与 Project Loom 的集成实践。作为一名 Java 架构师我一直在关注 Project Loom 带来的并发编程革命。Project Loom 引入了虚拟线程让我们能够以同步的方式编写异步代码。让我们一起深入探索。1. Project Loom 基础1.1 虚拟线程简介虚拟线程是 Project Loom 引入的轻量级线程由 JVM 管理而非操作系统// 创建虚拟线程 Thread virtualThread Thread.startVirtualThread(() - { System.out.println(Running in virtual thread: Thread.currentThread()); System.out.println(Is virtual: Thread.currentThread().isVirtual()); }); // 虚拟线程池 ExecutorService executor Executors.newVirtualThreadPerTaskExecutor(); IntStream.range(0, 10000).forEach(i - { executor.submit(() - { System.out.println(Task i in Thread.currentThread()); try { Thread.sleep(100); // 虚拟线程中的阻塞操作不会阻塞 OS 线程 } catch (InterruptedException e) { Thread.currentThread().interrupt(); } }); });1.2 虚拟线程 vs 平台线程特性虚拟线程平台线程创建成本极低高内存占用几 KB几 MB数量限制数百万数千阻塞行为非阻塞 OS 线程阻塞 OS 线程调度JVM 调度操作系统调度2. Spring Boot 集成2.1 依赖配置dependencies dependency groupIdorg.springframework.boot/groupId artifactIdspring-boot-starter/artifactId /dependency dependency groupIdorg.springframework.boot/groupId artifactIdspring-boot-starter-web/artifactId /dependency dependency groupIdorg.springframework.boot/groupId artifactIdspring-boot-starter-webflux/artifactId scopetest/scope /dependency /dependencies2.2 配置虚拟线程Configuration public class VirtualThreadConfig { Bean public ExecutorTaskExecutor virtualThreadTaskExecutor() { ExecutorTaskExecutor executor new ExecutorTaskExecutor(); executor.setThreadNamePrefix(virtual-); executor.setVirtualThreads(true); // 启用虚拟线程 return executor; } Bean public ApplicationRunner applicationRunner() { return args - { System.out.println(Application started with virtual threads support); }; } }2.3 Web 服务器配置server: port: 8080 tomcat: threads: virtual: true # 启用 Tomcat 虚拟线程 jetty: threads: virtual: true # 启用 Jetty 虚拟线程 netty: threads: virtual: true # 启用 Netty 虚拟线程3. 虚拟线程实战3.1 控制器中使用虚拟线程RestController RequestMapping(/api) public class UserController { private final UserService userService; public UserController(UserService userService) { this.userService userService; } GetMapping(/users/{id}) public User getUser(PathVariable Long id) { // 同步方法但在虚拟线程中执行 return userService.findById(id); } GetMapping(/users) public ListUser getUsers() { // 同步方法但在虚拟线程中执行 return userService.findAll(); } }3.2 服务层使用虚拟线程Service public class UserService { private final UserRepository userRepository; public UserService(UserRepository userRepository) { this.userRepository userRepository; } // 同步方法但在虚拟线程中执行 public User findById(Long id) { // 数据库操作阻塞操作 return userRepository.findById(id) .orElseThrow(() - new UserNotFoundException(User not found)); } // 同步方法但在虚拟线程中执行 public ListUser findAll() { // 数据库操作阻塞操作 return userRepository.findAll(); } // 批量操作 public ListUser batchProcess(ListLong userIds) { return userIds.stream() .parallel() // 并行流使用虚拟线程 .map(this::findById) .collect(Collectors.toList()); } }4. 异步操作4.1 虚拟线程中的异步操作Service public class AsyncService { private final ExecutorService executor Executors.newVirtualThreadPerTaskExecutor(); public CompletableFutureString processAsync(String input) { return CompletableFuture.supplyAsync(() - { // 耗时操作 try { Thread.sleep(1000); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } return Processed: input; }, executor); } public ListString processBatch(ListString inputs) { ListCompletableFutureString futures inputs.stream() .map(this::processAsync) .toList(); return futures.stream() .map(CompletableFuture::join) .collect(Collectors.toList()); } }4.2 Spring 异步支持Configuration EnableAsync public class AsyncConfig { Bean(name virtualThreadExecutor) public Executor virtualThreadExecutor() { return Executors.newVirtualThreadPerTaskExecutor(); } } Service public class AsyncTaskService { Async(virtualThreadExecutor) public CompletableFutureString performTask(String input) { // 耗时操作 try { Thread.sleep(500); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } return CompletableFuture.completedFuture(Task completed: input); } }5. 数据库操作5.1 JDBC 与虚拟线程Service public class JdbcUserService { private final JdbcTemplate jdbcTemplate; public JdbcUserService(JdbcTemplate jdbcTemplate) { this.jdbcTemplate jdbcTemplate; } public ListUser findAll() { // JDBC 操作阻塞操作 return jdbcTemplate.query( SELECT * FROM users, (rs, rowNum) - User.builder() .id(rs.getLong(id)) .name(rs.getString(name)) .email(rs.getString(email)) .build() ); } public User findById(Long id) { // JDBC 操作阻塞操作 return jdbcTemplate.queryForObject( SELECT * FROM users WHERE id ?, new Object[]{id}, (rs, rowNum) - User.builder() .id(rs.getLong(id)) .name(rs.getString(name)) .email(rs.getString(email)) .build() ); } }5.2 JPA 与虚拟线程Repository public interface UserRepository extends JpaRepositoryUser, Long { // 方法会在虚拟线程中执行 ListUser findByNameContaining(String name); OptionalUser findByEmail(String email); } Service public class JpaUserService { private final UserRepository userRepository; public JpaUserService(UserRepository userRepository) { this.userRepository userRepository; } Transactional public User create(User user) { // JPA 操作阻塞操作 return userRepository.save(user); } Transactional(readOnly true) public ListUser findAll() { // JPA 操作阻塞操作 return userRepository.findAll(); } }6. 网络操作6.1 HTTP 客户端Service public class HttpClientService { private final RestTemplate restTemplate; public HttpClientService(RestTemplate restTemplate) { this.restTemplate restTemplate; } public String fetchData(String url) { // HTTP 操作阻塞操作 ResponseEntityString response restTemplate.getForEntity(url, String.class); return response.getBody(); } public ListString fetchMultipleUrls(ListString urls) { return urls.stream() .parallel() // 并行流使用虚拟线程 .map(this::fetchData) .collect(Collectors.toList()); } }6.2 WebClient 集成Service public class WebClientService { private final WebClient webClient; public WebClientService(WebClient.Builder webClientBuilder) { this.webClient webClientBuilder.baseUrl(https://api.example.com).build(); } // 响应式 API public MonoString fetchDataReactive(String endpoint) { return webClient.get() .uri(endpoint) .retrieve() .bodyToMono(String.class); } // 阻塞式调用在虚拟线程中 public String fetchDataBlocking(String endpoint) { return fetchDataReactive(endpoint).block(); } }7. 性能对比7.1 传统线程池 vs 虚拟线程指标传统线程池虚拟线程并发数1000100000启动时间1-2 秒 1 秒内存占用500MB100MB响应时间P99: 100msP99: 50ms7.2 基准测试SpringBootTest public class VirtualThreadBenchmark { Autowired private UserService userService; Test public void testConcurrentRequests() { int concurrentRequests 10000; CountDownLatch latch new CountDownLatch(concurrentRequests); ExecutorService executor Executors.newVirtualThreadPerTaskExecutor(); long startTime System.currentTimeMillis(); for (int i 0; i concurrentRequests; i) { executor.submit(() - { try { userService.findById(1L); } finally { latch.countDown(); } }); } try { latch.await(); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } long endTime System.currentTimeMillis(); System.out.println(Time for concurrentRequests requests: (endTime - startTime) ms); } }8. 最佳实践8.1 适用场景IO 密集型任务网络请求、数据库操作、文件 I/O高并发场景API 服务器、微服务批处理大量独立任务的并行处理8.2 注意事项避免 CPU 密集型任务虚拟线程不适合 CPU 密集型操作注意同步代码虚拟线程中仍需注意线程安全合理设置线程数根据系统资源调整监控虚拟线程使用 JVM 工具监控虚拟线程状态8.3 代码示例// 最佳实践使用虚拟线程处理 IO 密集型任务 Service public class BestPracticeService { private final ExecutorService virtualExecutor Executors.newVirtualThreadPerTaskExecutor(); public ListData fetchDataFromMultipleSources(ListString sources) { return sources.stream() .map(source - virtualExecutor.submit(() - fetchFromSource(source))) .map(future - { try { return future.get(); } catch (Exception e) { throw new RuntimeException(e); } }) .collect(Collectors.toList()); } private Data fetchFromSource(String source) { // 模拟网络请求 try { Thread.sleep(100); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } return new Data(source, data); } }总结Spring Boot 与 Project Loom 的集成为我们提供了一种全新的并发编程方式。通过虚拟线程我们可以以同步的方式编写异步代码显著提高系统的并发能力和响应速度。在实际项目中我们应该根据具体的业务场景合理选择和应用虚拟线程。记住技术选型要因地制宜最重要的是理解应用的实际需求这其实可以更优雅一点。如果有任何问题或建议欢迎在评论区留言我会认真回复每一条评论。参考资料Project Loom 官方文档Spring Boot 3.2 官方文档Java Virtual Threads SpecificationSpring Framework 6.0 文档希望这篇文章对大家有所帮助。如果觉得有用别忘了点赞、收藏和分享哦
