Spring Webflux反应式链断裂致save操作未执行问题排查

问题代码 #

return getPlayerOrdersForAuction(order.getPlayerAddress(), order.getAuctionID())
        .map(el -> el.getWeight())
        .reduce((long) 0,(a,b) -> a+b)
        .doOnNext(sum -> validateOrder(order,sum)) // side effect
        .flatMap(el -> {
           return orderRepository.save(order); 
        });

问题解答 #

1. 反应式链被破坏的原因 #

核心问题出在reduce操作：当getPlayerOrdersForAuction返回的Flux为空（无任何订单数据）时，reduce会返回空的Mono。反应式流是元素驱动的，空Mono不会触发后续的doOnNext和flatMap操作——因为没有元素流经这个链，后续依赖元素存在的操作自然不会执行。

简单来说：如果没有找到任何玩家订单，reduce阶段就没有生成求和结果，流到这里直接终止，后面的save操作根本没机会被调用。

2. 存在的概念误解 #

• 对reduce的认知偏差：误以为reduce一定会返回初始值，但实际上只有当源Flux至少包含一个元素时，reduce才会从初始值开始累加；若源为空，reduce返回空Mono，不会输出初始值。
• 忽略反应式流的终止逻辑：反应式流一旦中途没有元素产生（比如空Mono），后续所有依赖元素的操作都会被跳过，整个流直接结束。
• 对副作用操作的误用：doOnNext是副作用操作，仅在有元素流经时执行，它无法改变流的状态，也不能让空流产生元素。

3. 为什么save()未被纳入主反应流 #

因为上游的reduce返回了空Mono，没有元素传递到flatMap。flatMap的作用是将流中的每个元素转换为新的Mono/Publisher，但如果上游没有元素，flatMap根本不会被触发，自然不会执行orderRepository.save(order)，也就不会把这个Mono加入主反应流。

修复方案 #

要确保即使源Flux为空，后续操作也能执行，可以用reduceWith（或reduce配合defaultIfEmpty）保证流始终有元素输出：

// 方案1：使用reduceWith
return getPlayerOrdersForAuction(order.getPlayerAddress(), order.getAuctionID())
        .map(el -> el.getWeight())
        .reduceWith(() -> 0L, (a,b) -> a+b) // 空流时返回初始值0
        .doOnNext(sum -> validateOrder(order,sum))
        .flatMap(el -> orderRepository.save(order));

// 方案2：reduce + defaultIfEmpty
return getPlayerOrdersForAuction(order.getPlayerAddress(), order.getAuctionID())
        .map(el -> el.getWeight())
        .reduce(0L, (a,b) -> a+b)
        .defaultIfEmpty(0L) // 为空时兜底返回0
        .doOnNext(sum -> validateOrder(order,sum))
        .flatMap(el -> orderRepository.save(order));

内容的提问来源于stack exchange，提问作者Joseph hans Bou Assaf