使用Apache Camel发出http请求

<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>

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();
    }
}

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();
    }
}