阿帕奇骆驼：分路器，CBR还是动态路由器？

Question

我有以下的POJO:

public class MyPOJO {
    private Fizz fizz;
    private Buzz buzz;

    // ctor, getters, setters, etc.
}

和下面的路线(Spring XML):

<route id="myroute">
    <from uri="timer://runOnce?repeatCount=1&amp;delay=10" />

    <to uri="bean:myPOJOFactory?method=newMyPOJO" />

    <!-- Not sure what to do here -->
    <!-- MyPOJO#Fizz should get routed to direct:fizzFarm. -->
    <!-- MyPOJO#Buzz should get routed to direct:buzzFarm. -->
</route>

其中myPOJOFactory是：

public class MyPOJOFactory {
    public MyPOJO newMyPOJO(Exchange exchange) {
        Fizz fizz = new Fizz(true, 3);
        Buzz buzz = new Buzz("awesome");

        MyPOJO pojo = new MyPOJO(fizz, buzz);

        exchange.getOut().setBody(pojo);
    }
}

我现在需要一种方法将 MyPOJO 实例（在 myPOJOFactory Bean 中创建）拆分为其组成 Fizz 和 Buzz 属性，并以一种方式路由 Fizz，以另一种方式路由 Buzz。

我对拆分器的理解是，它只是将交换的主体分解为2个对象的集合。但我不认为这是我想要的，因为尽管我确实希望MyPOJO被“拆分”成其组成部分Fizz和Buzz字段，但我希望将它们路由到不同的目的地。也许菲兹去导演：嘶嘶声农场和嗡嗡去直接：嗡嗡声农场。

我对基于内容的路由器的理解（

我对动态路由器的理解是，它会动态地将消息路由到不同的目的地，尽管我还不太确定是如何做到的。我相信这就是我想要的，但是，从< code>myPOJOFactory bean中出来，交换将包含一个< code>MyPOJO对象。我觉得在将< code>MyPOJO发送到动态路由器之前，我必须先将其拆分。这样，动态路由器将能够清楚地看到消息是< code>Fizz还是< code>Buzz，并正确地路由它。

因此，我认为我需要将分离器与动态路由器结合使用。我只是没有透过树看到森林。大概是这样的:

<route id="myroute">
    <from uri="timer://runOnce?repeatCount=1&amp;delay=10" />

    <to uri="bean:myPOJOFactory?method=newMyPOJO" />

    <split>
        <tokenize token="Somehow split MyPOJO into Fizz and Buzz here" />
        <to uri="direct:dynrouter" />
    </split>

    <from uri="direct:dynrouter" />

    <dynamicRouter>
        <!-- ??? Somehow route Fizz to direct:fizzFarm, and Buzz to direct:buzzFarm
    </dynamicRouter>
</route>

关于我如何实现这一点，有什么想法吗（#1将MyPOJO拆分为Fizz和Buzz，以及#2设置路由器将Fizz和Buzz路由到不同的目的地）？

Answer 1

你说得对，因为逻辑总是一样的，路由器可能会过度使用。

拆分器最常用于相同类型的对象（例如，拆分列表并分别处理每个项目）

所以我可以建议多播EIP吗？应该可以这样做：

from("timer://runOnce?repeatCount=1&delay=10")
    .bean(myPOJOFactory.class)
    .multicast().to("direct:sendFizz", "direct:sendBuzz")

from("direct:sendFizz")
    .setBody(simple("${body.fizz"))
    .to("direct:fizzFarm")

from("direct:sendBuzz")
    .setBody(simple("${body.buzz"))
    .to("direct:buzzFarm")

(这明显是DSL语法，也可以用XML试试)。