Java 现代特性深度指南（Java 8-21）

Java 自 1996 年诞生以来，经历了从”缓慢演进”到”快速迭代”的范式转变。从 Java 8（2014）的 Lambda、Stream、Optional 三剑客开启现代 Java 纪元，到 Java 21（2023）的虚拟线程、模式匹配、记录类三大支柱完成”现代 Java”形态构建，这 9 年间的演进重新定义了 Java 作为一门语言的表达力、性能边界与工程哲学。本文将以版本为线索、以特性为单元、以原理为深度，系统性地剖析 Java 8 至 21 的关键演进，让读者既能掌握每个特性的”如何使用”，也能理解”为何如此设计”，最终建立对 Java 语言演进的系统认知。

1. 学习目标（基于 Bloom 分类法）

本节以 Bloom 教育目标分类法（Anderson 2001 修订版）为框架，对学习目标进行显式分级。

1.1 认知层级目标

1.2 学习成果自检清单

完成本章学习后，读者应能独立完成以下任务：

1. 在不查阅文档的前提下，列出 Java 8、11、17、21 四个 LTS 版本的核心特性清单。
2. 用一句话向同事解释 invokedynamic 与 Lambda 表达式的关系。
3. 在白板上画出 Record 类的字节码结构，指出自动生成的方法及其语义。
4. 设计一个基于密封类 + 模式匹配 switch 的支付方式领域模型，编译器保证穷举性。
5. 对比虚拟线程、CompletableFuture、Reactor 三种并发模型的优缺点，给出选型建议。
6. 重写一段遗留 Java 7 代码（5 层 if-else 嵌套 + StringBuilder 拼接）为现代 Java 21 风格。

1.3 前置知识地图

Java 基础
    │
    ├── 面向对象（封装、继承、多态）
    ├── 集合框架（List、Map、Set）
    ├── 异常处理（try-catch-finally）
    └── 泛型（类型参数、通配符）
            │
            ▼
Java 函数式编程（Java 8 基础）
    │
    ├── Lambda 表达式
    ├── Stream API
    ├── Optional
    └── 函数式接口
            │
            ▼
Java 现代特性（本章）
    │
    ├── 语法层：Record、密封类、模式匹配、文本块、switch 表达式
    ├── API 层：List.of、Map.of、String 新方法、HttpClient
    ├── 并发层：虚拟线程、结构化并发、作用域值
    └── JVM 层：invokedynamic、ALPN、AppCDS、ZGC、Generational Shenandoah

1.4 章节阅读建议

• 零基础读者：建议按顺序阅读第 2-5 节，配合第 5 节代码示例上机实操，再回到第 3、4 节深化理论。
• 有 Java 8 经验的工程师：可跳过第 2 节基础部分，直接阅读第 3 节 Record 与密封类、第 4 节模式匹配、第 7 节反模式。
• 架构师：重点关注第 6 节对比分析、第 8 节工程实践与第 9 节案例研究，特别是虚拟线程与 Spring Boot 3 的集成。

2. 历史动机与演化

2.1 Java 演进的范式转变

Java 的发展史可分为三个阶段：

阶段 1：缓慢演进期（1996-2014，JDK 1.0-8）

• 每 3-5 年发布一个版本，特性数量大但迭代慢。
• 重大里程碑：JDK 1.1（反射、内部类）、JDK 1.5（泛型、注解、枚举、自动装箱）、JDK 1.8（Lambda、Stream、Optional、Date Time API）。
• 痛点：语言演进慢，社区被 Scala、Kotlin 等新语言蚕食。

阶段 2：快速迭代期（2017-2021，JDK 9-17）

• 2017 年起改为 6 个月一次发布（3 月、9 月），不再等”大版本”。
• 每 3 年发布一个 LTS 版本（长期支持，11、17、21）。
• 非 LTS 版本（9、10、12、13、14、15、16）仅支持 6 个月，作为”试验田”。
• 重大里程碑：JDK 9（模块系统）、JDK 11（HttpClient、var 关键字）、JDK 17（密封类、Pattern Matching for instanceof）。

阶段 3：现代化完成期（2021-至今，JDK 17+）

• Java 21（2023 年 9 月）成为”现代 Java”的里程碑：虚拟线程正式、模式匹配正式、记录模式正式。
• 后续版本（22、23、24…）继续增量演进，但核心形态已稳定。
• GraalVM、Native Image 推动 Java 向”云原生”友好演进。

2.2 JEP 机制与特性孵化

Java 的每个新特性都通过 JEP（JDK Enhancement Proposal） 流程推进。JEP 的状态机：

Draft → Submitted → Candidate → Funded → Owner Selected
                                              │
                                              ▼
                                        Designing
                                              │
                                              ▼
                                        Implementing
                                              │
                                              ▼
                                  ┌─── Integrated ───┐
                                  │                  │
                                  ▼                  ▼
                            Preview          Completed
                                  │                  │
                                  ▼                  ▼
                            Experimental     Released
                                  │
                                  ▼
                              Closed

关键状态说明：

• Preview：预览特性，需 --enable-preview 启用，可能在后续版本变更或移除。
• Experimental：实验性特性，仅供研究，不保证稳定性。
• Released：正式特性，向后兼容保证。
• Closed：撤销或废弃。

JEP 分为几类：

• Language Features：语法特性（如 Record、密封类）。
• Library Features：API 特性（如 HttpClient、List.of）。
• JVM Features：JVM 改进（如 invokedynamic、ZGC）。
• Tooling Features：工具链改进（如 jshell、jpackage）。
• Infrastructure Features：构建与发布流程改进。

2.3 关键 LTS 版本时间线

2.4 设计哲学：Java 演进的保守与激进

Java 的演进遵循 “保守的语法、激进的库” 原则：

• 语法层保守：Java 不轻易引入新语法，每个新关键字（如 record、sealed、permits、yield）都经过 5-10 年的预览与讨论。这保证了代码的长期可维护性，但被批评为”慢半拍”。
• 库层激进：Java 大量通过 API 演进（而非语法）提供新能力。例如 Stream API、Optional、CompletableFuture 都是库层创新，不改变语法但改变编程范式。
• JVM 层激进：JVM 内部持续引入激进优化（invokedynamic、ZGC、AppCDS、Scalar Replacement），这些对应用层透明但显著提升性能。

这一哲学的核心是 “向后兼容” —— 一份 1996 年的 Java 1.0 代码在 Java 21 上仍应能编译运行。这是 Java 在企业级市场不可替代的根本原因。

2.5 与其他语言的对比

历史轶事：Java 8 的 Lambda 设计曾引发激烈争论。Brian Goetz（Java 语言架构师）最终选择”基于 invokedynamic 的 Lambda”而非”内部类语法糖”，这一决策使 Lambda 在字节码层与 Scala、Kotlin 的闭包实现兼容，为后续函数式编程生态奠定基础。

3. 形式化定义

3.1 Record 类的形式化定义

Record 类 $R$ 是一个不可变的透明数据载体，定义为：

其语义等价于以下自动生成的成员：

1. 私有 final 字段：$\forall i: \text{private final } T_i \ c_i;$
2. 规范构造器（Canonical Constructor）：$R(T_1 c_1, \ldots, T_n c_n)$，赋值所有字段。
3. 访问器方法（Accessor）：$\forall i: T_i \ c_i()$（注意：无 get 前缀）。
4. equals 方法：基于所有字段，满足 $\text{equals}(r_1, r_2) \iff \bigwedge_i c_i(r_1) = c_i(r_2)$。
5. hashCode 方法：基于所有字段，满足 $\text{hashCode}(r) = \text{hash}(c_1(r), \ldots, c_n(r))$。
6. toString 方法：返回 R[c1=v1, c2=v2, ..., cn=vn] 格式。

形式化地，Record 类的”透明性”意味着其内部表示（字段值）与外部接口（访问器）完全对应，无隐藏状态。

3.2 密封类的形式化定义

密封类 $S$ 显式声明其 permitted 子类集合 $P(S)$：

约束：

1. 封闭性：$\forall x: x \text{ extends } S \implies x \in P(S)$。
2. 传递性：每个 $s_i \in P(S)$ 必须是 final、sealed 或 non-sealed。
   • final：不可继承。
   • sealed：继续密封，需声明 permits。
   • non-sealed：开放继承，任意类可继承（破坏封闭性，慎用）。
