2

我目前正在Vertx CircuitBreaker尝试重试请求事件总线。基于ReplyException.ReplyFailure我想跳过或避免重试。

例如，当事件总线响应时我不想重试ReplyFailure.RECIPIENT_FAILURE，因为这种错误不是应用程序错误，而是逻辑验证失败。

下面是我的代码，

    CircuitBreaker breaker = CircuitBreaker.create("my-circuit-breaker", vertx,
                    new CircuitBreakerOptions()
                            .setMaxFailures(2) 
                            .setTimeout(5 * 1000) 
                            .setFallbackOnFailure(true) 
                            .setResetTimeout(5000) 
                            .setMaxRetries(2)
).retryPolicy(retryCount -> retryCount * 5000L);

使用如下断路器，

breaker.execute(promise -> {  
            vertx.eventBus().<JsonObject>request(address, jsonObject, deliveryOptions)
                    .onComplete(event -> {

基于事件我不想断路器放弃重试。我尝试检查事件状态，然后调用 promise.complete 方法并出现异常，尽管断路器将其识别为失败并开始重试。如何告诉断路器停止重试？

我认为断路器对象可能有

  1. 一种关闭它的方法
  2. 停止重试的方法
  3. 一种增加失败的方法

更新 1 ---------------------

我自己实现了重试部分，为了使操作超时，我可以设置计时器并检查操作的状态，如果操作没有完成，我可以启动重试逻辑。但我不知道如何在重试下一个操作之前取消操作，例如如何取消事件总线请求？

更新 2 -----------------

Vertx 断路器也没有处理超时操作。在重试进行时，我可以看到来自事件总线的较旧响应。如果处理不当，这可能会混淆应用程序逻辑。

4

1 回答 1

1

Vert.x Circuit Breaker API 当前不支持此功能。这里有一个未解决的问题。还有一个 PR 试图修复它，但它已经存在一年了。不知道为什么它从未得到审查。

于 2021-05-21T15:55:22.393 回答