Camel模块间协调依赖

Question

from("servlet:///?matchOnUriPrefix=true")
  .process(customProcessor)
    .choice()
    .when(simple("${in.headers.ARestURN} contains ${in.headers.CamelHttpUri}"))
       .to("http4://" + AUrl + "?bridgeEndpoint=true&throwExceptionOnFailure=false")
    .when(simple("${in.headers.BRestURN} contains ${in.headers.CamelHttpUri}"))
       .to("http4://" + BUrl + "?bridgeEndpoint=true&throwExceptionOnFailure=false")
    .otherwise()
       .to("http4://" + DUrl + "?bridgeEndpoint=true&throwExceptionOnFailure=false");

我现在的问题是，我需要服务一个REST url请求，它要求我acccess、AUrl和BUrl并聚合结果，然后响应请求，我如何实现这一点？

我想写一些如下的东西

from("servlet:///?matchOnUriPrefix=true")
  .process(customProcessor)
    .choice()
    .when(simple("${in.headers.ARestURN} contains ${in.headers.CamelHttpUri}"))
       .to("http4://" + AUrl + "?bridgeEndpoint=true&throwExceptionOnFailure=false")
    .when(simple("${in.headers.BRestURN} contains ${in.headers.CamelHttpUri}"))
       .to("http4://" + BUrl + "?bridgeEndpoint=true&throwExceptionOnFailure=false")
  .when(simple("${in.headers.MultiModuleRestURN} contains ${in.headers.CamelHttpUri}"))
   .to("direct:multimodule")
    .otherwise()
       .to("http4://" + DUrl + "?bridgeEndpoint=true&throwExceptionOnFailure=false");

from("direct:multimodule")
   .process(new MyProcessor())
      .to("http4://" + AUrl + "?bridgeEndpoint=true&throwExceptionOnFailure=false");

但是我不知道如何从第一个“aurl”（这是一个返回json结果的REST服务）获得结果，并对它进行一些处理，将结果的特定值提供给下一个url（即BUrl）以从中获得结果，并对其进行处理，合并结果，然后将其发送回调用服务。

the REST call :    /AB/123/getPrice
Need to pass 123 to Module A - REST call ->  /A/123/getId     response-{A: 123, id: x1}
Need to pass x1 to Module B  - REST call ->  /B/x1/getPrice   response-{id: x1, p:$10}
Need to return to caller {name: 123, id: x1, price: $10 } (json combined object)

from("servlet:///?matchOnUriPrefix=true")
   .process(customProcessor)
     .choice()
       .when(simple("${in.headers.multiRestURN} contains ${in.headers.CamelHttpUri}"))
         .to("direct:multimodule")
       .when(simple("${in.headers.ARestURN} contains ${in.headers.CamelHttpUri}"))
         .to("http4://" +AUrl)
       .when(simple("${in.headers.BRestURN} contains ${in.headers.CamelHttpUri}"))
         .to("http4://" +BUrl)
       .otherwise()
         .to("http4://" +DUrl);
//    
from("direct:multimodule")
 .to(ExchangePattern.InOut,"http4://"+AUrl)
   .convertBodyTo(String.class) 
     .process(customAProcess)
      .to(ExchangePattern.InOut, "http4://"+BUrl+"/resources")
         .convertBodyTo(String.class) 
         .process(customBProcessor);

所以当BUrl请求得到结果时，这些数据是可用的，我向BUrl发送了不必要的数据，但这有望解决这个问题，也许当我有时间时，我会研究丰富和聚合的策略来解决这个问题。

Answer 1

Enricher组件可能是您正在寻找的。它是一种常见模式的实现。请注意，可以通过strategyRef参数传递聚合策略的实现。

当为第一次rest调用实现聚合策略时，您可以通过第一次rest响应返回的数据来丰富原始交换-请参见AggregationStrategy的界面。只需创建策略的bean并配置Enricher。

希望能有所帮助。示例上下文：）：

<camelContext id="camel" xmlns="http://camel.apache.org/schema/spring">
   <route>
      <from uri="servlet:///?matchOnUriPrefix=true"/>
      <enrich uri="http4://serviceA" strategyRef="strategyA"/>
      <enrich uri="http4://serviceB" strategyRef="strategyB"/>
    </route>
</camelContext>
<bean id="strategyA" class="..." />
<bean id="strategyB" class="..." />