能否用Java 11 HttpClient自定义Body Publisher直接发送对象请求体？

核心结论 #

Java 11 HttpClient没有内置直接发送Java对象的BodyPublisher实现，但完全可以自定义实现，进而封装出类似Spring RestTemplate.postForEntity()的便捷功能，无需手动将对象转为字符串再传入BodyPublishers.ofString()。

自定义BodyPublisher实现思路 #

HttpRequest.BodyPublisher本质是Flow.Publisher<ByteBuffer>的子接口，我们可以借助JSON序列化库（比如Jackson）将对象转为字节数组，再基于内置的BodyPublishers.ofByteArray()来封装自定义的BodyPublisher。

具体实现代码 #

1. 自定义对象转BodyPublisher的工具方法

import com.fasterxml.jackson.databind.ObjectMapper;
import java.net.http.HttpRequest;
import java.io.IOException;

public class HttpClientUtils {
    private static final ObjectMapper OBJECT_MAPPER = new ObjectMapper();

    // 自定义BodyPublisher，直接接收Java对象
    public static HttpRequest.BodyPublisher ofObject(Object body) throws IOException {
        byte[] jsonBytes = OBJECT_MAPPER.writeValueAsBytes(body);
        return HttpRequest.BodyPublishers.ofByteArray(jsonBytes);
    }
}

2. 封装类似postForEntity()的便捷方法

如果需要像RestTemplate.postForEntity()一样直接发送对象并返回响应实体，可以进一步封装：

import java.net.URI;
import java.net.http.HttpClient;
import java.net.http.HttpResponse;
import java.io.IOException;

public class RestClient {
    private final HttpClient httpClient;
    private final ObjectMapper objectMapper;

    public RestClient() {
        this.httpClient = HttpClient.newHttpClient();
        this.objectMapper = new ObjectMapper();
    }

    public <T, R> ResponseEntity<R> postForEntity(String url, T requestBody, Class<R> responseType) throws IOException, InterruptedException {
        HttpRequest request = HttpRequest.newBuilder(URI.create(url))
                .header("Content-Type", "application/json")
                .POST(HttpClientUtils.ofObject(requestBody))
                .build();

        HttpResponse<String> response = httpClient.send(request, HttpResponse.BodyHandlers.ofString());
        R responseBody = objectMapper.readValue(response.body(), responseType);

        return new ResponseEntity<>(responseBody, response.statusCode());
    }

    // 简单封装响应实体类
    public static class ResponseEntity<T> {
        private final T body;
        private final int statusCode;

        public ResponseEntity(T body, int statusCode) {
            this.body = body;
            this.statusCode = statusCode;
        }

        // getter方法
        public T getBody() { return body; }
        public int getStatusCode() { return statusCode; }
    }
}

3. 使用示例

// 定义请求对象
class UserRequest {
    private String name;
    private int age;

    // 构造器、getter、setter
    public UserRequest(String name, int age) {
        this.name = name;
        this.age = age;
    }
}

// 定义响应对象
class UserResponse {
    private String id;
    private String name;

    // getter、setter
}

// 调用示例
public class Main {
    public static void main(String[] args) throws IOException, InterruptedException {
        RestClient client = new RestClient();
        UserRequest request = new UserRequest("Alice", 30);
        RestClient.ResponseEntity<UserResponse> response = client.postForEntity("http://localhost:8080/api/test", request, UserResponse.class);

        System.out.println("状态码: " + response.getStatusCode());
        System.out.println("响应体ID: " + response.getBody().getId());
    }
}

补充说明 #

• 上述实现依赖Jackson库，需要在项目中引入对应依赖（比如Maven的com.fasterxml.jackson.core:jackson-databind）。
• 可根据需求扩展工具类，比如添加对不同媒体类型的支持、全局异常处理、请求超时配置等。

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