3. 共置要求：$S$ 与 $P(S)$ 必须在同一模块（若在模块中）或同一包（若在未命名模块中）。

密封类使得 穷举性检查（exhaustiveness）成为可能：编译器可验证 switch 表达式是否覆盖所有 $P(S)$，无需 default 分支。

3.3 Pattern Matching 的形式化语义

Pattern Matching 是一种将”类型测试 + 类型转换 + 变量绑定”三步合一的机制。形式化地，模式 $p$ 与值 $v$ 的匹配 $\text{match}(p, v)$ 定义为：

其中 $\theta$ 是绑定环境（变量名到值的映射）。

类型模式（Type Pattern）T x：

记录模式（Record Pattern）R(p_1, p_2, ..., p_n)：

守卫模式（Guarded Pattern）p when e：

3.4 虚拟线程的形式化模型

虚拟线程是 JVM 调度的轻量级线程，其形式化模型：

• 载体线程（Carrier Thread）：操作系统级平台线程，由 ForkJoinPool（默认 Runtime.getRuntime().availableProcessors() 个）提供。
• 虚拟线程状态机：NEW → RUNNABLE → (parked | pinned) → TERMINATED。
  • NEW：已创建未启动。
  • RUNNABLE：在载体线程上执行。
  • parked：因 I/O 阻塞、LockSupport.park() 等让出载体线程。
  • pinned：因 synchronized、native 方法、JNI 调用无法卸载，占用载体线程。
  • TERMINATED：执行结束。

虚拟线程的调度是 M:N 调度（M 个虚拟线程映射到 N 个载体线程），与传统线程的 1:1 调度相对。其优势：

• 内存占用低：虚拟线程初始栈约 1KB（可增长），平台线程栈约 1MB，相差 1000 倍。
• 创建成本低：虚拟线程无需 OS 系统调用（clone），JVM 内部分配。
• 阻塞成本低：虚拟线程阻塞时不占用载体线程，载体线程可执行其他虚拟线程。

3.5 invokedynamic 与 Lambda 的关系

Lambda 表达式在字节码层通过 invokedynamic 指令实现。形式化地：

Function<String, Integer> f = s -> s.length();

编译后等价于：

1. 生成隐式方法 lambda$0(String): int，包含 Lambda 体
2. 在调用点生成 invokedynamic 指令，bootstrap 方法为 LambdaMetafactory.metafactory
3. 首次执行时，LambdaMetafactory 生成实现 Function 接口的类，链接到 lambda$0
4. 后续调用直接分派到生成的类

这一设计的优势：

• 实现策略可演化：JVM 可选择内部类、MethodHandle、或直接生成字节码，对源码透明。
• 性能优化空间：JIT 可内联 Lambda 体，避免接口调用开销。
• 生态兼容：Scala、Kotlin、Groovy 的闭包也用 invokedynamic，统一了 JVM 函数式编程的底层。

4. 理论推导：现代特性的内部机制

4.1 Record 类的字节码剖析

考虑以下 Record 定义：

public record Point(int x, int y) {}

使用 javap -p -c Point 查看字节码：

public final class Point extends java.lang.Record {
    private final int x;
    private final int y;

    public Point(int, int);          // 规范构造器
    public final boolean equals(java.lang.Object);
    public final int hashCode();
    public final java.lang.String toString();
    public int x();                  // 访问器
    public int y();
}

关键点：

1. extends java.lang.Record：所有 Record 类隐式继承 java.lang.Record，这是 Record 的”标记基类”。
2. final 类：Record 不可继承，保证不可变性。
3. 无 setter：所有字段 final，无 setter 方法。
4. 访问器名即字段名：x() 而非 getX()，这是 Record 与 JavaBeans 的本质差异。

Record 类在 Record 属性（JVMS §4.7.30）中记录其组件元数据，反射 API 通过 Class.getRecordComponents() 读取，使 Jackson、Gson 等库能识别 Record 的规范构造器进行反序列化。

4.2 密封类的字节码剖析

public sealed interface Shape permits Circle, Square, Triangle {}

字节码：

public abstract interface Shape
  PermittedSubclasses attribute:
    Circle
    Square
    Triangle

PermittedSubclasses 属性（JVMS §4.7.31）记录所有 permitted 子类。JVM 在类加载时验证：

• 若类 $C$ 声明为 sealed permits $P$，则 $P$ 中每个子类必须存在且为 $C$ 的子类。
• 若类 $D$ extends $C$，但 $D \notin P$，JVM 抛出 IncompatibleClassChangeError。

这一机制在编译期和运行期双重保障封闭性。

4.3 Pattern Matching 的类型消除算法

instanceof 模式匹配的字节码等价于：

// 源码
if (obj instanceof String s) {
    System.out.println(s.length());
}

// 字节码等价
if (obj instanceof String) {
    String s = (String) obj;
    System.out.println(s.length());
}

但编译器会进行 流分析（Flow Analysis），确定变量 $s$ 的”明确赋值”（definite assignment）范围：

• $s$ 在 if 条件为真的分支中赋值。
• $s$ 在 if 条件为假的分支中未赋值（作用域结束）。
• 复杂的 &&、||、! 组合也能正确处理。

例如：

// s 的作用域是整个 if 块
if (obj instanceof String s && s.length() > 5) {
    System.out.println(s.toUpperCase()); // s 已绑定
}

// 否定模式：s 在 else 块中可用
if (!(obj instanceof String s)) {
    return; // obj 不是 String
}
System.out.println(s.length()); // s 已绑定

4.4 Switch 模式匹配的穷举性算法

Switch 模式匹配的穷举性检查基于以下规则：

1. 密封类穷举：若 switch 表达式的选择器类型是密封类 $S$，且所有 case 标签覆盖 $P(S)$，则穷举。
2. 类型层级穷举：若选择器类型是 $T$，且 case 标签覆盖 $T$ 的所有子类型（通过密封类递归），则穷举。
3. null 处理：若选择器可能为 null，需显式 case null 处理（Java 21+）。
4. default 替代：若不穷举，需 default 分支。

算法形式化：

其中 $\text{covered}(\text{cases}, T)$ 递归判断 cases 是否覆盖 $T$ 的所有可能值。

4.5 虚拟线程的卸载机制

虚拟线程的卸载（unmount）发生在以下场景：

1. I/O 阻塞：调用 socket.read()、file.read() 等 NIO 阻塞操作。
2. LockSupport.park()：显式 park。
3. Thread.sleep()：睡眠。
4. Object.wait() / Condition.await()：等待。
5. BlockingQueue 操作：put、take 等。

卸载流程：

虚拟线程 VT 执行阻塞操作
    │
    ▼
JVM 检测到阻塞（通过 java.lang.VirtualThread 的 park 机制）
    │
    ▼
VT 的栈帧保存到堆上的 Thread 对象中（Continuation）
    │
    ▼
载体线程释放 VT，继续执行其他 VT
    │
    ▼
阻塞操作完成（如 socket 数据到达）
    │
    ▼
JVM 唤醒 VT，将其加入调度队列
    │
    ▼
载体线程（可能是另一个）获取 VT，恢复栈帧，继续执行

固定（Pinning） 是卸载的反面：虚拟线程无法卸载，占用载体线程。发生场景：

1. synchronized 块内阻塞：synchronized 使用 OS monitor，无法在虚拟线程上重实现。
2. JNI 调用：native 方法持有 OS 资源。
3. 第三方库的 Thread.currentThread() 假设：某些库假设线程是平台线程，可能 break。

修复：用 ReentrantLock 替代 synchronized。JDK 21+ 提供了 jcmd Thread.dump_to_file 命令检测 pinning。

4.6 Text Block 的缩进剥离算法

Text Block（文本块）使用 """ 包裹多行字符串，其缩进剥离算法：

1. 确定最小缩进：扫描所有非空行，找到最小前导空格数 $m$。
2. 剥离缩进：每行去除前 $m$ 个空格。
3. 处理 """ 后换行：""" 后的换行符被忽略（第一个换行不计入内容）。
4. 处理尾部 """ 位置：尾部 """ 的位置决定”附加缩进”：
   • 若 """ 与最后一行同行，内容不附加缩进。
   • 若 """ 单独一行，内容附加缩进（缩进 = """ 的前导空格数）。

