在Reactive编程中，Optional.ifPresent不能直接用于异步流处理，应使用flatMap、switchIfEmpty等Reactor原生操作符替代，避免封装Optional及同步副作用。
在 Reactive 编程（如 Project Reactor 或 R2DBC 场景）中，Optional.ifPresent 本身**不能直接用于异步流处理**，因为它是一个阻塞式、面向同步语义的 API，而 Reactor 的核心是非阻塞、声明式的数据流（Mono/Flux）。强行混用不仅破坏响应式契约，还可能导致线程阻塞、上下文丢失或空指针隐患。真正安全的“变量消费”，应依托 Reactor 原生操作符完成。
用 Mono#flatMap 替代 ifPresent 实现存在性分支
当需要“仅在值存在时执行某异步操作”（类似 ifPresent 的语义），应使用 flatMap —— 它天然对空值（null 或空 Mono）静默跳过：
// ❌ 错误：把 Optional 塞进 reactive 流再调 ifPresent
Mono.just(Optional.of("data"))
.map(opt -> {
opt.ifPresent(s -> System.out.println("Got: " + s)); // 同步副作用，丢失异步能力
return opt;
});
// ✅ 正确：用 flatMap 实现“有值才继续异步链”
Mono<String> data = Mono.just("data");
data.flatMap(s ->
someAsyncService.process(s) // 返回 Mono<Void> 或 Mono<R>
.doOnSuccess(v -> log.info("Processed: {}", s))
);
用 Mono#hasElement() 或 switchIfEmpty 显式处理空值场景
若需区分“有值执行 A”和“无值执行 B”，避免手动判空，应使用 Reactor 提供的空值感知操作符：
-
hasElement()：返回Mono<Boolean>，适合条件判断后分发 -
switchIfEmpty(Mono<T>)：值为空时切换到备用流（最常用） -
defaultIfEmpty(T)：提供默认值，保持类型一致
// 示例：查用户，不存在则创建并返回
Mono<User> user = userRepository.findById(userId);
user.switchIfEmpty(
userCreator.createDefaultUser(userId)
.doOnNext(created -> log.info("Created default user: {}", created))
);
避免在 reactive 链中封装 Optional
Reactor 已通过 Mono 表达“零个或一个元素”的语义，再套一层 Optional 属于冗余且危险的设计：
-
Mono.empty()等价于Optional.empty() -
Mono.just(value)等价于Optional.of(value) - 将
Optional作为Mono的泛型（如Mono<Optional<T>>）会导致双重空值检查，极易出错
若上游必须返回 Optional（如 JPA Repository 的 findById），应立即用 Mono#fromOptional 转换：
// ✅ 正确转换（自动映射 empty → Mono.empty(), of → Mono.just） Mono<User> userMono = Mono.fromOptional(userJpaRepository.findById(id)); // ❌ 不要这样 Mono<Optional<User>> wrapped = Mono.just(userJpaRepository.findById(id));
副作用操作统一用 doOn* 系列，而非 ifPresent 模拟
日志、监控、清理等副作用，应在 reactive 链中使用声明式钩子，而非在 map 或 subscribe 中写 ifPresent：
-
doOnNext：值到达时执行（自动跳过空值） -
doOnSuccess：流成功完成时执行（含Mono.empty()） -
doFinally：无论成功/错误/取消都会执行
Mono<String> result = service.call();
result
.doOnNext(s -> log.debug("Received: {}", s)) // 仅当有值时触发
.doOnSuccess(v -> log.info("Call succeeded")) // 包括 Mono.empty()
.doFinally(signal -> log.trace("Cleanup"));
