# Java 专家 **虚拟线程（Project Loom）** * 轻量级线程可显着提高 I/O 密集型应用程序的可扩展性 * 使用 `Executors.newVirtualThreadPerTaskExecutor()` 作为线程池 * 非常适合具有许多并发连接的 Web 应用程序 * Spring Boot 3.2+ 通过配置支持虚拟线程 // 在 Spring Boot 3.2+ 中启用虚拟线程 // 应用程序. 属性 spring.threads.virtual.enabled=true // 或者以编程方式 @豆子公共 TomcatProtocolHandlerCustomizer protocolHandlerVirtualThreadExecutorCustomizer() { 返回协议处理程序 -> { protocolHandler.setExecutor(Executors.newVirtualThreadPerTaskExecutor()); }; } // 直接使用虚拟线程尝试 (var executor = Executors.newVirtualThreadPerTaskExecutor()) { 执行者.提交(() -> { // I/O 密集型任务线程睡眠（1000）；返回“结果”； }); } **模式匹配** * switch 的模式匹配 (Java 21) * 记录模式 * 通过模式匹配进行解构 // switch 的模式匹配字符串结果 = switch (obj) { case 字符串 s -> "字符串：" + s; case 整数 i -> "整数：" + i; case Long l -> "长：" + l; 案例为空->“空”；默认->“未知”； }; // 记录模式记录点(int x, int y) {} if (obj instanceof Point(int x, int y)) { System.out.println("x: " + x + ", y: " + y); } **记录** * 不可变的数据载体 * 自动生成构造函数、getters、equals()、hashCode()、toString() 公共记录 UserDTO(String name, String email, LocalDatebirthDate) { // 用于验证的紧凑构造函数公共用户DTO { if (name == null || name.isBlank()) { throw new IllegalArgumentException("名称不能为空"); } } } **密封课程** * 限制哪些类可以扩展/实现 * 提供详尽的模式匹配公共密封接口 Result 允许成功、失败 { 记录 Success(T 值) 实现 Result {} 记录 Failure（字符串错误）实现 Result {} } ### Spring Boot 3.x 最佳实践 (2026) **框架设置：** * **Java 21+** 作为基线（虚拟线程、模式匹配） * **Spring Boot 3.2+**（最新稳定版） * **Spring 框架 6.x** * **Jakarta EE**（不是 javax.*）- 命名空间更改 **项目结构（分层架构）：** src/main/java/com/example/app/ ├── 控制器/ # REST 端点 (RestController) ├── service/ # 业务逻辑（Service） │ └── impl/ # 服务实现 ├──repository/ # 数据访问（Repository） ├── 型号/ │ ├── 实体/ # JPA 实体 │ └── dto/ # 数据传输对象 ├── config/ # 配置类 ├── exception/ # 自定义异常和处理程序 └── util/ # 实用工具类 **控制器层（RestController）：** * 仅处理 HTTP 请求/响应 * 将业务逻辑委托给服务 * 将 DTO 用于请求/响应主体 * 切勿直接注入存储库 @RestController @RequestMapping("/api/users") @RequiredArgsConstructor 公共类用户控制器{ 私有最终 UserService userService； @GetMapping("/{id}") 公共 ResponseEntity getUser(@PathVariable Long id) { UserDTO 用户 = userService.findById(id); 返回 ResponseEntity.ok(用户); } @PostMapping 公共 ResponseEntity createUser(@Valid @RequestBody CreateUserDTO dto) { 创建的 UserDTO = userService.create(dto); 返回 ResponseEntity.status(HttpStatus.CREATED).body(已创建); } } **服务层：** * 包含业务逻辑 * 使用存储库进行数据访问 * 实体和DTO之间的转换 * 用`@Service`注释 @服务 @RequiredArgsConstructor @Transactional(只读 = true) 公共类 UserServiceImpl 实现 UserService { 私有最终 UserRepository userRepository; 私有最终 ModelMapper modelMapper； @覆盖公共 UserDTO findById(长 id) { 用户 user = userRepository.findById(id) .orElseThrow(() -> new UserNotFoundException(id)); 返回 modelMapper.map(用户, UserDTO.class); } @覆盖 @事务性公共 UserDTO 创建（CreateUserDTO dto）{ 用户 user = modelMapper.map(dto, User.class); 用户已保存 = userRepository.save(user); 返回 modelMapper.map(已保存, UserDTO.class); } } **存储库层（Spring Data JPA）：** * 扩展 `JpaRepository` * 定义自定义查询方法 * 使用`@Query`进行复杂查询 @存储库公共接口 UserRepository 扩展 JpaRepository { 可选<用户> findByEmail(字符串电子邮件); @Query("从用户 u WHERE u.createdAt > :date 中选择 u") List findRecentUsers(@Param("date") LocalDateTime date); // 性能预测 @Query("从用户 u 中选择新的 com.example.dto.UserSummaryDTO(u.id, u.name, u.email)") List findAllSummaries(); } ### JPA/Hibernate 最佳实践 **实体设计：** * 使用`@Entity`和`@Table`注解 * 始终使用生成策略定义`@Id` * 使用`@Column`进行约束和映射 * 根据业务key实现`equals()`和`hashCode()` @实体 @Table(名称=“用户”) @Getter @Setter @NoArgs构造函数公共类用户{ @Id @GenerateValue(策略 = GenerationType.IDENTITY) 私人长ID； @Column(nullable = false, unique = true) 私人字符串电子邮件； @Column(可为空 = false) 私有字符串名称； @OneToMany（mappedBy =“用户”，级联= CascadeType.ALL，orphanRemoval = true） private List orders = new ArrayList<>(); @创建日期 @Column（可为空= false，可更新= false）私有 LocalDateTime 创建于； @最后修改日期私有 LocalDateTime 更新时间； } **性能优化：** * 使用`@EntityGraph`或`JOIN FETCH`来防止N+1查询 * 默认情况下延迟加载关联 * 对大型结果集使用分页 * 在数据库中定义适当的索引 @Query("从用户 u 中选择 u JOIN FETCH u.orders WHERE u.id = :id") 可选 findByIdWithOrders(@Param("id") Long id); // 分页 Page<用户> findAll(可分页可分页); ### 测试（JUnit 5 + Mockito） **单元测试服务：** @ExtendWith(MockitoExtension.class) 类 UserServiceImplTest { @模拟私有 UserRepository 用户存储库； @模拟私有模型映射器模型映射器； @InjectMocks 私有 UserServiceImpl 用户服务； @测试无效findById_WhenUserExists_ReturnsUserDTO（）{ // 给定长用户ID=1L；用户用户=新用户(); user.setId(userId); UserDTO 预期DTO = new UserDTO(); when(userRepository.findById(userId)).thenReturn(Optional.of(user)); when(modelMapper.map(user, UserDTO.class)).thenReturn(expectedDTO); // 当 UserDTO 结果 = userService.findById(userId); // 然后断言NotNull（结果）；验证(userRepository).findById(userId); 验证（modelMapper）.map（用户，UserDTO.class）； } } **集成测试（Spring Boot测试）：** @SpringBootTest @AutoConfigureMockMvc @事务性类 UserControllerIntegrationTest { @Autowired 私人 MockMvc 模拟Mvc； @Autowired 私有 ObjectMapper 对象映射器； @测试 void createUser_WithValidData_ReturnsCreated() 抛出异常 { CreateUserDTO dto = new CreateUserDTO("John Doe", "john@example.com"); mockMvc.perform(post("/api/users") .contentType(MediaType.APPLICATION_JSON) .content(objectMapper.writeValueAsString(dto))) .andExpect(status().isCreated()) .andExpect(jsonPath("$.name").value("John Doe")); } } ### 构建工具（Maven 和 Gradle） **Maven（pom.xml）：** <属性> 21

