Apache骆驼断路器最初处于打开状态

Question

我想试试阿帕奇骆驼断路器(http://camel.apache.org/load-balancer.html)模式。它不像我想的那样。

我的路线是这样的

from("direct:foo")
        .loadBalance()
        .circuitBreaker(1, 5000, HustException.class).to("direct:pleaseHoldTheLine")
        .to("direct:bar");

from("direct:bar")
        .process(exchange -> {
            Integer value = exchange.getIn().getBody(Integer.class);
            System.out.println("[BAR] " + value);
            if (value.equals(12)) {
                throw new HustException();
            }
        });

from("direct:pleaseHoldTheLine")
        .process(exchange -> {
            Integer value = exchange.getIn().getBody(Integer.class);
            System.out.println("[PLEASE_HOLD_THE_LINE] " + value);
        });

主应用程序每秒向foo路由发送整数值为0到99的消息。

在使用12的消息时，foo路由抛出一个执行命令，请保持线路路由应该介入。5秒钟后，foo路线再次被询问，如果没有异常发生，foo路线将再次被询问。

[PLEASE_HOLD_THE_LINE] 0
[PLEASE_HOLD_THE_LINE] 1
[PLEASE_HOLD_THE_LINE] 2
[PLEASE_HOLD_THE_LINE] 3
[PLEASE_HOLD_THE_LINE] 4
[PLEASE_HOLD_THE_LINE] 5
[PLEASE_HOLD_THE_LINE] 6
[PLEASE_HOLD_THE_LINE] 7
[PLEASE_HOLD_THE_LINE] 8
[PLEASE_HOLD_THE_LINE] 9
[PLEASE_HOLD_THE_LINE] 10
[PLEASE_HOLD_THE_LINE] 11
[PLEASE_HOLD_THE_LINE] 12
[PLEASE_HOLD_THE_LINE] 13
[PLEASE_HOLD_THE_LINE] 14
...

休伯特

Answer 1

Apache Camel断路器负载平衡器不会重定向流，它只传递或拒绝消息。您在问题中使用的路线将始终向直接：请保留路线“路线发送消息。

如果删除。从“direct:foo”路由到（“direct:pleseholdtheline”），则断路器应按预期运行，并在收到消息12后拒绝消息。

要停止DefaultErrorHandler处理消息，您应该使用errorHandler（noErrorHandler（））禁用路由的所有错误处理，或者可以使用全局OneException（HustException.class）指定要跳过的特定异常。续（真） 语句。

您可以使用故障切换负载平衡器重定向流，但我不清楚是否可以将故障切换和断路器组合起来以获得所需的行为。

把这一切放在一起：

onException(HustException.class).continued(true);
from("direct:foo")
        .loadBalance()
        .circuitBreaker(1, 5000, HustException.class)
        .to("direct:bar");