从Mono<class>中提取数据

基础概念

Mono<T> 是 Project Reactor 中的一个核心类，用于表示一个异步计算的单一结果。它是响应式编程的一部分，主要用于处理非阻塞的异步操作。与 Java 8 的 CompletableFuture 类似，但 Mono 提供了更多的操作符来组合和处理异步流。

类型

Mono 可以包含任何类型的对象，包括基本数据类型、自定义对象、集合等。

应用场景

Mono 常用于以下场景：

API 响应：在 Web 开发中，用于表示 API 调用的异步响应。
数据库查询：用于表示数据库查询的异步结果。
文件 I/O：用于表示文件读写的异步操作。
外部服务调用：用于表示对外部服务的异步调用。

示例代码

假设我们有一个 User 类：

public class User {
    private String name;
    private int age;

    // getters and setters
}

我们可以使用 Mono 来表示一个异步获取用户信息的操作：

import reactor.core.publisher.Mono;

public class UserService {
    public Mono<User> getUserById(String userId) {
        // 模拟异步操作，例如从数据库中获取用户信息
        return Mono.just(new User("John Doe", 30));
    }
}

提取数据

要从 Mono<User> 中提取数据，可以使用 block() 方法（不推荐在生产环境中使用，因为它会阻塞当前线程），或者使用 subscribe() 方法来处理结果：

public class Main {
    public static void main(String[] args) {
        UserService userService = new UserService();
        Mono<User> userMono = userService.getUserById("123");

        // 使用 block() 方法（不推荐）
        User user = userMono.block();
        System.out.println(user.getName());

        // 使用 subscribe() 方法
        userMono.subscribe(
            user -> System.out.println(user.getName()),
            error -> System.err.println("Error: " + error.getMessage())
        );
    }
}

遇到的问题及解决方法

问题：为什么 Mono 中的数据没有被提取？

原因：

异步操作未完成：Mono 表示的是一个异步操作，数据可能在调用 block() 或 subscribe() 之前还未准备好。
错误处理不当：如果异步操作中发生了错误，可能会导致数据无法被提取。

解决方法：

确保异步操作已完成：可以使用 Mono 的 await() 方法（需要引入 reactor-test 依赖）来等待异步操作完成。
正确处理错误：在 subscribe() 方法中添加错误处理逻辑，以便在发生错误时能够捕获并处理。

import reactor.test.StepVerifier;

public class UserServiceTest {
    @Test
    public void testGetUserById() {
        UserService userService = new UserService();
        Mono<User> userMono = userService.getUserById("123");

        StepVerifier.create(userMono)
            .expectNextMatches(user -> "John Doe".equals(user.getName()))
            .verifyComplete();
    }
}

通过以上方法，可以确保从 Mono 中正确提取数据，并处理可能出现的错误。