如何从java.net.http.HttpRequest生成curl？请求体获取遇困境

由于java.net.http.HttpRequest的BodyPublisher本身没有直接暴露请求体内容的API，要生成包含请求体的curl命令，核心思路是提前记录请求体或通过包装类捕获请求体数据，以下是具体实现方案：

方案一：构建请求时提前保存请求体 #

这是最直接的方式，在创建HttpRequest前先把要发送的请求体内容（字符串、字节数组等）保存下来，生成curl命令时直接复用该内容。

示例代码：

// 提前定义并保存请求体
String requestBody = "{\"username\":\"test\",\"password\":\"123456\"}";

// 构建HttpRequest
HttpRequest request = HttpRequest.newBuilder()
        .uri(URI.create("https://example.com/login"))
        .header("Content-Type", "application/json")
        .POST(HttpRequest.BodyPublishers.ofString(requestBody))
        .build();

// 生成curl命令
String curlCommand = String.format(
        "curl -X POST %s -H \"Content-Type: application/json\" -d '%s'",
        request.uri(),
        requestBody.replace("'", "\\'") // 转义单引号避免curl语法错误
);

方案二：自定义BodyPublisher包装类捕获请求体 #

如果无法提前获取请求体（比如BodyPublisher由第三方逻辑生成），可以通过包装BodyPublisher来捕获发送的字节数据。

自定义记录型BodyPublisher #

import java.io.ByteArrayOutputStream;
import java.nio.ByteBuffer;
import java.util.concurrent.Flow;
import java.net.http.HttpRequest;

public class RecordingBodyPublisher implements HttpRequest.BodyPublisher {
    private final HttpRequest.BodyPublisher delegate;
    private final ByteArrayOutputStream recordedBytes = new ByteArrayOutputStream();

    public RecordingBodyPublisher(HttpRequest.BodyPublisher delegate) {
        this.delegate = delegate;
    }

    @Override
    public long contentLength() {
        return delegate.contentLength();
    }

    @Override
    public void subscribe(Flow.Subscriber<? super ByteBuffer> subscriber) {
        delegate.subscribe(new Flow.Subscriber<>() {
            @Override
            public void onSubscribe(Flow.Subscription subscription) {
                subscriber.onSubscribe(subscription);
            }

            @Override
            public void onNext(ByteBuffer item) {
                // 复制字节到记录流
                recordedBytes.write(item.array(), item.position(), item.remaining());
                subscriber.onNext(item);
            }

            @Override
            public void onError(Throwable throwable) {
                subscriber.onError(throwable);
            }

            @Override
            public void onComplete() {
                subscriber.onComplete();
            }
        });
    }

    // 获取记录的字节形式请求体
    public byte[] getRecordedBody() {
        return recordedBytes.toByteArray();
    }

    // 获取字符串形式请求体（需根据实际编码调整）
    public String getRecordedBodyAsString() {
        return new String(recordedBytes.toByteArray());
    }
}

使用方式 #

// 假设原BodyPublisher是第三方生成的
HttpRequest.BodyPublisher originalPublisher = HttpRequest.BodyPublishers.ofByteArray("hello world".getBytes());
RecordingBodyPublisher recordingPublisher = new RecordingBodyPublisher(originalPublisher);

// 构建请求时使用包装后的Publisher
HttpRequest request = HttpRequest.newBuilder()
        .uri(URI.create("https://example.com/echo"))
        .POST(recordingPublisher)
        .build();

// 生成curl命令
String curlBody = recordingPublisher.getRecordedBodyAsString().replace("'", "\\'");
String curlCommand = String.format("curl -X POST %s -d '%s'", request.uri(), curlBody);

注意事项 #

• 对于大体积请求体（如文件上传），记录完整内容会占用大量内存，建议仅在调试场景使用，或只记录部分内容。
• 生成curl命令时要处理特殊字符转义（如单引号、换行符），避免出现语法错误。
• 如果HttpRequest已经构建完成且无法修改构建流程，几乎没有可靠方法获取请求体——因为BodyPublisher的设计仅负责发布数据，不暴露原始内容。

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