Reactive Java中Mono用法困惑：MongoDB删除操作为何有时失效

我正在学习Reactive Java，尝试使用嵌入式MongoDB执行电影信息删除操作。我尝试了多种根据ID删除的方法，部分有效部分无效，怀疑遗漏了响应式编程的基础概念。

示例1：删除有效 #

return moviesInfoService.deleteMovieInfoById(id)
                .then(Mono.just(ResponseEntity.noContent().build()));

原因解析 #

响应式编程核心特性之一是惰性执行：只有当订阅者（这里是Spring Web框架，会自动订阅接口返回的Mono）触发订阅时，定义的操作才会实际运行。

• deleteMovieInfoById(id)返回Mono<Void>，代表一个“执行删除操作、完成后无数据输出”的响应式序列。
• .then(Mono.just(...))操作符会等待上游的删除操作完成，然后发射后续的响应实体。
  整个序列被框架订阅后，删除逻辑会被执行，完成后返回204响应，因此有效。

示例2：删除无效 #

moviesInfoService.deleteMovieInfoById(id);
return Mono.just(ResponseEntity.noContent().build());

原因解析 #

这里仅调用了deleteMovieInfoById(id)，但没有将其纳入被订阅的响应式序列中。响应式操作是惰性的，没有订阅就不会执行任何实际逻辑。直接返回的Mono.just(...)被框架订阅后，只会返回204响应，删除操作根本没被触发，因此无效。

示例3：删除无效 #

Mono<Void> result = moviesInfoService.deleteMovieInfoById(id);
Mono<ResponseEntity> result2 = result.map(m -> ResponseEntity.noContent().build());
return result2;

原因解析 #

• Mono<Void>是特殊的响应式序列：它只会发送完成信号，不会发射任何实际数据。
• map操作符的作用是转换序列中发射的数据，但Mono<Void>没有数据可供转换，因此map中的逻辑永远不会执行。
  虽然返回的result2被订阅时，上游的删除操作会被执行，但result2无法生成预期的ResponseEntity，导致接口响应不符合预期，你可能会误以为删除未执行。正确的做法是用.then()替代map来等待完成信号。

示例4：删除有效 #

return moviesInfoService 
                .getMovieInfoById(id)
                .flatMap(fm -> moviesInfoService.deleteMovieInfoById(fm.getMovieInfoId()))
                .then(Mono.just(ResponseEntity.noContent().build()));

原因解析 #

• getMovieInfoById(id)返回Mono<MovieInfo>，当这个序列成功发射电影数据时，flatMap会触发后续的deleteMovieInfoById操作，将删除的Mono<Void>合并到主序列中。
• .then(...)同样等待删除操作完成后返回响应实体。
  整个序列被框架订阅后，查询、删除操作会按顺序执行，完成后返回正确响应，因此有效。

关键响应式概念总结 #

1. 惰性执行：所有响应式操作（如delete、get）只有在被订阅时才会实际运行，必须确保操作被包含在最终返回的序列中。
2. 操作符匹配：针对Mono<Void>这类无数据输出的序列，使用then()来等待完成信号；map仅适用于有数据发射的序列，用来转换数据。
3. 序列串联：使用flatMap、then等操作符串联操作，确保上游操作完成后再执行下游逻辑，同时保证整个链路被订阅。

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