如何从 REST 通信到消息队列

有一些方法可以解决这种情况。

您可以为每个客户端请求创建主题并等待另一端的回复，例如，DriverService 将读取请求消息，获取您的所有数据并将其发布到您的客户端请求主题。一旦您使用响应消息，您就会销毁该主题。

但是在请求-响应交互中删除“临时”主题可能需要很长时间（如果没有配置避免这种情况，例如 delete.topic.enable 属性），您需要监视可能的主题过度增长。

Websocket 是另一种可能的解决方案。您的客户端将开始侦听先前与您的服务器达成一致的特定主题，然后在特定超时时间内您将等待响应，当您的 DriverService 将发布到该特定套接字通道时。

Spring Boot 为您提供了很好的 Kafka 和 Websockets 入门。如果您期望有大量交易，我会采用混合策略，使用 Kafka 帮助我的后端扩展和处理所有交易，然后通过 Websocket 响应客户端。