Mono无法按预期发射值，异步执行顺序异常的问题求助

问题原因 #

1. 异步非阻塞执行特性：Reactor框架的subscribe()方法是异步触发的，主线程执行到该方法时只会完成订阅动作，不会等待流内部的逻辑执行完毕。所以代码中println("Checkpoint 3")会先于subscribe回调里的println("Checkpoint 2")执行，导致initValue还未被赋值就进入后续的callAnotherService调用。
2. block()操作被禁止：在Reactor的IO线程（如reactor-http-nio-8）中，框架严格禁止使用block()/blockFirst()这类阻塞方法。这类线程是为高吞吐量的非阻塞任务设计的，阻塞会破坏异步模型，导致线程池耗尽、性能急剧下降。

解决方案 #

遵循Reactor的链式编程范式，不要依赖外部可变变量传递异步值，而是将所有后续操作嵌入反应式流的生命周期中，保证执行顺序和值的正确传递。

基础场景代码示例 #

// 构建获取初始化值的反应式流
val initValueMono = Mono.fromCallable { getValue() }
    // 过滤非空值，若为空则切换到服务调用流
    .filter { it != null }
    .switchIfEmpty(service.getValFromService().map { it.value })

// 链式执行所有逻辑，保证顺序
initValueMono
    .doOnSubscribe { println("Checkpoint 1") } // 订阅时触发
    .doOnNext { println("Checkpoint 2") }     // 获取到值时触发
    .subscribe { value ->
        println("Checkpoint 3")
        callAnotherService(value) // 此时value已正确赋值
    }

WebFlux环境适配（如Controller/Handler） #

如果是在WebFlux的请求处理流程中，不要手动调用subscribe()，而是将Mono返回给框架，由框架负责订阅执行，避免线程问题：

fun processRequest(): Mono<Void> {
    val initValueMono = Mono.fromCallable { getValue() }
        .filter { it != null }
        .switchIfEmpty(service.getValFromService().map { it.value })

    return initValueMono
        .doOnSubscribe { println("Checkpoint 1") }
        .doOnNext { println("Checkpoint 2") }
        .doOnNext { println("Checkpoint 3") }
        // 若callAnotherService返回Mono，用flatMap串联
        .flatMap { value -> callAnotherServiceReturningMono(value) }
        .then() // 转换为Mono<Void>表示请求处理完成
}

关键注意点 #

• 避免使用外部可变变量（如原代码中的var initValue）接收异步流的值，这是反应式编程的反模式，会引发线程安全和执行顺序问题。
• 所有依赖异步结果的操作必须嵌入到反应式流的操作链中，通过doOnNext、flatMap等操作符传递值。

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