如何解决异步微服务的断路器..?
有一个 ActiveMQ 队列 (QueueA
)。服务 (MyService
) 订阅消息、处理消息并将消息发送到另一个 ActiveMQ 队列 (QueueB
)。
QueueA -> MyService -> QueueB
考虑在 QueueA
中有数千条消息的场景。同时,QueueB
已关闭。如果一定数量的消息(比如 100 条)在向 QueueB
发送消息时连续失败,我想停止处理。它应该在特定时间段内测试滚动窗口(例如,100 条连续消息在 60 秒内失败)并从 QueueA
停止消费。然后它应该通过再发送一条消息来测试服务是否在 15 分钟左右后启动。如果仍然失败,再次从 QueueA
停止消费 15 分钟。
现在的情况是所有消息都出错了,我们必须再次重新处理每条消息。有一个恢复机制,但由于当前架构的限制,恢复机制正在过载。
这有什么模式吗?它是同一个断路器吗(我在同步上下文中知道它)。如果是这样,不确定Java / Spring Boot / Apache Camel中是否有解决方案。是的,这就是我们目前使用的技术堆栈。即使您可能不了解该特定技术平台,任何针对该模式的指南也会有所帮助。
我还在 StackOverflow 中阅读了以下问题。
Is circuit breaker pattern applicable for asynchronous requests also?
感谢并感谢您花时间帮助我。
解决方法
查看基于 ThrottlingExceptionRoutePolicy
的 CircuitBreakerLoadBalancer
类型的 Camel RoutePolicy。
使用此策略应该允许您在电路处于打开状态时停止从端点消费(与标准电路行为进行比较:绕过服务调用,并回退到另一个响应)。
@Bean
public ThrottlingExceptionRoutePolicy myCustomPolicy() {
// Important: do not open circuit for this kind of exceptions
List<Class<?>> handledExceptions = Arrays.asList(MyException.class);
return new ThrottlingExceptionRoutePolicy(failureThreshold,failureWindow,halfOpenAfter,handledExceptions);
}
from("jms:queue:QueueA")
.routePolicy(myCustomPolicy)
.to("mock:MyService")
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。