String s = """
        Hello
        World
        """; // 最小缩进 8，剥离后 "Hello\nWorld\n"

String s2 = """
        Hello
        World
    """; // 最小缩进 8，尾部 """ 缩进 4，剥离后 "    Hello\n    World\n"

stripIndent() 方法实现这一算法，可手动调用。

4.7 var 关键字的类型推断

var 是 Java 10 引入的局部变量类型推断（Local Variable Type Inference），仅用于局部变量（不可用于字段、方法参数、返回类型）。

var list = new ArrayList<String>();  // 推断为 ArrayList<String>
var stream = list.stream();          // 推断为 Stream<String>
var map = Map.of("a", 1);            // 推断为 Map<String, Integer>

类型推断算法基于 LU（Least Upper Bound）：从初始化表达式的类型推断变量类型。对于泛型，var 使用 <> 的目标类型推断：

var list = new ArrayList<>();  // 推断为 ArrayList<Object>，而非 ArrayList<String>

注意：var 不是动态类型，变量类型在编译期确定，不可变。以下代码编译错误：

var x = 1;
x = "string"; // 编译错误：x 是 int，不能赋值 String

5. 代码示例：从入门到进阶的完整实战

5.1 示例 1：Record 类全面演示

// 文件：RecordDemo.java
/**
 * Record 类全面演示
 * 演示规范构造器、紧凑构造器、自定义方法、实现接口、静态工厂
 */
public class RecordDemo {

    // 基本 Record：自动生成构造器、访问器、equals、hashCode、toString
    public record Point(int x, int y) {
        // 紧凑构造器（Compact Constructor）：用于参数验证
        public Point {
            if (x < 0 || y < 0) {
                throw new IllegalArgumentException("坐标不能为负数");
            }
        }

        // 自定义方法
        public double distanceTo(Point other) {
            return Math.sqrt(Math.pow(x - other.x, 2) + Math.pow(y - other.y, 2));
        }

        // 静态工厂方法
        public static Point origin() {
            return new Point(0, 0);
        }
    }

    // Record 实现接口
    public interface Measurable {
        double measure();
    }

    public record Circle(double radius) implements Measurable {
        public Circle {
            if (radius < 0) {
                throw new IllegalArgumentException("半径不能为负");
            }
        }

        @Override
        public double measure() {
            return Math.PI * radius * radius;
        }
    }

    // Record 与泛型
    public record Pair<A, B>(A first, B second) {
        public <C> Pair<C, B> mapFirst(java.util.function.Function<A, C> mapper) {
            return new Pair<>(mapper.apply(first), second);
        }
    }

    public static void main(String[] args) {
        // 基本用法
        Point p1 = new Point(3, 4);
        Point p2 = new Point(6, 8);
        System.out.println(p1); // Point[x=3, y=4]
        System.out.println(p1.x()); // 3（注意：不是 getX()）
        System.out.println(p1.distanceTo(p2)); // 5.0

        // equals / hashCode
        Point p3 = new Point(3, 4);
        System.out.println(p1.equals(p3)); // true
        System.out.println(p1.hashCode() == p3.hashCode()); // true

        // 静态工厂
        Point origin = Point.origin();
        System.out.println(origin); // Point[x=0, y=0]

        // 实现接口
        Circle c = new Circle(5);
        System.out.println("圆面积: " + c.measure()); // 78.5398...

        // 泛型
        Pair<String, Integer> pair = new Pair<>("Hello", 42);
        Pair<Integer, Integer> mapped = pair.mapFirst(String::length);
        System.out.println(mapped); // Pair[first=5, second=42]
    }
}

5.2 示例 2：密封类与模式匹配 switch

// 文件：SealedPatternDemo.java
/**
 * 密封类 + 模式匹配 switch 演示
 * 演示领域建模、穷举性检查、记录模式嵌套
 */
public class SealedPatternDemo {

    // 密封接口：支付方式领域模型
    public sealed interface PaymentMethod permits CreditCard, WeChatPay, BankTransfer, Cash {}

    // Record 实现密封接口
    public record CreditCard(String number, String expiry, String cvv) implements PaymentMethod {}
    public record WeChatPay(String openId) implements PaymentMethod {}
    public record BankTransfer(String account, String bankName) implements PaymentMethod {}
    public record Cash(double amount) implements PaymentMethod {}

    // 模式匹配 switch：穷举所有 PaymentMethod 子类，无需 default
    public static String describe(PaymentMethod method) {
        return switch (method) {
            case CreditCard(var num, var exp, var cvv) ->
                "信用卡，尾号: " + num.substring(num.length() - 4) + "，有效期: " + exp;
            case WeChatPay(var openId) ->
                "微信支付，OpenID: " + openId;
            case BankTransfer(var acct, var bank) ->
                "银行转账，" + bank + " 账户: " + acct;
            case Cash(double amount) ->
                "现金支付，金额: " + amount;
        };
    }

    // 带守卫的模式匹配
    public static String assess(PaymentMethod method) {
        return switch (method) {
            case CreditCard(var num, var exp, var cvv) when num.startsWith("4") ->
                "Visa 信用卡";
            case CreditCard(var num, var exp, var cvv) when num.startsWith("5") ->
                "Mastercard 信用卡";
            case CreditCard(var num, var exp, var cvv) ->
                "其他信用卡";
            case WeChatPay _ -> "微信支付";
            case BankTransfer _ -> "银行转账";
            case Cash(double amount) when amount > 10000 -> "大额现金";
            case Cash _ -> "小额现金";
        };
    }

    // 嵌套记录模式：解构嵌套 Record
    public sealed interface Shape permits Circle, Box {}
    public record Circle(double radius) implements Shape {}
    public record Box(double width, double height, double depth) implements Box {} // 错误：Box 应实现 Shape

    // 修正版
    public sealed interface Shape2 permits Circle2, Rectangle2, Triangle2 {}
    public record Circle2(double radius) implements Shape2 {}
    public record Rectangle2(double width, double height) implements Shape2 {}
    public record Triangle2(double a, double b, double c) implements Shape2 {}

    public static double area(Shape2 shape) {
        return switch (shape) {
            case Circle2(var r) -> Math.PI * r * r;
            case Rectangle2(var w, var h) -> w * h;
            case Triangle2(var a, var b, var c) -> {
                double s = (a + b + c) / 2;
                yield Math.sqrt(s * (s - a) * (s - b) * (s - c));
            }
        };
    }

    // instanceof 模式匹配
    public static void process(Object obj) {
        if (obj instanceof String s && s.length() > 5) {
            System.out.println("长字符串: " + s.toUpperCase());
        } else if (obj instanceof Integer i && i > 0) {
            System.out.println("正整数: " + i);
        } else if (obj instanceof Point(int x, int y)) {
            System.out.println("点: (" + x + ", " + y + ")");
        } else {
            System.out.println("未知类型");
        }
    }

    // 假设 Point 是上面的 Record
    public record Point(int x, int y) {}

    public static void main(String[] args) {
        PaymentMethod[] methods = {
            new CreditCard("4111111111111111", "12/25", "123"),
            new CreditCard("5111111111111111", "11/26", "456"),
            new WeChatPay("wx_openid_001"),
            new BankTransfer("622848", "工商银行"),
            new Cash(500.0),
            new Cash(20000.0)
        };

        for (PaymentMethod m : methods) {
            System.out.println(describe(m));
            System.out.println("  -> " + assess(m));
        }

        // 模式匹配处理
        process("Hello World");
        process(42);
        process(new Point(3, 4));
    }
}

5.3 示例 3：文本块与字符串增强

// 文件：TextBlockDemo.java
/**
 * 文本块 + 字符串增强演示
 * 演示多行字符串、formatted、stripIndent、translateEscapes
 */
public class TextBlockDemo {

