java - 使用 Apache Camel 发送 POST 请求

Question

我能够使用 Apache Camel 向 REST 服务发送 GET 请求，现在我正在尝试使用 Apache Camel 发送带有 JSON 正文的 POST 请求。我无法弄清楚如何添加 JSON 正文并发送请求。如何添加 JSON 正文、发送请求并获取响应代码？

Answer 1

下面你可以找到一个示例路由，它使用 POST 方法向服务器发送（每 2 秒）json，在示例中它是 localhost:8080/greeting。还有一种方法可以得到响应：

from("timer://test?period=2000")
    .process(exchange -> exchange.getIn().setBody("{\"title\": \"The title\", \"content\": \"The content\"}"))
    .setHeader(Exchange.HTTP_METHOD, constant("POST"))
    .setHeader(Exchange.CONTENT_TYPE, constant("application/json"))
    .to("http://localhost:8080/greeting")
    .process(exchange -> log.info("The response code is: {}", exchange.getIn().getHeader(Exchange.HTTP_RESPONSE_CODE)));

通常手动准备 json 并不是一个好主意。你可以使用例如

<dependency>
    <groupId>org.apache.camel</groupId>
    <artifactId>camel-gson</artifactId>
</dependency>

为您执行编组。假设您定义了一个 Greeting 类，您可以通过删除第一个处理器并改用以下代码来修改 Route：

.process(exchange -> exchange.getIn().setBody(new Greeting("The title2", "The content2")))
.marshal().json(JsonLibrary.Gson)

进一步阅读：http : //camel.apache.org/http.html 值得注意的是，还有 http4 组件（它们在后台使用不同版本的 Apache HttpClient）。

Answer 2

您可以这样做：

from("direct:start")
 .setHeader(Exchange.HTTP_METHOD, constant("POST"))
 .to("http://www.google.com");

当前 Camel Exchange 的正文将被发布到 URL 端点。

Answer 3

//This code is for sending post request and getting response
public static void main(String[] args) throws Exception {
    CamelContext c=new DefaultCamelContext();       
    c.addRoutes(new RouteBuilder() {
        @Override
        public void configure() throws Exception {          
            from("direct:start")
            .process(new Processor() {
                public void process(Exchange exchange) throws Exception {
                System.out.println("i am worlds fastest flagship processor ");
                exchange.getIn().setHeader("CamelHttpMethod", "POST");
                exchange.getIn().setHeader("Content-Type", "application/json");
                exchange.getIn().setHeader("accept", "application/json");
                }
                })
              // to the http uri
                .to("https://www.google.com")
       // to the consumer
                .to("seda:end");
        }
    });



    c.start();
    ProducerTemplate pt = c.createProducerTemplate();
      // for sending request 
    pt.sendBody("direct:start","{\"userID\": \"678\",\"password\": \"password\", 
  \"ID\": \"123\"  }");
    ConsumerTemplate ct = c.createConsumerTemplate();
    String m = ct.receiveBody("seda:end",String.class);
    System.out.println(m);
}

Answer 4

请注意，虽然您可能更喜欢显式设置 HTTP 方法，但您不必这样做。以下来自Camel 的 http 组件文档：

将使用哪种 HTTP 方法

以下算法用于确定应使用哪种 HTTP 方法：

1. 使用作为端点配置提供的方法 (httpMethod)。
2. 使用标头中提供的方法 (Exchange.HTTP_METHOD)。
3. 如果在标头中提供了查询字符串，则获取。
4. GET 如果端点配置有查询字符串。
5. POST 如果有数据要发送（正文不为空）。
6. 否则获取。

换句话说，如果你有一个 body/data 并且条件 1-4 不适用，它会默认 POST。这适用于我已实施的路线。