微服务异步通信断路器答案

【问题标题】：Microservices async communication circuit breaker微服务异步通信断路器
【发布时间】：2021-09-19 05:58:43
【问题描述】：

我有 2 个使用 spring boot 运行的服务，我有以下情况：

服务 A（N 个实例）-> 队列（多个实例）-> 服务 B（N 个实例）

流量正在增加，我们注意到活动需要花费大量时间排队。我们需要更快地处理事件。每个事件的负载都很小，这个解决方案已经工作了几年，几年前他们认为队列是个好主意，但现在我遇到了这个性能问题。

这个调用应该是异步的，并且还应该实现一个断路器以避免在 B 出现故障时丢失消息。如果 B 出现故障，我可以使用队列来保存消息，一旦 B 运行并再次从队列中提取消息。

我有两个问题：

谢谢

【问题讨论】：

您的解决方案将如何帮助We need to process events faster.？也许您需要研究服务 b 的性能/扩展性？
我们在服务和队列中有一些监视器，我们看到消息大部分时间都在队列中。当我们增加队列中的实例时，一切都会更好
这意味着服务 B 可以快速处理所有内容，因为一旦我们在队列中增加实例，就无需在 B 中添加更多实例
您可以使用消费者组来扩展和消费消息。Link::activemq.apache.org/message-groups
要求“其他可能更好的方法”将产生讨论和基于意见的答案，而不是基于事实的答案。这是 Stack Overflow 上的题外话。此外，您在这里问了多个问题，这也是题外话。

【解决方案1】：

提问

是的，有可能，我假设您正在使用 spring boot，因为您在标签中提到了 java，所以有一种称为 RetryTemplate 的机制，您也可以将其用于异步调用，您可以在此处找到更多详细信息 -> https://www.openprogrammer.info/2019/09/03/using-spring-boot-async-with-retry/
我会说有更好的方法，当你在这里说队列时，你实现了什么？喜欢它是 LIFO 还是 AWS SQS 之类的东西？如果是这种情况，那么您可以尝试寻找基于主题的队列机制，例如 apache kafka

【讨论】：

【解决方案2】：

如果瓶颈在队列中，我认为您不应该将其删除。您可以尝试使用 SQS 或其他基于云的队列，它们没有这个问题。

如果服务 A 直接调用服务 B，而服务 B 宕机了怎么办？请求将丢失。使用队列，消息将一直保留在那里，直到服务 B 恢复。

断路器用于避免请求使失败的服务不堪重负（以使其恢复）。因此，当它启动时，那里会出现明显的数据丢失。

【讨论】：