    public static void main(String[] args) {
        // 1. 基本文本块：SQL 查询
        String sql = """
            SELECT u.id, u.name, u.email, o.total
            FROM users u
            JOIN orders o ON u.id = o.user_id
            WHERE u.created_at > '2026-01-01'
              AND o.total > 100
            ORDER BY o.total DESC
            """;
        System.out.println("SQL:\n" + sql);

        // 2. JSON 模板
        String json = """
            {
                "user": {
                    "id": %d,
                    "name": "%s",
                    "email": "%s"
                },
                "timestamp": "%s"
            }
            """.formatted(1001, "张三", "zhangsan@example.com", java.time.Instant.now());
        System.out.println("JSON:\n" + json);

        // 3. HTML 模板
        String html = """
            <html>
                <head><title>%s</title></head>
                <body>
                    <h1>%s</h1>
                    <p>%s</p>
                </body>
            </html>
            """.formatted("Welcome", "Hello, World", "This is a text block demo.");
        System.out.println("HTML:\n" + html);

        // 4. 字符串新方法（Java 11+）
        String messy = "  Hello   World  ";
        System.out.println("strip(): '" + messy.strip() + "'");           // "Hello   World"
        System.out.println("stripLeading(): '" + messy.stripLeading() + "'"); // "Hello   World  "
        System.out.println("stripTrailing(): '" + messy.stripTrailing() + "'"); // "  Hello   World"
        System.out.println("strip() vs trim(): strip() 是 Unicode 感知的");

        System.out.println("repeat(): " + "ab".repeat(3));    // ababab
        System.out.println("isBlank(): " + "   ".isBlank());  // true
        System.out.println("lines():");
        "line1\nline2\nline3".lines().forEach(System.out::println);

        // 5. 缩进控制
        String indented = """
            Hello
            World
            """.indent(4);
        System.out.println("indent(4):\n" + indented);

        String stripped = """
                Hello
                World
                """.stripIndent();
        System.out.println("stripIndent():\n" + stripped);

        // 6. translateEscapes：将字符串中的转义序列转换为实际字符
        String raw = "Hello\\nWorld\\t!";
        System.out.println("原始: " + raw);
        System.out.println("translateEscapes: " + raw.translateEscapes());

        // 7. formatted 方法（替代 String.format）
        String formatted = "用户 %s，年龄 %d".formatted("李四", 30);
        System.out.println(formatted);
    }
}

5.4 示例 4：虚拟线程实战

// 文件：VirtualThreadDemo.java
import java.net.URI;
import java.net.http.HttpClient;
import java.net.http.HttpRequest;
import java.net.http.HttpResponse;
import java.time.Duration;
import java.time.Instant;
import java.util.List;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import java.util.stream.IntStream;

/**
 * 虚拟线程实战演示
 * 演示虚拟线程创建、并发 HTTP 请求、与平台线程性能对比
 */
public class VirtualThreadDemo {

    public static void main(String[] args) throws Exception {
        // 1. 基础创建方式
        Thread vt1 = Thread.startVirtualThread(() -> {
            System.out.println("虚拟线程运行: " + Thread.currentThread());
        });
        vt1.join();

        // 2. Builder API
        Thread vt2 = Thread.ofVirtual()
            .name("my-vt-", 0)
            .start(() -> System.out.println("命名虚拟线程: " + Thread.currentThread()));
        vt2.join();

        // 3. 虚拟线程执行器
        System.out.println("\n=== 并发 HTTP 请求 ===");
        long syncStart = System.currentTimeMillis();
        try (var executor = Executors.newVirtualThreadPerTaskExecutor()) {
            List<Future<String>> futures = IntStream.range(0, 100)
                .mapToObj(i -> executor.submit(() -> fetchUrl("https://httpbin.org/delay/1")))
                .toList();

            for (Future<String> f : futures) {
                f.get();
            }
        }
        long syncDuration = System.currentTimeMillis() - syncStart;
        System.out.println("100 个并发请求（虚拟线程）耗时: " + syncDuration + " ms");

        // 4. 对比：平台线程
        long platformStart = System.currentTimeMillis();
        try (var executor = Executors.newFixedThreadPool(100)) {
            List<Future<String>> futures = IntStream.range(0, 100)
                .mapToObj(i -> executor.submit(() -> fetchUrl("https://httpbin.org/delay/1")))
                .toList();

            for (Future<String> f : futures) {
                f.get();
            }
        }
        long platformDuration = System.currentTimeMillis() - platformStart;
        System.out.println("100 个并发请求（平台线程，100 线程池）耗时: " + platformDuration + " ms");

        // 5. 虚拟线程 + CompletableFuture
        System.out.println("\n=== 虚拟线程 + CompletableFuture ===");
        try (var executor = Executors.newVirtualThreadPerTaskExecutor()) {
            Instant start = Instant.now();
            List<String> results = List.of(
                    "https://httpbin.org/delay/1",
                    "https://httpbin.org/delay/2",
                    "https://httpbin.org/delay/3"
                ).stream()
                .map(url -> java.util.concurrent.CompletableFuture
                    .supplyAsync(() -> fetchUrl(url), executor))
                .toList()
                .stream()
                .map(java.util.concurrent.CompletableFuture::join)
                .toList();

            System.out.println("3 个串行请求（虚拟线程并发）总耗时: " +
                Duration.between(start, Instant.now()).toMillis() + " ms");
        }

        // 6. 检测虚拟线程是否固定（Pinning）
        System.out.println("\n=== 虚拟线程固定检测 ===");
        System.out.println("运行以下命令检测 pinning：");
        System.out.println("  jcmd <pid> Thread.dump_to_file -format=json thread_dump.json");
        System.out.println("在 JSON 中搜索 'pinned' 字段");
    }

    /**
     * 模拟 HTTP 请求
     */
    private static String fetchUrl(String url) {
        try {
            HttpClient client = HttpClient.newBuilder()
                .connectTimeout(Duration.ofSeconds(10))
                .build();
            HttpRequest request = HttpRequest.newBuilder()
                .uri(URI.create(url))
                .timeout(Duration.ofSeconds(30))
                .GET()
                .build();
            HttpResponse<String> response = client.send(request, HttpResponse.BodyHandlers.ofString());
            return response.body().substring(0, Math.min(100, response.body().length()));
        } catch (Exception e) {
            return "Error: " + e.getMessage();
        }
    }
}

5.5 示例 5：结构化并发（Structured Concurrency）

// 文件：StructuredConcurrencyDemo.java
import java.util.concurrent.*;
import java.util.concurrent.StructuredTaskScope.*;

/**
 * 结构化并发演示（Java 21 预览特性，Java 24 正式）
 * 演示 ShutdownOnFailure 和 ShutdownOnSuccess 两种作用域
 *
 * 编译运行需启用预览特性：
 *   javac --enable-preview --release 21 StructuredConcurrencyDemo.java
 *   java --enable-preview StructuredConcurrencyDemo
 */
public class StructuredConcurrencyDemo {

    record User(Long id, String name, String email) {}
    record Order(Long id, Long userId, double total) {}
    record OrderDetail(User user, Order order, List<Item> items) {}
    record Item(Long id, String name, double price) {}

    /**
     * ShutdownOnFailure：任一子任务失败则关闭所有子任务
     */
    public static OrderDetail fetchOrderDetail(Long orderId) throws Exception {
        try (var scope = new ShutdownOnFailure()) {
            // 并发 fork 三个子任务
            Subtask<User> userTask = scope.fork(() -> fetchUser(orderId));
            Subtask<Order> orderTask = scope.fork(() -> fetchOrder(orderId));
            Subtask<List<Item>> itemsTask = scope.fork(() -> fetchItems(orderId));

            // 等待所有子任务完成
            scope.join();
            // 若任一子任务失败，抛出 ExecutionException
            scope.throwIfFailed();

            // 所有子任务都成功，组装结果
            return new OrderDetail(userTask.get(), orderTask.get(), itemsTask.get());
        }
    }

    /**
     * ShutdownOnSuccess：任一子任务成功则关闭其他子任务（用于竞速）
     */
    public static String fetchFromMultipleSources(String query) throws Exception {
        try (var scope = new ShutdownOnSuccess<String>()) {
            // 并发查询多个数据源
            scope.fork(() -> queryPrimaryDB(query));
            scope.fork(() -> queryReplicaDB(query));
            scope.fork(() -> queryCache(query));

            scope.join();
            // 返回第一个成功的结果
            return scope.result();
        }
    }

    // 模拟数据获取方法
    private static User fetchUser(Long orderId) throws InterruptedException {
        Thread.sleep(100); // 模拟网络延迟
        return new User(1L, "张三", "zhangsan@example.com");
    }

    private static Order fetchOrder(Long orderId) throws InterruptedException {
        Thread.sleep(150);
        return new Order(orderId, 1L, 199.99);
    }

