JDK21新特性

JDK 21 于 2023 年 9 月 19 日正式发布。Oracle 提供GPL 下的生产就绪二进制文件；其他供应商的二进制文件也将很快推出。
Spring Boot 3.x 版本最低支持的 JDK 版本为 JDK 17，也就是说如果你还想用 JDK8的话，那能用的最高 Spring Boot 版本为 2.7。
Dubbo 在官方说明中也已经将 JDK 17 作为推荐的版本了。其他的几乎你所能用到的一些开源框架或工具包都早已支持最起码 JDK 17 了。JDK 8 不知道还能坚持多久。
JDK21是 LTS（长期支持版），至此为止，目前有 JDK8、JDK11、JDK17和 JDK21这四个长期支持版了。相信用不了多久，JDK21就会取代JDK17的位置，因为 JDK21在 JDK17的基础上做了向上增强。

下载 JDK 21

jdk21下载链接


不管你工作上用的 JDK版本是不是 1.8，都可以下载下来尝试一下，早点熟悉、早点适应，早晚会用上的。

序列化集合接口

我们常用的ArrayList和LinkedList等也都实现了这个接口

//
// Source code recreated from a .class file by IntelliJ IDEA
// (powered by FernFlower decompiler)
//

package java.util;

public interface SequencedCollection extends Collection {
    SequencedCollection reversed();

    default void addFirst(E e) {
        throw new UnsupportedOperationException();
    }

    default void addLast(E e) {
        throw new UnsupportedOperationException();
    }

    default E getFirst() {
        return this.iterator().next();
    }

    default E getLast() {
        return this.reversed().iterator().next();
    }

    default E removeFirst() {
        Iterator it = this.iterator();
        E e = it.next();
        it.remove();
        return e;
    }

