Spring WebFlux REST API - 消息驱动答案

【问题标题】：Spring WebFlux REST API - Message DrivenSpring WebFlux REST API - 消息驱动
【发布时间】：2019-09-17 08:19:20
【问题描述】：

我最近一直在玩 Spring Webflux，它看起来非常有用和高效。此外，阅读反应式系统，似乎此类系统的定义特征之一是它们是消息驱动的。

在网上看到这个帖子：https://www.captechconsulting.com/blogs/annotation-driven-reactive-web-apis-with-spring-webflux

这篇文章还提到，

Spring WebFlux 包含对响应式 HTTP Rest API 的支持， WebSocket 应用程序和服务器发送的事件。 Spring WebFlux 是响应迅速、有弹性、可扩展和消息驱动。

我的问题是，如果编写一个简单的 REST API，就像帖子描述的那样，执行由 MongoDB 支持并使用 spring-boot-starter-data-mongodb-reactive 的 CRUD 操作，可以我调用我的 API 服务消息驱动？我还可以添加一个Webclient 来与一些下游服务对话。

在 REST API 的上下文中驱动消息是否有意义？

【问题讨论】：

我确实认为，如果我们将 REST 服务调用和来自数据库的结果视为“事件”数据流，并且我的 API 在将最终结果返回给用户时会响应这些调用，那么也许这个系统符合消息/事件驱动的条件？

标签： rest spring-webflux reactor-netty

【解决方案1】：

不，您的应用程序不是消息驱动的，而是您的应用程序是Reactive。反应式应用程序是事件驱动的、非阻塞的、可扩展的、弹性的和弹性的。它支持发布者和订阅者机制，意味着发布者和订阅者之间正在进行异步通信。它支持两种类型的Publishers

Mono：我们只生产一件商品时使用。
Flux：当我们生产多个项目时使用。

要使您的应用程序消息驱动，您需要使用任何消息代理，例如Kafka、RabbitMQ 等。

【讨论】：