使用Apache Camel发出http请求

Apache Camel 是一个强大的集成框架，允许你通过路由和处理消息来集成不同的系统和服务。使用 Apache Camel 发出 HTTP 请求非常简单，你可以使用 Camel 的 HTTP 组件来实现这一点。

以下是一个简单的示例，展示如何使用 Apache Camel 发出 HTTP 请求。

步骤 1：添加依赖

首先，你需要在你的项目中添加 Apache Camel 的依赖。如果你使用的是 Maven，可以在 pom.xml 中添加以下依赖：

<dependencies>
    <!-- Apache Camel Core -->
    <dependency>
        <groupId>org.apache.camel</groupId>
        <artifactId>camel-core</artifactId>
        <version>3.14.0</version>
    </dependency>

    <!-- Apache Camel HTTP 组件 -->
    <dependency>
        <groupId>org.apache.camel</groupId>
        <artifactId>camel-http</artifactId>
        <version>3.14.0</version>
    </dependency>
</dependencies>

步骤 2：创建 Camel 上下文和路由

接下来，编写代码创建 Camel 上下文和路由。在这个示例中，我们将创建一个简单的路由，从一个定时器触发器开始，发出一个 HTTP GET 请求，并将响应打印到控制台。

import org.apache.camel.CamelContext;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.impl.DefaultCamelContext;

public class HttpGetExample {

    public static void main(String[] args) throws Exception {
        // 创建 Camel 上下文
        CamelContext context = new DefaultCamelContext();

        // 添加路由
        context.addRoutes(new RouteBuilder() {
            @Override
            public void configure() {
                from("timer:foo?period=5000") // 每5秒触发一次
                    .to("http://httpbin.org/get") // 发出 HTTP GET 请求
                    .log("HTTP Response: ${body}"); // 打印响应
            }
        });

        // 启动 Camel 上下文
        context.start();

        // 运行一段时间后停止
        Thread.sleep(20000);
        context.stop();
    }
}

步骤 3：运行代码

运行上述代码，你将看到每5秒发出一次 HTTP GET 请求，并将响应打印到控制台。

发送 HTTP POST 请求

如果你需要发送 HTTP POST 请求，可以修改路由中的 .to 方法，指定 HTTP 方法和请求体。例如：

import org.apache.camel.CamelContext;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.impl.DefaultCamelContext;

public class HttpPostExample {

    public static void main(String[] args) throws Exception {
        // 创建 Camel 上下文
        CamelContext context = new DefaultCamelContext();

        // 添加路由
        context.addRoutes(new RouteBuilder() {
            @Override
            public void configure() {
                from("timer:foo?period=5000") // 每5秒触发一次
                    .setHeader("Content-Type", constant("application/json"))
                    .setBody(constant("{\"key\":\"value\"}")) // 设置请求体
                    .to("http://httpbin.org/post?httpMethod=POST") // 发出 HTTP POST 请求
                    .log("HTTP Response: ${body}"); // 打印响应
            }
        });

        // 启动 Camel 上下文
        context.start();

        // 运行一段时间后停止
        Thread.sleep(20000);
        context.stop();
    }
}