    private static List<Item> fetchItems(Long orderId) throws InterruptedException {
        Thread.sleep(200);
        return List.of(
            new Item(1L, "商品A", 99.99),
            new Item(2L, "商品B", 99.99)
        );
    }

    private static String queryPrimaryDB(String query) throws InterruptedException {
        Thread.sleep(300);
        return "Primary: " + query;
    }

    private static String queryReplicaDB(String query) throws InterruptedException {
        Thread.sleep(200);
        return "Replica: " + query;
    }

    private static String queryCache(String query) throws InterruptedException {
        Thread.sleep(50);
        return "Cache: " + query;
    }

    public static void main(String[] args) throws Exception {
        System.out.println("=== ShutdownOnFailure 示例 ===");
        OrderDetail detail = fetchOrderDetail(1001L);
        System.out.println(detail);

        System.out.println("\n=== ShutdownOnSuccess 示例 ===");
        String result = fetchFromMultipleSources("hello");
        System.out.println("最先返回: " + result);
    }
}

5.6 示例 6：作用域值（Scoped Values）

// 文件：ScopedValueDemo.java
import java.util.concurrent.Executors;

/**
 * 作用域值演示（Java 21 预览，Java 25 正式）
 * 作用域值是 ThreadLocal 的现代替代品，特别适合虚拟线程
 *
 * 编译运行需启用预览特性：
 *   javac --enable-preview --release 21 ScopedValueDemo.java
 *   java --enable-preview ScopedValueDemo
 */
public class ScopedValueDemo {

    // 定义作用域值
    private static final ScopedValue<User> CURRENT_USER = ScopedValue.newInstance();
    private static final ScopedValue<String> REQUEST_ID = ScopedValue.newInstance();

    record User(Long id, String name, String role) {}

    public static void main(String[] args) throws Exception {
        User admin = new User(1L, "Admin", "ADMIN");

        // 绑定作用域值并执行
        ScopedValue.where(CURRENT_USER, admin)
            .where(REQUEST_ID, "req-001")
            .run(() -> {
                handleRequest();
                System.out.println("当前用户: " + CURRENT_USER.get());
                System.out.println("请求 ID: " + REQUEST_ID.get());
            });

        // 作用域值在 run() 之外不可访问
        // System.out.println(CURRENT_USER.get()); // 抛出 NoSuchElementException

        // 虚拟线程中使用作用域值
        try (var executor = Executors.newVirtualThreadPerTaskExecutor()) {
            for (int i = 0; i < 3; i++) {
                final int idx = i;
                executor.submit(() -> {
                    ScopedValue.where(REQUEST_ID, "req-" + idx)
                        .run(() -> handleRequest());
                });
            }
        }
    }

    static void handleRequest() {
        // 在任意深层调用中都能访问作用域值
        System.out.println("[" + REQUEST_ID.get() + "] 处理请求开始");
        doBusiness();
        System.out.println("[" + REQUEST_ID.get() + "] 处理请求完成");
    }

    static void doBusiness() {
        // 作用域值是不可变的，无法在子调用中修改
        // 但可以重新绑定（创建新作用域）
        System.out.println("[" + REQUEST_ID.get() + "] 业务处理中");
    }
}

5.7 示例 7：HttpClient（Java 11+）

// 文件：HttpClientDemo.java
import java.net.URI;
import java.net.http.*;
import java.time.Duration;

/**
 * 现代 HttpClient 演示（Java 11+）
 * 替代老旧的 HttpURLConnection，支持 HTTP/2、WebSocket、异步
 */
public class HttpClientDemo {

    public static void main(String[] args) throws Exception {
        // 1. 同步请求
        HttpClient client = HttpClient.newBuilder()
            .version(HttpClient.Version.HTTP_2)
            .connectTimeout(Duration.ofSeconds(10))
            .followRedirects(HttpClient.Redirect.NORMAL)
            .build();

        HttpRequest request = HttpRequest.newBuilder()
            .uri(URI.create("https://api.github.com/users/octocat"))
            .header("Accept", "application/vnd.github.v3+json")
            .header("User-Agent", "Java 21 HttpClient")
            .timeout(Duration.ofSeconds(30))
            .GET()
            .build();

        HttpResponse<String> response = client.send(request, HttpResponse.BodyHandlers.ofString());
        System.out.println("状态码: " + response.statusCode());
        System.out.println("响应体: " + response.body().substring(0, Math.min(200, response.body().length())));

        // 2. 异步请求
        System.out.println("\n=== 异步请求 ===");
        CompletableFuture<HttpResponse<String>> future =
            client.sendAsync(request, HttpResponse.BodyHandlers.ofString());

        future.thenAccept(r -> System.out.println("异步状态码: " + r.statusCode()))
              .thenAccept(r -> System.out.println("异步完成"))
              .exceptionally(e -> {
                  System.err.println("请求失败: " + e.getMessage());
                  return null;
              });

        future.join();

        // 3. POST 请求
        System.out.println("\n=== POST 请求 ===");
        String jsonBody = """
            {
                "title": "foo",
                "body": "bar",
                "userId": 1
            }
            """;
        HttpRequest postRequest = HttpRequest.newBuilder()
            .uri(URI.create("https://jsonplaceholder.typicode.com/posts"))
            .header("Content-Type", "application/json")
            .POST(HttpRequest.BodyPublishers.ofString(jsonBody))
            .build();

        HttpResponse<String> postResponse = client.send(postRequest, HttpResponse.BodyHandlers.ofString());
        System.out.println("POST 状态码: " + postResponse.statusCode());
        System.out.println("POST 响应: " + postResponse.body());

        // 4. 多个并发请求
        System.out.println("\n=== 并发请求 ===");
        long start = System.currentTimeMillis();
        var futures = java.util.List.of(
                "https://jsonplaceholder.typicode.com/posts/1",
                "https://jsonplaceholder.typicode.com/posts/2",
                "https://jsonplaceholder.typicode.com/posts/3"
            ).stream()
            .map(url -> client.sendAsync(
                HttpRequest.newBuilder().uri(URI.create(url)).GET().build(),
                HttpResponse.BodyHandlers.ofString()))
            .toList();

        futures.forEach(f -> f.thenAccept(r ->
            System.out.println("并发请求状态码: " + r.statusCode())));

        CompletableFuture.allOf(futures.toArray(new CompletableFuture[0])).join();
        System.out.println("3 个并发请求总耗时: " + (System.currentTimeMillis() - start) + " ms");
    }

    // CompletableFuture 需要 import
    private static final class CompletableFuture<T> extends java.util.concurrent.CompletableFuture<T> {}
}

5.8 示例 8：集合工厂方法与不可变集合

// 文件：CollectionFactoryDemo.java
import java.util.*;

/**
 * 集合工厂方法演示（Java 9+）
 * 演示 List.of、Set.of、Map.of 及其特性
 */
public class CollectionFactoryDemo {

