用Apache Camel处理外部web服务响应

Question

我正在考虑两个小的Spring Boot应用程序：

• 应用1：运行在http：//localhost:8081上的小型web服务，实现一个简单的Spring控制器来响应/camel上的GET请求。访问http://localhost:8081/camel时，该服务仅返回“Hello World”。
• 应用程序2：一个小型应用程序，它应该执行对应用程序1的GET请求，并打印出对控制台的响应（在本例中为“Hello World”）。

使用SpringsRestTemplate，我可以轻松地在应用程序2中实现这个GET请求：

RestTemplate template = new RestTemplate();
String response = template.getForBody("http://localhost:8081/camel", String.class);
System.out.println(response);

public class MyRoutes extends RouteBuilder {
    @Override
    public void configure() throws Exception() {
        from("jetty:http://localhost:8081/camel").to("direct:processRest");

        from("direct:processRest").process(new Processor() {
            @Override
            public void process(Exchange exchange) throws Exception {
                System.out.println(exchange.getIn().getBody());
            }
        });
    }
}

org.apache.camel.spring.boot.CamelSpringBootInitializationException: java.net.BindException: Address already in use: bind

Spring Boot或Apache Camel自动尝试在端口8081上启动Jetty服务器，但另一个web服务（应用程序1）已经在此端口上运行。

有人知道如何避免这个问题吗？

Answer 1

您遇到的问题来自这样一个事实，即您将Camel的Jetty组件作为消费者使用，这将启动一个嵌入式Jetty服务器并将其绑定到端口8081，从而与Spring Boot应用程序冲突。要发送HTTP请求，您应该使用Jetty组件作为生产者，即将路由定义更改为类似于

从（“Scheduler：CamelTest？Delay=1000”）.到（“Jetty：http：//localhost:8081/camel”）.到（“Direct：ProcessRest”）；