使用zipWhen操作符时Mono未发射元素问题（Java/Spring/Reactor）

你的问题出在zipWhen操作符的特性上，咱们一步步拆解：

核心原因 #

zipWhen属于Reactor中的zip类操作符，它的工作逻辑是：

1. 先等待第一个Mono（这里是userService.getUser(username)）发射一个元素
2. 然后用这个元素调用你提供的函数（也就是this::processUser）得到第二个Mono
3. 必须等待第二个Mono也发射一个元素，才会把两个元素组合成Tuple2并向下游发射

但你的processUser方法返回的是Mono.empty()——这个Mono只会正常完成，不会发射任何元素。这就导致zipWhen永远等不到第二个元素，自然也就不会向下游发射Tuple2，后续的map(Tuple2::getT1)也没有元素可以处理，最终整个doSomething2返回的Mono只会完成，却没有任何User元素输出。

而doSomething1没有使用zipWhen，只要userService.getUser(username)成功发射User元素，就会直接向下游传递，所以能拿到预期结果。

解决方案 #

根据你的需求，如果你只是想在获取到User后执行processUser这个操作（不需要它返回的元素），应该用flatMap或者副作用类操作符，而不是zipWhen：

方案1：用flatMap（保留原User元素，等待processUser完成） #

Mono<User> doSomething2(String username) {
    return userService
                .getUser(username)
                .flatMap(user -> processUser(user).thenReturn(user)) // 执行processUser后返回原User
                .doOnError(error -> LOG.error(error.getMessage(), error));
}

这个方式会等待processUser执行完成后，再把原User元素传递下去，同时如果processUser出错，错误会被主流程的doOnError捕获。

方案2：用doOnNext（执行副作用，不阻塞原元素传递） #

如果processUser是不需要等待完成的副作用操作（比如异步记录日志），可以用这个方式：

Mono<User> doSomething2(String username) {
    return userService
                .getUser(username)
                .doOnNext(this::processUser) // 触发副作用，原元素直接向下传递
                .doOnError(error -> LOG.error(error.getMessage(), error));
}

注意：这种方式是"fire-and-forget"的，如果processUser出错，错误不会传递到主流程中，需要单独处理processUser的错误。

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