服务器使用 Spring WebFlux、EventSource 和 RabbitMQ 发送事件

Question

我想为我的网站创建实时通知。

参考链接：http://sinhamohit.com/writing/spring-boot-reactive-sse

上面的链接包含 SSE 和事件源的示例。创建对象流以创建通量流。

就我而言，我想创建服务器发送的事件并将它们发送到 RabbitMQ 服务器，其余控制器应该能够侦听消息队列并接收消息。

现在我能够接收消息，但我不确定如何将它们转换为 Flux 并将流发送到 rest URL。

我应该怎么做？ 参考，链接和示例会很棒。

Answer 1

请参考以下链接，这里使用了 activemq，但您也可以使用 RabbitMQ。