2019獨(dú)角獸企業(yè)重金招聘Python工程師標(biāo)準(zhǔn)>>>

split和aggregate，看圖就明白了。

下面我用一個(gè)例子來(lái)說(shuō)明，非常難得，你很難在網(wǎng)上找到apache camel這樣的例子。

1、路由

from("jms:TOOL.TTT").bean(TttBean.class, "start").split(body(List.class),new MyAggregationStrategy()).bean(TttBean.class, "processOneLi").end().split(body(List.class)).bean(TttBean.class, "processOne").bean(TttBean.class, "end");2、測(cè)試bean

public class TttBean {public void start(Exchange exchange){List<List<Integer>> ii = new ArrayList<List<Integer>>();for(int i =0;i<2;i++){List<Integer> li = new ArrayList<Integer>();for(int j = 10;j < 15; j++){li.add(j);}ii.add(li);}exchange.getIn().setBody(ii);System.out.println("start....");}public void processOneLi(Exchange exchange){System.out.println("CamelSplitIndex:" + exchange.getProperty("CamelSplitIndex",int.class));System.out.println("CamelSplitSize:" + exchange.getProperty("CamelSplitSize",int.class));System.out.println("CamelSplitComplete:" + exchange.getProperty("CamelSplitComplete",boolean.class));List<Integer> li = exchange.getIn().getBody(List.class);System.out.println("oneLi");}public void processOne(Exchange exchange){System.out.println("CamelSplitIndex:" + exchange.getProperty("CamelSplitIndex",int.class));System.out.println("CamelSplitSize:" + exchange.getProperty("CamelSplitSize",int.class));System.out.println("CamelSplitComplete:" + exchange.getProperty("CamelSplitComplete",boolean.class));int i = exchange.getIn().getBody(int.class);System.out.println(i);}public void end(Exchange exchange){System.out.println("ending....");} }3、聚合類

public class MyAggregationStrategy implements AggregationStrategy{@Overridepublic Exchange aggregate(Exchange oldExchange, Exchange newExchange) {if (oldExchange == null) {// the first time we aggregate we only have the new exchange,// so we just return itreturn newExchange;}List<Integer> lio = oldExchange.getIn().getBody(List.class);List<Integer> lin = newExchange.getIn().getBody(List.class);for(Integer i : lin){lio.add(i);}oldExchange.getIn().setBody(lio);return oldExchange;}}4、輸出：

start....

CamelSplitIndex:0

CamelSplitSize:2

CamelSplitComplete:false

oneLi

CamelSplitIndex:1

CamelSplitSize:2

CamelSplitComplete:true

oneLi

CamelSplitIndex:0

CamelSplitSize:10

CamelSplitComplete:false

10

ending....

CamelSplitIndex:1

CamelSplitSize:10

CamelSplitComplete:false

11

ending....

CamelSplitIndex:2

CamelSplitSize:10

CamelSplitComplete:false

12

ending....

CamelSplitIndex:3

CamelSplitSize:10

CamelSplitComplete:false

13

ending....

CamelSplitIndex:4

CamelSplitSize:10

CamelSplitComplete:false

14

ending....

CamelSplitIndex:5

CamelSplitSize:10

CamelSplitComplete:false

10

ending....

CamelSplitIndex:6

CamelSplitSize:10

CamelSplitComplete:false

11

ending....

CamelSplitIndex:7

CamelSplitSize:10

CamelSplitComplete:false

12

ending....

CamelSplitIndex:8

CamelSplitSize:10

CamelSplitComplete:false

13

ending....

CamelSplitIndex:9

CamelSplitSize:10

CamelSplitComplete:true

14

ending....

我的例子里面從一個(gè)jms消息開始，然后經(jīng)歷一系列的路由處理，最終將任務(wù)完成。問題是，我們希望在任務(wù)結(jié)束的時(shí)候，再發(fā)一個(gè)jms來(lái)通知任務(wù)發(fā)起者，“我已經(jīng)完成啦。”，但上面的輸出顯然有問題，因?yàn)橛泻枚鄠€(gè)end....。當(dāng)然，根據(jù)我提供的代碼，你肯定發(fā)現(xiàn)多種方法來(lái)判斷任務(wù)的結(jié)束。你可以試試看。

轉(zhuǎn)載于:https://my.oschina.net/jianglibo/blog/17627

總結(jié)

以上是生活随笔為你收集整理的apache camel 的 split 和 aggregate的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。