    public static void main(String[] args) {
        // 1. List.of：创建不可变 List
        List<String> fruits = List.of("Apple", "Banana", "Cherry");
        System.out.println("List: " + fruits);

        // 2. Set.of：创建不可变 Set（自动去重）
        Set<Integer> numbers = Set.of(1, 2, 3, 4, 5);
        System.out.println("Set: " + numbers);

        // 3. Map.of：创建不可变 Map（最多 10 对 key-value）
        Map<String, Integer> ages = Map.of(
            "Alice", 25,
            "Bob", 30,
            "Charlie", 35
        );
        System.out.println("Map: " + ages);

        // 4. Map.ofEntries：超过 10 对时使用
        Map<String, Integer> bigMap = Map.ofEntries(
            Map.entry("k1", 1),
            Map.entry("k2", 2),
            Map.entry("k3", 3),
            Map.entry("k4", 4),
            Map.entry("k5", 5),
            Map.entry("k6", 6),
            Map.entry("k7", 7),
            Map.entry("k8", 8),
            Map.entry("k9", 9),
            Map.entry("k10", 10),
            Map.entry("k11", 11)
        );
        System.out.println("Big Map size: " + bigMap.size());

        // 5. 不可变性测试
        try {
            fruits.add("Date"); // 抛出 UnsupportedOperationException
        } catch (UnsupportedOperationException e) {
            System.out.println("List.of 返回不可变 List，add 失败");
        }

        try {
            ages.put("David", 40); // 抛出 UnsupportedOperationException
        } catch (UnsupportedOperationException e) {
            System.out.println("Map.of 返回不可变 Map，put 失败");
        }

        // 6. 不允许 null
        try {
            List<String> withNull = List.of("a", null, "b");
        } catch (NullPointerException e) {
            System.out.println("List.of 不允许 null 元素");
        }

        // 7. Set.of 不允许重复
        try {
            Set<Integer> duplicate = Set.of(1, 2, 2); // 抛出 IllegalArgumentException
        } catch (IllegalArgumentException e) {
            System.out.println("Set.of 不允许重复元素");
        }

        // 8. Arrays.asList vs List.of
        String[] arr = {"A", "B", "C"};
        List<String> asList = Arrays.asList(arr); // 可修改元素，不可增删
        List<String> listOf = List.of(arr);       // 完全不可变

        asList.set(0, "X"); // OK
        // listOf.set(0, "X"); // 抛出 UnsupportedOperationException

        arr[0] = "Y"; // asList 和原数组关联，但 listOf 不关联
        System.out.println("Arrays.asList[0]: " + asList.get(0)); // Y
        System.out.println("List.of[0]: " + listOf.get(0)); // A（List.of 复制元素）

        // 9. Stream API 配合
        List<String> filtered = fruits.stream()
            .filter(f -> f.startsWith("A") || f.startsWith("B"))
            .sorted()
            .toList(); // Java 16+ 的 Stream.toList()
        System.out.println("Filtered: " + filtered);

        // 10. Sequenced Collections（Java 21+）
        SequencedCollection<String> seq = new LinkedList<>(fruits);
        seq.addFirst("First");
        seq.addLast("Last");
        System.out.println("Sequenced: " + seq);
        System.out.println("First: " + seq.getFirst());
        System.out.println("Last: " + seq.getLast());
        System.out.println("Reversed: " + seq.reversed());
    }
}

5.9 示例 9：Sequenced Collections（Java 21）

// 文件：SequencedCollectionDemo.java
import java.util.*;

/**
 * Sequenced Collections 演示（Java 21+）
 * 新增三个接口：SequencedCollection、SequencedSet、SequencedMap
 * 统一了"有顺序的集合"的 API
 */
public class SequencedCollectionDemo {

    public static void main(String[] args) {
        // SequencedCollection：List、LinkedList、ArrayDeque 等
        SequencedCollection<String> list = new ArrayList<>(List.of("A", "B", "C"));
        list.addFirst("Z"); // 在头部添加
        list.addLast("D");  // 在尾部添加
        System.out.println("List: " + list); // [Z, A, B, C, D]
        System.out.println("First: " + list.getFirst()); // Z
        System.out.println("Last: " + list.getLast()); // D
        System.out.println("Reversed: " + list.reversed()); // [D, C, B, A, Z]

        list.removeFirst();
        list.removeLast();
        System.out.println("After remove: " + list); // [A, B, C]

        // SequencedSet：LinkedHashSet、SortedSet 等
        SequencedSet<Integer> set = new LinkedHashSet<>(List.of(3, 1, 4, 1, 5, 9));
        set.addFirst(100);
        set.addLast(200);
        System.out.println("Set: " + set); // [100, 3, 1, 4, 5, 9, 200]
        System.out.println("Reversed: " + set.reversed());

        // SequencedMap：LinkedHashMap、TreeMap 等
        SequencedMap<String, Integer> map = new LinkedHashMap<>();
        map.put("one", 1);
        map.put("two", 2);
        map.put("three", 3);
        System.out.println("Map: " + map);
        System.out.println("FirstEntry: " + map.firstEntry()); // one=1
        System.out.println("LastEntry: " + map.lastEntry());   // three=3
        System.out.println("Reversed: " + map.reversed());

        map.putFirst("zero", 0);
        System.out.println("After putFirst: " + map); // {zero=0, one=1, two=2, three=3}

        // pollFirst / pollLast：移除并返回
        Map.Entry<String, Integer> polled = map.pollFirstEntry();
        System.out.println("Polled: " + polled);
        System.out.println("After poll: " + map);

        // SequencedCollections 的新方法在所有有序集合上一致可用
        // 之前需要 list.get(0)、deque.getFirst()、set.iterator().next() 等不一致的写法
    }
}

5.10 示例 10：Switch 表达式与 yield

// 文件：SwitchExpressionDemo.java
/**
 * Switch 表达式演示（Java 14+）
 * - 表达式形式（有返回值）
 * - 箭头语法（无 fall-through）
 * - yield 关键字返回值
 * - 多值 case 标签
 */
public class SwitchExpressionDemo {

    public static void main(String[] args) {
        // 1. 基本表达式形式
        int day = 3;
        String dayName = switch (day) {
            case 1 -> "Monday";
            case 2 -> "Tuesday";
            case 3 -> "Wednesday";
            case 4 -> "Thursday";
            case 5 -> "Friday";
            case 6 -> "Saturday";
            case 7 -> "Sunday";
            default -> throw new IllegalArgumentException("Invalid day: " + day);
        };
        System.out.println("Day: " + dayName);

        // 2. 多值 case 标签
        String type = switch (day) {
            case 1, 2, 3, 4, 5 -> "Weekday";
            case 6, 7 -> "Weekend";
            default -> throw new IllegalArgumentException("Invalid day");
        };
        System.out.println("Type: " + type);

        // 3. 块语句与 yield
        int score = 85;
        String grade = switch (score / 10) {
            case 10, 9 -> "A";
            case 8 -> {
                System.out.println("  good score");
                yield "B";
            }
            case 7 -> "C";
            case 6 -> "D";
            default -> {
                System.out.println("  need improvement");
                yield "F";
            }
        };
        System.out.println("Grade: " + grade);

        // 4. switch 作为语句（无返回值）
        switch (day) {
            case 1, 2, 3, 4, 5 -> System.out.println("工作日");
            case 6, 7 -> System.out.println("周末");
        }

        // 5. 与枚举配合
        enum Color { RED, GREEN, BLUE }
        Color color = Color.GREEN;
        String hex = switch (color) {
            case RED -> "#FF0000";
            case GREEN -> "#00FF00";
            case BLUE -> "#0000FF";
        };
        System.out.println("Color hex: " + hex);
    }
}

6. 对比分析：现代特性的取舍

6.1 Record vs 传统 POJO vs Lombok @Data

选型建议：

• DTO / 值对象 / 不可变数据：优先使用 Record。
• JPA Entity / 可变实体：使用传统 POJO 或 Lombok（Entity 的可变性通常是需要的）。
• 避免 Lombok 的新项目：Record + 密封类可覆盖大部分场景，减少对 Lombok 的依赖。

6.2 虚拟线程 vs CompletableFuture vs Reactor

选型建议：

• 新项目（JDK 21+）：优先使用虚拟线程，“同步代码、异步性能”。
• 遗留 JDK 8 项目：CompletableFuture + 线程池。
• 背压敏感场景（如流处理）：Reactor 仍是首选，虚拟线程不解决背压。
• 混合场景：虚拟线程处理 I/O，Reactor 处理流。

6.3 Pattern Matching vs 传统 instanceof + 强转

// 传统写法（Java 7）
if (obj instanceof String) {
    String s = (String) obj;
    System.out.println(s.length());
}

// 模式匹配写法（Java 16+）
if (obj instanceof String s) {
    System.out.println(s.length());
}

6.4 Text Block vs 字符串拼接

// 传统写法
String json = "{\n" +
              "  \"name\": \"Alice\",\n" +
              "  \"age\": 30\n" +
              "}";

// Text Block
String json = """
        {
            "name": "Alice",
            "age": 30
        }
        """;

7. 陷阱与反模式

7.1 反模式 1：Record 中添加可变状态

// 反模式：Record 中添加可变字段（违反 Record 不可变性）
public record Counter(int initial) {
    private int count = initial; // 编译错误：Record 字段必须 final
    // 但可以用数组绕过
    private int[] mutable = {initial};

    public void increment() {
        mutable[0]++; // 反模式：Record 不应有可变状态
    }
}

// 正确：Record 保持不可变，可变状态用其他类管理
public record CounterSnapshot(int value) {}

public class Counter {
    private int value;
    public synchronized void increment() { value++; }
    public CounterSnapshot snapshot() { return new CounterSnapshot(value); }
}

7.2 反模式 2：密封类的 non-sealed 滥用

