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

Question

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

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

以上 link 包含 SSE 和事件源的示例。创建流对象是为了创建 Flux 流。

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

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

我应该怎么做？ 参考文献、links 和示例会很棒。

Answer 1

参考以下，这里使用activemq，也可以使用RabbitMQ。