javascript - 使用 Kafka 主题后发送 HTTP 响应

Question

我目前正在编写一个包含大量微服务的 Web 应用程序。我目前正在探索如何在所有这些服务之间正确通信，并且我决定坚持使用消息总线，或更具体地说是 Apache Kafka。

但是，我有一些问题，我不确定如何从概念上解决。我使用 API 网关服务作为应用程序的主要入口。它充当将操作转发到适用的微服务的主要代理。考虑以下场景:

1. 用户向 API 网关发送包含一些信息的 POST 请求。
2. 网关生成一条新消息并将其发布到 Kafka 主题。
3. 订阅的微服务获取主题中的消息并处理数据。

那么，我现在应该如何从网关响应客户端？如果我需要来自该微服务的一些数据怎么办？感觉 HTTP 请求可能会超时。我应该在客户端和 API 网关之间坚持使用 Websocket 吗？

而且，如果客户端发送 GET 请求来获取一些数据，我该如何使用 Kafka 来处理该请求？

谢谢。

Answer 1

您可以选择在网关中创建更多端点吗？

我会让 POST 端点专门用于向 Kafka 队列生成消息，其他微服务将使用该消息。作为从端点返回的对象，它将包含某种引用或 ID 来获取消息的状态。

并在网关中创建另一个 GET 端点，您可以在其中使用创建消息时获得的消息的引用来检索消息的状态。