// 反模式：non-sealed 破坏封闭性
public sealed interface Shape permits Circle, Square, Triangle, Freeform {}
public non-sealed class Freeform implements Shape {} // 任意类可继承

// 后果：switch 模式匹配无法穷举，需要 default
public double area(Shape s) {
    return switch (s) {
        case Circle c -> Math.PI * c.radius() * c.radius();
        case Square sq -> sq.side() * sq.side();
        case Triangle t -> heronFormula(t);
        case Freeform f -> computeFreeformArea(f); // 但子类可能很多
        // 需要 default，丧失穷举性检查
    };
}

// 正确：避免 non-sealed，或将其限制在受控范围

7.3 反模式 3：虚拟线程中使用 synchronized

// 反模式：synchronized 导致虚拟线程固定（Pinning）
public synchronized String fetchData() {  // synchronized 修饰方法
    return blockingNetworkCall(); // 阻塞时虚拟线程无法卸载
}

public String processData() {
    synchronized (this) {  // synchronized 块
        return blockingNetworkCall(); // 载体线程被占用
    }
}

// 正确：使用 ReentrantLock 替代
private final ReentrantLock lock = new ReentrantLock();

public String fetchData() {
    lock.lock();
    try {
        return blockingNetworkCall(); // 阻塞时虚拟线程可正常卸载
    } finally {
        lock.unlock();
    }
}

7.4 反模式 4：var 过度使用

// 反模式：var 滥用导致类型不清晰
var result = process(data);  // result 是什么类型？
var x = getService().getConfig().getTimeout();  // x 是 Duration 还是 int？
var list = new ArrayList<>();  // list 是 ArrayList<Object>，丢失泛型

// 正确：类型不明显时显式声明
String result = process(data);
Duration timeout = getService().getConfig().getTimeout();
List<User> users = new ArrayList<>();

// var 适合的场景：类型明显
var users = List.of(new User(1), new User(2));  // List<User> 明显
var stream = users.stream();                     // Stream<User> 明显
var entry = Map.entry("key", 1);                 // Map.Entry<String, Integer> 明显

7.5 反模式 5：在 Record 紧凑构造器中修改参数

// 反模式：在紧凑构造器中修改参数（违反规范）
public record Age(int years) {
    public Age {
        if (years < 0) {
            years = 0; // 反模式：应抛出异常而非静默修改
        }
    }
}

// 正确：紧凑构造器用于验证，不修改
public record Age(int years) {
    public Age {
        if (years < 0) {
            throw new IllegalArgumentException("年龄不能为负数: " + years);
        }
    }

    // 如需规范化，提供静态工厂
    public static Age safe(int years) {
        return new Age(Math.max(0, years));
    }
}

7.6 反模式 6：模式匹配 switch 忘记 null 处理

// 反模式：未处理 null，运行时 NPE
public String describe(Shape s) {
    return switch (s) {  // 若 s 为 null，抛出 NullPointerException
        case Circle c -> "圆";
        case Square sq -> "方";
    };
}

// 正确：显式处理 null（Java 21+）
public String describe(Shape s) {
    return switch (s) {
        case null -> "空";
        case Circle c -> "圆";
        case Square sq -> "方";
    };
}

// 或在调用前检查
public String describe(Shape s) {
    if (s == null) return "空";
    return switch (s) {
        case Circle c -> "圆";
        case Square sq -> "方";
    };
}

7.7 反模式 7：文本块缩进混乱

// 反模式：文本块缩进不一致，导致剥离结果不符预期
String json = """
  {
    "name": "Alice"
  }
    """; // 尾部 """ 缩进 4，最小缩进 2，剥离后内容会缩进 2

// 正确：保持缩进一致
String json = """
        {
            "name": "Alice"
        }
        """; // 所有行缩进 8，尾部 """ 缩进 8，剥离后无附加缩进

7.8 反模式 8：虚拟线程池化

// 反模式：池化虚拟线程（虚拟线程本应即用即弃）
private static final ExecutorService pool =
    Executors.newFixedThreadPool(100); // 不要这样做

// 正确：每次创建新虚拟线程
try (var executor = Executors.newVirtualThreadPerTaskExecutor()) {
    // 每个任务一个虚拟线程，无需池化
}

7.9 反模式 9：作用域值的误用

// 反模式：作用域值不是 ThreadLocal，无法在任意位置修改
private static final ScopedValue<Integer> COUNTER = ScopedValue.newInstance();

// 以下代码无法工作
ScopedValue.where(COUNTER, 0).run(() -> {
    increment(); // 无法修改 COUNTER
});

void increment() {
    // COUNTER.set(COUNTER.get() + 1); // 编译错误：ScopedValue 不可变
}

// 正确：用 AtomicInteger 或 ThreadLocal
private static final ThreadLocal<Integer> COUNTER = ThreadLocal.withInitial(() -> 0);
// 或使用可变引用
private static final ScopedValue<int[]>> COUNTER = ScopedValue.newInstance();
ScopedValue.where(COUNTER, new int[]{0}).run(() -> {
    COUNTER.get()[0]++;
});

7.10 反模式 10：忽视预览特性的不稳定性

// 反模式：在生产代码使用预览特性
public String process(String input) {
    // 字符串模板是预览特性，可能在后续版本变更
    return STR."Processed: \{input}";
}

// 正确：预览特性仅在实验中使用，生产等待正式版
public String process(String input) {
    return "Processed: " + input; // 等待正式版
}

8. 工程实践：现代 Java 的项目落地

8.1 JDK 版本选型

8.2 升级路径

8.2.1 JDK 8 → JDK 17 升级清单

1. 模块系统适配：

   • 检查 sun.* 内部 API 使用，替换为公开 API。
   • 添加 --add-opens 启动参数（临时方案）。
   • 评估将库迁移为 JPMS 模块。

2. 强封装适配：

   • 反射访问 JDK 内部类失败，添加 --add-opens。
   • Lombok、Mockito 等字节码增强工具需升级版本。

3. 废弃 API 替换：

   • SecurityManager 弃用，迁移到 java.security 替代方案。
   • java.util.Date / Calendar 迁移到 java.time.*。

4. GC 选择：

   • JDK 8 默认 Parallel GC，JDK 9+ 默认 G1 GC。
   • 评估 ZGC（JDK 15+）用于低延迟场景。

5. 类文件版本：

   • 重新编译所有依赖到 JDK 17 字节码（class file version 61）。
   • 检查第三方依赖的兼容性。

8.2.2 JDK 17 → JDK 21 升级清单

1. 虚拟线程适配：

   • 替换 synchronized 为 ReentrantLock。
   • 评估 ThreadLocal 在百万虚拟线程下的内存占用。

2. 模式匹配重构：

   • 将 if instanceof + 强转 重构为 if instanceof T t。
   • 将复杂 if-else 链重构为 switch 模式匹配。

3. Record 重构：

   • 将 Lombok @Value 替换为 Record。
   • DTO 类迁移到 Record。

8.3 Spring Boot 3 + 虚拟线程实践

# application.yml - 启用虚拟线程
spring:
  threads:
    virtual:
      enabled: true  # Spring Boot 3.2+

server:
  tomcat:
    threads:
      max: 200  # 平台线程数（载体线程）

// Spring Boot 3.2+ 自动配置虚拟线程
// - Tomcat 请求处理使用虚拟线程
// - @Async 方法使用虚拟线程
// - @Scheduled 任务使用虚拟线程
// - Spring WebClient 使用虚拟线程

@Service
public class OrderService {
    // 同步阻塞代码，但底层使用虚拟线程
    public OrderDetail getOrderDetail(Long orderId) {
        // 这三个调用在虚拟线程中串行执行
        // 但因虚拟线程成本低，可改为并行
        Order order = orderDao.findById(orderId);
        List<Item> items = itemDao.findByOrderId(orderId);
        User user = userDao.findById(order.getUserId());
        return new OrderDetail(order, items, user);
    }

    // 并行版本：使用虚拟线程执行器
    public OrderDetail getOrderDetailParallel(Long orderId) {
        try (var executor = Executors.newVirtualThreadPerTaskExecutor()) {
            var orderFuture = executor.submit(() -> orderDao.findById(orderId));
            var itemsFuture = executor.submit(() -> itemDao.findByOrderId(orderId));

            Order order = orderFuture.get();
            var userFuture = executor.submit(() -> userDao.findById(order.getUserId()));

            return new OrderDetail(order, itemsFuture.get(), userFuture.get());
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }
}

8.4 Record 与 Jackson 集成

// Jackson 2.12+ 原生支持 Record 反序列化
public record UserDTO(
    Long id,
    String name,
    String email,
    Integer age
) {}

@RestController
@RequestMapping("/api/users")
public class UserController {

