spring boot 从Mono<String>中提取出某个字符串返回

在 Spring Boot 中，如果你有一个 Mono<String>（来自 WebFlux 或 Reactor），并且需要从中提取字符串并返回，可以使用以下几种方式：

1. 直接返回 Mono<String>（推荐）

Spring WebFlux 支持直接返回 Mono 或 Flux，框架会自动订阅并处理响应：

import reactor.core.publisher.Mono;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class MyController {

    @GetMapping("/example")
    public Mono<String> getExample() {
        Mono<String> monoString = Mono.just("Hello, WebFlux!");
        return monoString; // 直接返回 Mono，Spring 会自动处理
    }
}

访问 /example 会直接返回 Hello, WebFlux!。

2. 阻塞等待（不推荐，仅用于测试）

如果 必须 获取 Mono 中的值（例如在非 Reactor 上下文中），可以使用 block()，但 会阻塞线程，违反 Reactor 的非阻塞原则：

@GetMapping("/block-example")
public String getBlockExample() {
    Mono<String> monoString = Mono.just("Hello, Blocking!");
    return monoString.block(); // 阻塞等待 Mono 完成（不推荐在生产代码中使用）
}

⚠️ 警告：block() 会强制同步等待 Mono 完成，可能影响性能，仅适用于测试或命令行工具。

3. 使用 subscribe()（不推荐）

如果只是想触发 Mono 的执行（例如记录日志），可以 subscribe()，但 不会返回结果：

@GetMapping("/subscribe-example")
public void getSubscribeExample() {
    Mono<String> monoString = Mono.just("Hello, Subscribe!");
    monoString.subscribe(result -> System.out.println("Received: " + result));
    // 注意：这里没有返回值，适用于异步处理
}

适用场景：日志记录、异步通知等，但 不能用于 HTTP 响应。

4. 结合 flatMap 或 map 处理

如果需要对 Mono 中的字符串进行处理后再返回：

@GetMapping("/process-example")
public Mono<String> getProcessExample() {
    Mono<String> monoString = Mono.just("Hello, WebFlux!");
    return monoString.map(s -> s.toUpperCase()); // 转换为大写后返回
}

访问 /process-example 会返回 HELLO, WEBFLUX!。

5. 从 Mono<String> 提取值并返回给前端

如果 Mono<String> 是某个异步操作的结果（例如从数据库或远程服务获取），可以直接返回 Mono，Spring 会自动处理：

@GetMapping("/async-example")
public Mono<String> getAsyncExample() {
    return someAsyncService.fetchData(); // 返回 Mono<String>
}

总结

最佳实践

• 在 WebFlux 控制器中，直接返回 Mono<String>，让 Spring 处理订阅和响应。
• 避免 block()，除非在测试或非响应式上下文中。
• 使用 map/flatMap 处理 Mono 中的数据。

这样既能保持响应式编程的优势，又能正确返回数据给前端。