骆驼节流

Question

我在努力弄清楚骆驼的节流概念。我已经看过骆驼的路由策略了，但这适用于大量的飞行交流。

我的路线如下：

routeBuilders.add(new RouteBuilder() {
            @Override
            public void configure() throws Exception {
                from("rabbitmq://127.0.0.1:5672/abc?queue=a&username=XXX&password=XXX&autoAck=false&durable=true&exchangeType=direct&autoDelete=false")
                .to("rabbitmq://127.0.0.1:5672/abc?queue=b&username=XXX&password=XXX&autoAck=false&durable=true&exchangeType=direct&autoDelete=false");
            }
        });

现在我的用例是，我想在这些路由之间传输例如2000条消息，我知道可以通过.throttle(2000)来完成。但是，我不得不决定，当下一个2000条信息被发送时，我将如何控制它。只有当接收方队列变为空时，我才想路由下2000条消息。

例如，消息正在从queue a路由到b。假设2k消息已被成功路由，现在我希望挂起我的路由，以便在队列b变为空之前它不会传输更多的消息(假设有一个消费者正在从b队列中提取消息)

如对此有任何帮助或指导，将不胜感激。

Answer 1

您可以为此使用路由策略。您在该路由策略中实现逻辑以暂停/恢复路由以节流该路由。

我们有一个开箱即用的策略，使用Camel中的信息数量作为它的度量标准。但是，如果队列是否为空，则应该添加检查该队列的逻辑。

路由策略的文档在这里。

• http://camel.apache.org/routepolicy

以及飞行节流器的代码

• https://github.com/apache/camel/blob/master/camel-core/src/main/java/org/apache/camel/impl/ThrottlingInflightRoutePolicy.java