带你了解Java中的Mono接口

import reactor.core.publisher.Mono;
import java.time.Duration;
// 1. 创建有值的 Mono
Mono<String> mono1 = Mono.just("Hello, Reactor!");
// 2. 创建空 Mono
Mono<String> monoEmpty = Mono.empty();
// 3. 从 Supplier 创建（延迟执行）
Mono<String> monoSupplier = Mono.fromSupplier(() -> "延迟计算的值");
// 4. 从 Callable / Runnable 创建
Mono<String> monoCallable = Mono.fromCallable(() -> "从 Callable 返回");
// 5. 延迟创建（延迟指定时间）
Mono<String> delayed = Mono.delay(Duration.ofSeconds(2))
                           .map(tick -> "延迟2秒后返回");
// 6. 从 CompletableFuture 转换
Mono<String> fromFuture = Mono.fromFuture(CompletableFuture.supplyAsync(() -> "从 Future 来"));
// 7. 错误 Mono
Mono<Object> errorMono = Mono.error(new RuntimeException("出错了！"));

Mono<User> userMono = userRepository.findById(1L)  // 返回 Mono<User>
    .map(user -> user.getName().toUpperCase())     // 转换
    .filter(name -> name.length() > 5)             // 过滤（结果仍为 Mono）
    .flatMap(name -> fetchDetail(name))            // 扁平化嵌套 Mono
    .switchIfEmpty(Mono.just("默认用户"))          // 为空时替换
    .doOnSuccess(user -> System.out.println("成功: " + user))
    .doOnError(err -> System.err.println("错误: " + err))
    .subscribe();  // 触发执行

Mono<String> mono = Mono.just("测试");
// 方式1：简单订阅
mono.subscribe(System.out::println);
// 方式2：完整处理 onNext / onError / onComplete
mono.subscribe(
    value -> System.out.println("收到: " + value),
    error -> System.err.println("错误: " + error),
    () -> System.out.println("完成！")
);

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

    @GetMapping("/{id}")
    public Mono<User> getUser(@PathVariable Long id) {
        return userService.findById(id)          // 返回 Mono<User>
                         .switchIfEmpty(Mono.error(new NotFoundException("用户不存在")));
    }

    @PostMapping
    public Mono<User> createUser(@RequestBody User user) {
        return userService.save(user);
    }
}