未使用Quarkus响应式扩展时I/O操作类型咨询及Java异步诉求

一、不使用Quarkus响应式扩展时的I/O操作 #

• 默认情况下，Quarkus采用阻塞式I/O模型。使用常规JDBC、Servlet API或普通REST客户端（非响应式版本）时，所有I/O操作（数据库查询、HTTP请求等）都会阻塞当前线程，直到操作完成。
• 这种模式下，每个请求占用一个线程，线程在等待I/O期间处于闲置状态，适合简单业务场景，但高并发场景下的资源利用率不如响应式模型。

二、Java中类似C# async/await的异步编程方式 #

Java从Java 8开始引入异步编程能力，Java 19及后续版本的虚拟线程（Project Loom）配合结构化并发，已能实现和C# async/await高度接近的编程体验：

1. CompletableFuture模拟异步调用（Java 8+） #

虽然没有原生async/await关键字，但通过链式调用结合join()可实现类似逻辑，代码保持线性可读：

CompletableFuture<String> fetchDataAsync() {
    return CompletableFuture.supplyAsync(() -> {
        // 模拟阻塞I/O操作
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
        return "异步获取的数据";
    });
}

// 使用方式
public void useAsyncData() {
    String data = fetchDataAsync().join(); // 类似await，等待结果返回
    System.out.println(data);
}

2. 虚拟线程+结构化并发（Java 21+正式特性） #

Java 21的虚拟线程轻量高效，配合StructuredTaskScope可实现完全同步风格的异步代码，彻底避免响应式回调：

String fetchData() throws InterruptedException {
    // 模拟阻塞I/O操作
    Thread.sleep(1000);
    return "虚拟线程获取的数据";
}

// 结构化并发使用虚拟线程
public void useVirtualThreadAsync() throws Exception {
    try (var scope = new StructuredTaskScope.ShutdownOnFailure()) {
        Future<String> dataFuture = scope.fork(this::fetchData);
        scope.join(); // 等待任务完成，等价于await
        scope.throwIfFailed();
        String data = dataFuture.resultNow();
        System.out.println(data);
    }
}

3. Quarkus中的适配 #

Quarkus完全支持Java虚拟线程特性，你可以直接在项目中使用虚拟线程处理异步I/O，无需依赖响应式扩展，既能获得高效的并发处理能力，又能保持同步风格的代码写法。

内容的提问来源于stack exchange，提问作者user2566397