本文详解如何在 spring webflux 中正确构建响应式流，通过定时轮询（如每秒一次）异步查询数据库并发布最新记录，重点解决 `mono` 与 `flux` 的嵌套组合问题，避免阻塞和类型不匹配错误。
在响应式编程中，不能将阻塞式思维直接迁移到 Mono/Flux 上。例如，reactiveDocumentRepository.findLastDocument() 返回的是 Mono，它代表一个异步、延迟计算、可能为空的单值响应式序列；而 Flux.interval(…) 生成的是一个周期性触发的 Flux。若错误地使用 .map() 尝试将 Mono “塞进”字符串拼接（如 “document-” + mono.map(…)），会导致编译失败或运行时返回 Mono.toString() 这类无意义字符串——因为 map 是同步转换函数，无法“等待” Mono 发出数据。
✅ 正确做法是使用 flatMap：它专为将每个上游元素（这里是 Long）映射为一个新的响应式序列（Mono）并自动展平（flatten）为 Flux 而设计。flatMap 会订阅每个 Mono，等待其发出数据后合并到最终流中，真正实现“每秒查一次库、取最新文档描述、发一条消息”的语义。
以下是修正后的完整控制器示例：