    @GetMapping("/{id}")
    public UserDTO getUser(@PathVariable Long id) {
        // Jackson 自动序列化 UserDTO 为 JSON
        return userService.findById(id);
    }

    @PostMapping
    public UserDTO createUser(@RequestBody UserDTO dto) {
        // Jackson 自动反序列化 JSON 为 UserDTO
        return userService.create(dto);
    }
}

// 配置 Jackson 适配 Record
@Configuration
public class JacksonConfig {
    @Bean
    public ObjectMapper objectMapper() {
        return JsonMapper.builder()
            .enable(MapperFeature.ACCEPT_CASE_INSENSITIVE_PROPERTIES)
            .build();
    }
}

8.5 密封类 + 模式匹配的领域建模

// 领域模型：电商订单状态
public sealed interface OrderStatus permits Pending, Paid, Shipped, Delivered, Cancelled {}

public record Pending(Instant createdAt) implements OrderStatus {}
public record Paid(Instant paidAt, String paymentMethod) implements OrderStatus {}
public record Shipped(Instant shippedAt, String trackingNumber) implements OrderStatus {}
public record Delivered(Instant deliveredAt) implements OrderStatus {}
public record Cancelled(Instant cancelledAt, String reason) implements OrderStatus {}

// 状态机：处理状态转换
public class OrderStateMachine {
    public static OrderStatus transition(OrderStatus current, OrderEvent event) {
        return switch (current) {
            case Pending(var createdAt) -> switch (event) {
                case PAY -> new Paid(Instant.now(), "unknown");
                case CANCEL -> new Cancelled(Instant.now(), "user_cancelled");
                default -> throw new IllegalStateException("Pending 状态不支持: " + event);
            };
            case Paid(var paidAt, var method) -> switch (event) {
                case SHIP -> new Shipped(Instant.now(), generateTrackingNumber());
                case CANCEL -> new Cancelled(Instant.now(), "refund");
                default -> throw new IllegalStateException("Paid 状态不支持: " + event);
            };
            case Shipped(var shippedAt, var tracking) -> switch (event) {
                case DELIVER -> new Delivered(Instant.now());
                default -> throw new IllegalStateException("Shipped 状态不支持: " + event);
            };
            case Delivered _) -> throw new IllegalStateException("Delivered 是终态");
            case Cancelled(_) -> throw new IllegalStateException("Cancelled 是终态");
        };
    }

    private static String generateTrackingNumber() {
        return "TRK" + System.currentTimeMillis();
    }
}

enum OrderEvent { PAY, SHIP, DELIVER, CANCEL }

9. 案例研究：主流框架的现代 Java 实践

9.1 案例研究 1：Spring Framework 6 的 Java 17 基线

Spring Framework 6（2022 年 11 月发布）将基线提升到 Java 17，并广泛使用现代特性：

1. Record 用于配置类：SpringApplication 的内部配置大量使用 Record。
2. 密封类用于事件：ApplicationEvent 的子类型使用密封类，便于事件处理穷举。
3. Pattern Matching 用于条件判断：Spring AOT 编译器使用 instanceof 模式匹配简化代码。
4. HttpClient 替代 RestTemplate：Spring 6 的 RestClient 基于 Java 11+ HttpClient。
5. 虚拟线程支持：Spring Boot 3.2+ 自动配置虚拟线程。

9.2 案例研究 2：Quarkus 的原生镜像与 Record

Quarkus 框架深度集成 GraalVM Native Image，Record 在其中扮演重要角色：

1. Record 作为配置载体：Quarkus 的 @ConfigRoot 注解的配置类推荐用 Record。
2. Record 的反射友好性：Native Image 中 Record 的规范构造器可被反射调用，无需额外配置。
3. 密封类 + Pattern Matching：Quarkus 的 CDI 容器使用密封类建模 Bean 类型，模式匹配简化分派。

9.3 案例研究 3：Kafka 客户端的虚拟线程适配

Kafka 客户端（kafka-clients 3.7+）适配了虚拟线程：

// 传统 Kafka 消费者（平台线程）
try (KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props)) {
    consumer.subscribe(List.of("topic"));
    while (running) {
        ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100));
        // 处理记录
    }
}

// 虚拟线程友好的 Kafka 消费者
Thread vt = Thread.startVirtualThread(() -> {
    try (KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props)) {
        consumer.subscribe(List.of("topic"));
        while (running) {
            ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100));
            // poll() 内部阻塞时虚拟线程自动卸载
            records.forEach(this::process);
        }
    }
});

9.4 案例研究 4：JIT 优化对现代特性的影响

HotSpot JIT 编译器对现代特性有专门优化：

1. Lambda 内联：invokedynamic 调用的 Lambda 在 JIT 编译后可被内联，避免接口调用开销。
2. Record 的标量替换：Record 对象在逃逸分析后可被标量替换，避免堆分配。
3. Pattern Matching 的优化：instanceof 模式匹配的 type check 在 JIT 中可合并，减少指令数。
4. 虚拟线程的 Continuation 优化：虚拟线程的栈帧保存/恢复在 JIT 中被优化为栈指针操作。

9.5 案例研究 5：电商订单系统的现代 Java 重构

某电商系统从 JDK 8 升级到 JDK 21 的重构案例：

重构前（JDK 8）：

// DTO
public class OrderDTO {
    private Long id;
    private Long userId;
    private BigDecimal total;
    // ... 50 行 getter/setter
}

// 状态判断
public String getOrderStatus(Order order) {
    if (order.getStatus().equals("PENDING")) {
        return "待支付";
    } else if (order.getStatus().equals("PAID")) {
        return "已支付";
    } else if (order.getStatus().equals("SHIPPED")) {
        return "已发货";
    }
    // ... 10 行 if-else
}

// 并发请求
public OrderDetail getOrderDetail(Long orderId) throws ExecutionException, InterruptedException {
    ExecutorService executor = Executors.newFixedThreadPool(3);
    Future<Order> orderFuture = executor.submit(() -> orderDao.findById(orderId));
    Future<List<Item>> itemsFuture = executor.submit(() -> itemDao.findByOrderId(orderId));
    Future<User> userFuture = executor.submit(() -> userDao.findById(orderFuture.get().getUserId()));
    // 手工管理线程池
    try {
        return new OrderDetail(orderFuture.get(), itemsFuture.get(), userFuture.get());
    } finally {
        executor.shutdown();
    }
}

重构后（JDK 21）：

// Record DTO
public record OrderDTO(Long id, Long userId, BigDecimal total) {}

// 密封类 + 模式匹配
public sealed interface OrderStatus permits Pending, Paid, Shipped, Delivered, Cancelled {}
public record Pending(Instant createdAt) implements OrderStatus {}
public record Paid(Instant paidAt) implements OrderStatus {}
public record Shipped(Instant shippedAt, String trackingNo) implements OrderStatus {}
public record Delivered(Instant deliveredAt) implements OrderStatus {}
public record Cancelled(Instant cancelledAt, String reason) implements OrderStatus {}

public String getOrderStatus(Order order) {
    return switch (order.status()) {
        case Pending(_) -> "待支付";
        case Paid(_) -> "已支付";
        case Shipped(var _, var trackingNo) -> "已发货，单号: " + trackingNo;
        case Delivered(_) -> "已送达";
        case Cancelled(var _, var reason) -> "已取消: " + reason;
    };
}

// 虚拟线程并发
public OrderDetail getOrderDetail(Long orderId) {
    try (var executor = Executors.newVirtualThreadPerTaskExecutor()) {
        var orderFuture = executor.submit(() -> orderDao.findById(orderId));
        var itemsFuture = executor.submit(() -> itemDao.findByOrderId(orderId));

        Order order = orderFuture.get();
        var userFuture = executor.submit(() -> userDao.findById(order.userId()));

        return new OrderDetail(order, itemsFuture.get(), userFuture.get());
    } catch (Exception e) {
        throw new RuntimeException(e);
    }
}