    default E removeLast() {
        Iterator it = this.reversed().iterator();
        E e = it.next();
        it.remove();
        return e;
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40

更加方便获取第一个元素，最后一个元素，删除最后一个元素，从头部插入元素

List list = List.of(1, 2, 3);
        // 翻转集合
        List reversed = list.reversed();
        reversed.forEach(System.out::println);
        // 获取第一个元素
        Integer first = list.getFirst();
        // 获取最后一个元素
        Integer last = list.getLast();
1
2
3
4
5
6
7
8

之前获取第一个元素是 list.get(0)，现在用 list.getFirst()就可以了

ZGC 增加分代

可能很多人对JVM垃圾收集机制还停留在G1上，ZGC实在JDK11中推出的，ZGC是低延迟垃圾收集器，几乎是全并发，停顿时间不超过10ms

JDK21中对ZGC的功能进行拓展，增加了分代功能，比如CMS收集器区分老年代和年轻代，可以更加频繁的收集年轻代，要使用ZGC以及分代功能，需要加入以下参数：

-XX:+UseZGC -XX:+ZGenerational
1

Record匹配模式

声明Record

record Person(String name, int age) {}
1

在JDK21之前，我们要使用instanceof判断一个对象，并取出对象字段

 // jdk21之前
       Person p = new Person("leibo", 18);
        if (p instanceof Person) {
            System.out.println("Name: " + p.name());
        }
1
2
3
4
5

在JDK21之后，直接将参数带着，然后自动解析出参数的具体值：

// jdk21之后
        Person p = new Person("leibo", 18);
        // 可以直接解构记录字段
        if (p instanceof Person(String name, int age)) {
            System.out.println(name);
        }
1
2
3
4
5
6

swich增强

增强的swich可以直接根据参数类型来匹配

 public static String switchObject(Object obj) {
        return switch (obj) {
            case Integer i -> String.format("int %d", i);
            case Long l -> String.format("long %d", l);
            case Double d -> String.format("double %f", d);
            case String s -> String.format("String %s", s);
            default -> obj.toString();
        };
    }
1
2
3
4
5
6
7
8
9

测试：

public static void main(String[] args) {
        var strObj = "字符串";
        var intObj = 1;
        var doubleObj = 8.88D;
        System.out.println(switchObject(strObj));
        System.out.println(switchObject(intObj));
        System.out.println(switchObject(doubleObj));
    }
1
2
3
4
5
6
7
8

输出结果：

虚拟线程（Virtual Threads）

虚拟线程是基于协程的线程，它们与其他语言中的协程具有相似之处，但也存在一些不同之处。

虚拟线程是依附于主线程的，如果主线程销毁了，那虚拟线程也不复存在。

相同之处：

虚拟线程和协程都是轻量级的线程，它们的创建和销毁的开销都比传统的操作系统线程要小。
虚拟线程和协程都可以通过暂停和恢复来实现线程之间的切换，从而避免了线程上下文切换的开销。
虚拟线程和协程都可以使用异步和非阻塞的方式来处理任务，提高应用程序的性能和响应速度。
不同之处：

虚拟线程是在 JVM 层面实现的，而协程则是在语言层面实现的。因此，虚拟线程的实现可以与任何支持 JVM 的语言一起使用，而协程的实现则需要特定的编程语言支持。
虚拟线程是一种基于线程的协程实现，因此它们可以使用线程相关的 API，如 ThreadLocal、Lock 和 Semaphore。而协程则不依赖于线程，通常需要使用特定的异步编程框架和 API。
虚拟线程的调度是由 JVM 管理的，而协程的调度是由编程语言或异步编程框架管理的。因此，虚拟线程可以更好地与其他线程进行协作，而协程则更适合处理异步任务。

虚拟线程例子

现在创建线程的方法：

public class SimpleThread implements Runnable{
    @Override
    public void run() {
        System.out.println("当前线程的名称" + Thread.currentThread().getName());

        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
    }
}
1
2
3
4
5
6
7
8
9
10
11
12

使用这个线程，启动线程

  public static void main(String[] args) {
        // 使用线程
        Thread thread = new Thread(new SimpleThread());
        thread.start();
    }
1
2
3
4
5

有了虚拟线程后，怎么实现呢？

Thread.ofPlatform().name("thread1").start(new SimpleThread());
1

下面是使用虚拟线程的几种方法

1.直接启动一个虚拟线程

Thread thread = Thread.startVirtualThread(new SimpleThread());
1

2.使用 ofVirtual(),builder 方式启动虚拟线程，可以设置线程的名称，优先级,异常处理等配置

Thread thread = Thread.ofVirtual()
                .name("thread2")
                .uncaughtExceptionHandler((t, e) -> {
                    System.out.println(t.getName() + e.getMessage());
                }).unstarted(new SimpleThread());
        thread.start();
1
2
3
4
5
6

3.使用Factory创建线程

 // 使用factory
        ThreadFactory factory = Thread.ofVirtual().factory();
        Thread thread = factory.newThread(new SimpleThread());
        thread.setName("thread03");
        thread.start();
1
2
3
4
5

4.使用Executors方式

// 使用Executors方式
        ScheduledExecutorService executorService = Executors.newSingleThreadScheduledExecutor();
        Future submit = executorService.submit(new SimpleThread());
        Object o = submit.get();
1
2
3
4

结构化编程的例子

列举一个场景，假设你有三个任务要同时进行，只要任意一个返回结果，那就直接用这个结果，其他两个任务就停止。

在java8：

ExecutorService executor = Executors.newFixedThreadPool(5);

        // 创建任务列表
        List> tasks = List.of(
                () -> "Task 1",
                () -> "Task 2",
                () -> "Task 3"
        );

        // 执行任务并返回 Future 对象列表
        List> futures = executor.invokeAll(tasks);

        // 等待任一任务完成并获取结果
        String result = executor.invokeAny(tasks);

        System.out.println("Results:");
        for (Future future : futures) {
            System.out.println(future.get());
        }

        System.out.println("Result of the first completed task: " + result);

        executor.shutdown();
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

使用 ExecutorService的invokeAll和invokeAny实现，但是会有一些额外的工作，在拿到第一个结果后，要手动关闭另外的线程。

在JDK21中，可以使用结构化编程实现

ShutdownOnSuccess 捕获第一个结果并关闭任务范围中断未完成的线程并唤醒调用线程。适用于任意子任务的结果可以直接调用，并且无需等待其他线程完成任务的情况。它定义了获取第一个结果或在所有子任务失败时抛出异常

public static void main(String[] args) throws IOException {
  try (var scope = new StructuredTaskScope.ShutdownOnSuccess()) {
    Future res1 = scope.fork(() -> runTask(1));
    Future res2 = scope.fork(() -> runTask(2));
    Future res3 = scope.fork(() -> runTask(3));
    scope.join();
    System.out.println("scope:" + scope.result());
  } catch (ExecutionException | InterruptedException e) {
    throw new RuntimeException(e);
  }
}

public static String runTask(int i) throws InterruptedException {
  Thread.sleep(1000);
  long l = new Random().nextLong();
  String s = String.valueOf(l);
  System.out.println("第" + i + "个任务：" + s);
  return s;
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

ShutdownOnFailure执行多个任务，只要有一个失败（出现异常或其他主动抛出异常情况），就停止其他未执行完的任务，使用scope.throwIfFailed捕捉并抛出异常。如果所有任务均正常，则使用 Feture.get() 或*Feture.resultNow() 获取结果

public static void main(String[] args) throws IOException {
  try (var scope = new StructuredTaskScope.ShutdownOnFailure()) {
    Future res1 = scope.fork(() -> runTaskWithException(1));
    Future res2 = scope.fork(() -> runTaskWithException(2));
    Future res3 = scope.fork(() -> runTaskWithException(3));
    scope.join();
    scope.throwIfFailed(Exception::new);

    String s = res1.resultNow(); //或 res1.get()
    System.out.println(s);
    String result = Stream.of(res1, res2,res3)
      .map(Future::resultNow)
      .collect(Collectors.joining());
    System.out.println("直接结果:" + result);
  } catch (Exception e) {
    e.printStackTrace();
    //throw new RuntimeException(e);
  }
}

// 有一定几率发生异常
public static String runTaskWithException(int i) throws InterruptedException {
  Thread.sleep(1000);
  long l = new Random().nextLong(3);
  if (l == 0) {
    throw new InterruptedException();
  }
  String s = String.valueOf(l);
  System.out.println("第" + i + "个任务：" + s);
  return s;
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32

Scoped Values 的例子

我们肯定都用过 ThreadLocal，它是线程本地变量，只要这个线程没销毁，可以随时获取 ThredLocal 中的变量值。Scoped Values 也可以在线程内部随时获取变量，只不过它有个作用域的概念，超出作用域就会销毁

public class ScopeValueTest {

    final static ScopedValue loginUser = ScopedValue.newInstance();

    public static void main(String[] args) throws InterruptedException {
        ScopedValue.where(loginUser, "lisi")
                .run(()-> {
                    new Service().login();
                });
        Thread.sleep(2000);
    }
    static class Service {
        void login() {
            System.out.println("当前用户是： " + loginUser.get());
        }

    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

上面的例子模拟一个用户登录的过程，使用 ScopedValue.newInstance()声明了一个 ScopedValue，用 ScopedValue.where给 ScopedValue设置值，并且使用 run 方法执行接下来要做的事儿，这样一来，ScopedValue就在 run() 的内部随时可获取了，在run方法中，模拟调用了一个service 的login方法，不用传递LoginUser这个参数，就可以直接通过LoginUser.get方法获取当前登录用户的值了。

Key Encapsulation Mechanism API

提供一套非对称加密的API。使应用程序能够使用 KEM 算法，例如 RSA 密钥封装机制 （RSA-KEM）、椭圆曲线集成加密方案 （ECIES） 以及美国国家标准与技术研究院 （NIST） 后量子加密标准化过程的候选 KEM 算法。

我们如果用 Java 8 的话，涉及到加密算法的部分几乎都是用的第三方加密，那升级了 JDK21之后，就不用使用第三方包了。

JDK帮助文档

https://docs.oracle.com/en/java/javase/21/docs/api/index.html