蹲在骆驼里

Question

我正在骆驼中开发一种机制，它将从一个可以是真或假的标志中为消息选择一个endpoint。这是一种节流机制，在我的上游通道被洪水淹没的情况下，它将把消息重新路由到批量摄取endpoint（发送到HDFS）。

最终，我的路线是这样的：

from("queue:myqueue").bean("messageParser")
    .dynamicRoute(bean(ThrottleHelper.class, 'buildEndpoint'));

from('direct:regular').to('hbase');

from('direct:throttle').to('hdfs');

我的ThrottleHelper类的buildEndpoint方法如下所示：

public static String buildEndpoint() {
   synchronized(shouldThrottle) {
      if(shouldThrottle)
         return "direct:throttle";
      else
         return "direct:regular"
    }
} 

目前，我在类上有一个名为checkStatus（）的方法；设置shouldThrottle（静态变量）。checkStatus（）每分钟在Camel quartz计时器上运行一次。

我注意到一些奇怪的行为，我想我可能误用了这个模式。从对Camel模式实现的进一步搜索来看，在消息遍历返回的每个endpoint之后，似乎会调用buildEndpoint（）。这是真的吗？或者，我可以期待路径在转到“direct:throttle”或“direct:regular”后终止吗？

从我在网上收集的信息来看，我的方法真的应该是这样吗？

public static String buildEndpoint(Message message) {
   if(message.getHeader('throttled') != null)
      return null;
   else
      message.setHeader('throttled', true);

   synchronized(shouldThrottle) {
      if(shouldThrottle)
         return "direct:throttle";
      else
         return "direct:regular"
    }
} 

谢谢

Answer 1

正如程序员Dan所指出的，动态路由器用于通过多个endpoint路由消息，因此需要显式返回null来指示路由的结束。

如果您只想使用表达式或bean方法选择单个endpoint，最好使用动态收件人列表（cfr.http://camel.apache.org/recipient-list.html）。如果您在路由生成器中使用。收件人列表（）而不是。动态路由（），您的第一个BuildEndpoint方法实现将正常工作。

Answer 2

从官方的留档来看，是的，您的第二个构造更接近正确的用法。基本上，动态路由器可以用于将消息路由到多个终结点，而不仅仅是立即终止的单个终结点。要告诉动态路由器停止将消息路由到另一个终结点，您的bean必须返回null，就像您在最终代码片段中写的那样，以指示此消息的路由已经完成。