是否可以在 Go 中创建一个既使用消息流(来自 Kafka)又读取 REST API 请求的服务?
问题内容
我最近读了一篇文章《大规模微服务之间共享数据》
这张图片是关于异步连接的。
如果我没记错的话,这张图中的订单页面服务似乎能够读取来自 Kafka 的消息流,并且还可以读取来自前端应用程序的 REST API 请求。
所以,我想知道是否可以编写一个可以同时完成这两个任务的服务:
- 读取来自 Kafka 的消息流
- 读取 REST API 请求
仅在 1 个服务中,例如在 Go 中。
这是否是一个好主意?
解决方法
是的,您绝对可以编写一个从 Kafka 消费并公开 REST 端点的 Go 服务。然而,这不是一个理想的设计决策。
基于Kafka的流媒体系统允许生产者和消费者之间进行异步通信。然而,基于REST API的系统在调用者和被调用者之间进行同步通信。
同步和同步模式通信之间的可用性保证是不同的。基于 Kafka 流的系统将具有与 REST API 不同的可用性保证。在流式系统中,我们关注的是消息处理的吞吐量,而在端到端的同步通信中,延迟是主要关注点(你不想让调用者等待很长时间才能得到结果) .
如果我们将这两种类型的系统放在一个服务中,就很难了解该服务的可用性。此外,服务的异步部分或同步部分可能会在另一方的嘈杂邻居中发挥作用,从而使服务不可用。
因此,一般来说,建议将基于 REST 的 API 和 Kafka 流作为两个独立的服务。
以上就是是否可以在 Go 中创建一个既使用消息流(来自 Kafka)又读取 REST API 请求的服务?的详细内容,更多请关注编程网其它相关文章!
免责声明:
① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。
② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341