Spring Boot Webflux reactive api

Question

我希望得到一些关于我正在构建的一个小型Spring Boot应用程序的提示。

@GetMapping(produces = MediaType.APPLICATION_STREAM_JSON_VALUE)
public Flux<Event> getApis() {
    return … 
}

我需要一些提示的地方是--我如何将这个API的每个消费者视为一个新的订阅者--并在我让他们进入时向他们发布事件？实现一个完整的pub-sub模式，跟踪订阅者以及他们何时停止使用endpoint，这当然是可能的。但我想知道是否有一个更简单的解决方案使用一些Springs的反应功能。我输入的事件不需要存储--只需转发给在事件发生时订阅的每个消费者。

谢谢

Answer 1

在从控制器处理程序返回流量 之前，请确保始终返回：

• 相同的实例，例如作为属性保存在控制器中
• 对其应用flux.share()，以便所有订阅服务器共享相同的事件热流