使用Apache Camel消费RESTful web服务

Question

我正在尝试使用camel使用restful Web服务。

为此，我正在配置动态endpointurl，因为RESTful url是在运行时创建的。每次我都会使用CamelContext类的以下方法检查特定endpointurl是否在我的CamelContext中注册为路由。

endpoint有Endpoint（String uri）；

在这种情况下，如果未注册终结点，则使用自定义路由生成器将路由添加到骆驼上下文中。

我使用骆驼HTTP组件。这对我来说很好。

然而，我认为从性能角度来看，这并不好，因为每次我都必须检查一条路由是否已在camel上下文中注册，如果没有，则在进行webservice调用之前注册相同的路由。

有人能告诉我是否有更好的方法来使用骆驼中的RESTful网络服务吗？

我还想知道我正在使用的RESTful Web服务是否使用OAuth 2.0协议，在我正在使用它时，我是否需要更改代码中的任何内容？

问候，尼洛帕尔

谢谢你的回复。

我正在检查路线是否已经存在，以确保我不会最终向骆驼上下文添加重复的路线。

关于长寿路线和路线动态，你能解释一下吗？我如何实现路线动态？

如果您能给我举一些CXF-RS生产商的例子，也会很有帮助。。我阅读了CXFRS的文档，但不能清楚地理解它。

谢谢你，尼洛帕尔

Answer 1

CamelContext context = new DefaultCamelContext();

我的目标

我试图拦截传入的请求，并根据传入请求的ip，我想调用获取报价的动态endpoint

context.addRoutes(new RouteBuilder(){
     public void configure(){

     from("jetty:localhost:9000/offers")
     .process(new Processor(){
         public void process(Exchange exchange) throws Exception {

            //getting the request object
            HttpServletRequest req = exchange.getIn().getBody(HttpServletRequest.class);
            //Extracting information from the request
            String requestIP=req.getRemoteAddr();

            /**
             * After getting the ip address i do necessay processing
             * and then add a property to exchange object.
             * Destination ip address is the address to which i want to   
             * send my request
             */

           exchange.setProperty("operatorAddress",destinationIpAddress);


       }
      })
     .to("direct:getOffers")
     .end();
}
});

现在我将调用getOffersendpoint

所以首先我要登记一下

context.addRoutes(new RouteBuilder(){
     public void configure(){
         from("direct:getOffers")
         .toD("jetty:${property.operatorAddress}/api/v2.0/offers? 
          bridgeEndpoint=true")
        .end();

    }
});

因此，我们可以访问exchange对象的operatorAddress属性

${property.operatorAddress}

还有，当我们有动态路线时，我们需要打电话

.toD()   and not .to()

Answer 2

确切地说，为什么在打电话之前需要检查路线是否已注册？您或许应该设置一个更长寿命的路由，并动态路由以重新分配资源。

至于用骆驼Rest，我认为超文本传输协议组件做得很好，但是也有更高级别的组件可以使用，更适合REST。CXFRS和Restlet，restlet的生产者示例可以在ApacheCamel源单元测试中找到，比如这个RestletProducerGetTest.java.

至于oAuth 2.0，Camel有一些内置的oAuth支持，尤其是对google。寻找gauth组件。甚至还有一个教程，但它可能与您的案例不一致，它仍然可能提供一些背景信息，以便您可以解决您的问题：http://camel.apache.org/tutorial-oauth.html