如何将带--data-binary的curl命令转为Spring Webflux WebClient请求？

你的curl命令curl http://some-host:8080/api/theapi --data-binary @mydata核心行为是直接发送文件中的原始二进制内容，默认会设置请求头Content-Type: application/x-www-form-urlencoded（尽管请求体是JSON）。而你之前的WebClient代码将Map序列化为JSON并默认设置Content-Type: application/json，这与服务器期望的请求格式不匹配，导致500错误。

以下是几种等效的WebClient实现方式：

方式1：完全模拟curl的二进制发送行为（推荐） #

直接读取文件的原始字节，发送并设置与curl一致的请求头：

import org.springframework.web.reactive.function.BodyInserters;
import org.springframework.web.reactive.function.client.WebClient;
import java.nio.file.Files;
import java.nio.file.Paths;

public class WebClientBinaryExample {
    public static void main(String[] args) throws Exception {
        // 读取mydata文件的原始二进制内容
        byte[] fileBytes = Files.readAllBytes(Paths.get("mydata"));

        WebClient webClient = WebClient.create();

        String response = webClient.post()
                .uri("http://some-host:8080/api/theapi")
                // 匹配curl默认的Content-Type
                .header("Content-Type", "application/x-www-form-urlencoded")
                // 发送原始二进制数据，对应--data-binary的行为
                .body(BodyInserters.fromValue(fileBytes))
                .retrieve()
                .bodyToMono(String.class)
                .block();

        System.out.println(response);
    }
}

方式2：发送JSON字符串（若服务器接受application/json） #

如果服务器实际期望application/json类型的请求体，可以明确设置请求头并发送JSON字符串：

import org.springframework.web.reactive.function.BodyInserters;
import org.springframework.web.reactive.function.client.WebClient;
import java.nio.file.Files;
import java.nio.file.Paths;

public class WebClientJsonExample {
    public static void main(String[] args) throws Exception {
        String jsonContent = Files.readString(Paths.get("mydata"));

        WebClient webClient = WebClient.create();

        String response = webClient.post()
                .uri("http://some-host:8080/api/theapi")
                .header("Content-Type", "application/json")
                .body(BodyInserters.fromValue(jsonContent))
                .retrieve()
                .bodyToMono(String.class)
                .block();

        System.out.println(response);
    }
}

方式3：使用Map序列化（修正原代码） #

如果你想继续用Map生成JSON，只需明确设置请求头，确保与服务器期望一致：

import org.springframework.web.reactive.function.BodyInserters;
import org.springframework.web.reactive.function.client.WebClient;
import java.util.Map;

public class WebClientMapExample {
    public static void main(String[] args) {
        WebClient webClient = WebClient.create();

        Map<String, String> jsonPayload = Map.of("somekey", "someValue", "anotherkey", "events");

        String response = webClient.post()
                .uri("http://some-host:8080/api/theapi")
                // 根据服务器需求设置Content-Type，这里模拟curl默认值
                .header("Content-Type", "application/x-www-form-urlencoded")
                .body(BodyInserters.fromValue(jsonPayload))
                .retrieve()
                .bodyToMono(String.class)
                .block();

        System.out.println(response);
    }
}

关键说明 #

• --data-binary的核心是不修改原始数据，直接发送文件的字节流，所以方式1最贴近curl的原始行为。
• 服务器返回500的核心原因是请求头Content-Type与服务器期望不匹配，你可以根据服务器的实际要求调整Content-Type值。

内容的提问来源于stack exchange，提问作者PatPanda