如何在Kotlin中非阻塞提取Mono<String>内容并赋值给变量？

首先要明确：在反应式编程模型中，无法同步且非阻塞地直接将Mono内部的String值赋值给一个同步变量。因为Mono的结果是异步产生的，同步返回String的方法必然需要等待异步操作完成，这就会导致阻塞。如果要保持非阻塞，必须遵循反应式的异步处理流程。

下面是两种正确的非阻塞处理方案：

方案一：延续反应式调用链 #

修改consumeFoo()使其返回Mono<String>，让调用方通过订阅来异步获取结果：

fun foo(): Mono<String> {
    return Mono.just("Hello")
}

fun consumeFoo(): Mono<String> {
    // 直接返回Mono，不阻塞线程，让后续调用方处理异步结果
    return foo()
}

// 非阻塞的调用示例
fun main() {
    consumeFoo()
        .subscribe { result ->
            // 在这里异步处理拿到的结果，比如执行业务逻辑
            println("获取到结果：$result")
        }
}

方案二：通过订阅回调异步处理结果 #

如果不需要传递Mono，而是直接在consumeFoo()内部处理结果，可通过subscribe()方法注册回调，在回调中异步使用结果：

fun foo(): Mono<String> {
    return Mono.just("Hello")
}

fun consumeFoo() {
    foo()
        .subscribe { result ->
            // 异步获取到结果后执行操作，不会阻塞当前线程
            println("处理结果：$result")
        }
}

注意：同步返回String必然阻塞 #

如果你的consumeFoo()必须返回String类型，那不存在非阻塞的实现方式。此时只能使用block()方法强制阻塞线程直到Mono完成，但这违背了非阻塞的要求，不推荐在反应式场景中使用：

// 阻塞实现，非必要不要用
fun consumeFoo(): String {
    return foo().block()!! // block()会阻塞当前线程直到Mono产生结果
}

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