Spring Boot WebFlux 中实现数据库实时轮询并持续推送最新记录-java教程

本文详解如何在 spring webflux 中使用 `flux.interval` 定期触发异步数据库查询，通过 `flatmap` 正确组合 `mono`（如查询最新文档）与 `flux`，实现每秒拉取并发布数据库中最新记录的描述字段。

在响应式编程中，不能将阻塞式思维套用于异步流操作。例如，直接在 map() 中调用返回 Mono 的仓库方法（如 findLastDocument()），会导致编译错误或运行时异常——因为 map 仅支持同步转换，而 Mono 是一个异步容器，其值需通过响应式链式操作（如 flatMap）进行“解包”与后续处理。

正确做法是：使用 flatMap 将每个定时信号（由 Flux.interval 发出）映射为一个新的异步查询流。flatMap 会订阅每个 Mono 并将其扁平化为 Flux 元素，从而保持整个流的响应式特性。

以下是修正后的控制器代码：

@RestController
public class WebFluxController {

    @Autowired
    private ReactiveDocumentRepository reactiveDocumentRepository;

    @CrossOrigin
    @GetMapping(value = "/documents", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
    public Flux getDocuments() {
        return Flux.interval(Duration.ofSeconds(1))
                .onBackpressureLatest() // 防止下游消费慢导致事件积压
                .flatMap(x -> reactiveDocumentRepository.findLastDocument()
                        .map(document -> "document-" + document.getDescription())
                        .defaultIfEmpty("document-NO_DATA")); // 处理查无结果场景
    }
}

? 关键说明：