3.2.0

<依赖关系> <依赖关系> org.springframework.boot spring-boot-starter-web <依赖关系> org.springframework.boot spring-boot-starter-data-jpa <依赖关系> org.springframework.boot spring-boot-starter-validation **摇篮（build.gradle）：** 插件{ id 'java' id 'org.springframework.boot' 版本 '3.2.0' id 'io.spring.dependency-management' 版本 '1.1.4' } 爪哇{ 源兼容性 = JavaVersion.VERSION_21 } 依赖项{ 实现 'org.springframework.boot:spring-boot-starter-web' 实现 'org.springframework.boot:spring-boot-starter-data-jpa' 实现 'org.springframework.boot:spring-boot-starter-validation' 仅编译 'org.projectlombok:lombok' 注释处理器'org.projectlombok:lombok' testImplementation 'org.springframework.boot:spring-boot-starter-test' } ### 异常处理 **全局异常处理程序：** @RestControllerAdvice 公共类 GlobalExceptionHandler { @ExceptionHandler(UserNotFoundException.class) 公共 ResponseEntity handleUserNotFound(UserNotFoundException ex) { 错误响应错误=新的错误响应（ “USER_NOT_FOUND”，例如.getMessage(), LocalDateTime.now() ）；返回 ResponseEntity.status(HttpStatus.NOT_FOUND).body(错误); } @ExceptionHandler(MethodArgumentNotValidException.class) 公共 ResponseEntity handleValidation(MethodArgumentNotValidException ex) { Map 错误 = ex.getBindingResult() .getFieldErrors() .stream() .collect(Collectors.toMap( 字段错误::getField, 字段错误::getDefaultMessage ））；错误响应错误=新的错误响应（ “VALIDATION_ERROR”， “输入无效”，错误， LocalDateTime.now() ）；返回 ResponseEntity.status(HttpStatus.BAD_REQUEST).body(错误); } } ### 日志记录和监控 **日志记录（SLF4J + Logback）：** @Slf4j @服务公共类 UserServiceImpl 实现 UserService { 公共 UserDTO findById(长 id) { log.debug("查找id为{}的用户", id); 尝试{ 用户 user = userRepository.findById(id) .orElseThrow(() -> new UserNotFoundException(id)); log.info("找到用户：{}", user.getEmail()); 返回 modelMapper.map(用户, UserDTO.class); } catch (UserNotFoundException ex) { log.error("未找到 ID 为 {} 的用户", id, ex); 扔前； } } } **监控执行器：** 管理：端点：网址：曝光：包括：健康、信息、指标、普罗米修斯端点：健康状况：显示详细信息：始终 ## 铁律 1. **始终**使用构造函数注入，而不是使用“@Autowired”进行字段注入 - 字段注入会隐藏依赖项，使测试变得更加困难，并创建部分初始化的对象，如果上下文未完全加载，这些对象会在运行时崩溃。 2. **永远不要**在没有前面的 `isPresent()` 检查或 `orElse()`/`orElseThrow()` 的情况下使用 `Optional.get()` — 无条件的 `get()` 对空可选值抛出 `NoSuchElementException`，默默地破坏了Optional的全部目的。 3. **始终** 显式处理“@Transactional”边界 - 从同一类中调用事务方法会绕过代理并在没有事务的情况下运行，从而导致静默数据不一致。 4. **永远不要**在没有配置`TaskExecutor`的情况下使用`@Async` - Spring默认的`@Async`执行器使用单线程池；并发异步调用排队并破坏并行性。 5. **始终**使用具有特定异常类型的“@ControllerAdvice”进行错误处理 - 全局捕获“Exception”隐藏根本原因；特定的异常处理程序会生成正确的 HTTP 状态代码和有意义的错误响应。 ## 反模式反模式|为什么失败 |正确的做法 ---|---|--- 使用“@Autowired”进行字段注入 |隐藏的依赖关系；没有 Spring 上下文无法测试；单元测试中为 null |构造函数注入；所有必需的依赖项都声明为最终字段 `Optional.get()` 不带检查 |运行时的“NoSuchElementException”；击败Optional的零安全合约|使用“orElseThrow()”、“orElse()”或“map()”/“flatMap()”链同类方法调用上的“@Transactional” | Spring代理绕过；方法在事务之外运行；数据完整性丢失|将事务方法移至单独的服务 bean；从外部注入和调用默认 `@Async` 线程池 |单线程池将所有任务排队；异步调用按顺序运行 |使用池大小、队列和拒绝策略配置“ThreadPoolTaskExecutor” 全局 `@ExceptionHandler(Exception.class)` |吞掉特定的异常；所有错误都返回相同的通用 500 响应 |将特定异常类型映射到 HTTP 状态代码；使用“@ResponseStatus”注释 ## 综合技能这项专家技能整合了 1 项个人技能： * java专家 ## 内存协议（强制） **开始之前：** 猫.克劳德/上下文/内存/learnings.md **完成后：** 记录发现的任何新模式或异常。 > 假设中断：您的上下文可能会重置。如果它不在记忆中，那么它就没有发生。

Java专家

包含技能