我希望得到一些有关正在构建的小型Spring Boot应用程序的提示。
应用程序本身的功能应类似于消耗Kafka主题（或任何发布/订阅模式）。但是，我没有像Kafka这样的工具可用，因此都应在应用程序本身中完成。
该应用程序将具有一个RestController，该控制器应在事件发生时公开“热”事件流。
@GetMapping(produces = MediaType.APPLICATION_STREAM_JSON_VALUE)
public Flux<Event> getApis() {
return …
}
该应用程序本身将消耗来自另一个应用程序的事件流。
我需要一些提示的地方-如何将这个API的每个使用者视为新订阅者-并在收到它们时向他们发布事件？当然，可以实现一个完整的pub-sub模式来跟踪订户以及订户何时停止消费端点。但是我想知道是否有使用Springs Reactive功能的简单解决方案。我参加的活动不需要存储-只需转发给每个在活动发生时订阅的用户即可。
谢谢
Flux<Event>从控制器处理程序返回您的信息之前，请确保您始终在返回：
Flux.share()，以便所有订户共享相同的事件热流本文收集自互联网，转载请注明来源。
如有侵权，请联系 [email protected] 删除。
我来说两句