Java封装REST请求工具类示例

封装Java REST请求工具类的核心在于抽象HTTP请求细节并提供统一API。1. 工具类基于OkHttp和Jackson构建，支持GET、POST、PUT等HTTP方法；2. 封装了请求头、查询参数、请求体的处理；3. 包含响应解析与异常管理机制；4. 提供默认及可自定义的客户端配置，提升灵活性和可测试性；5. 通过统一异常处理确保请求行为一致性和可维护性。

封装Java REST请求工具类，核心在于将HTTP请求的底层细节抽象化，提供一套简洁、统一且可复用的API，让开发者能够专注于业务逻辑而非繁琐的网络通信配置。这不仅能提升开发效率，还能确保请求行为的一致性和可维护性。

解决方案

一个实用的Java REST请求工具类，通常会基于一个成熟的HTTP客户端库来构建，例如OkHttp。它会包含不同HTTP方法（GET, POST, PUT, DELETE等）的封装，并处理请求头、查询参数、请求体以及响应解析和异常。

以下是一个基于OkHttp和Jackson库的通用REST请求工具类示例：

import okhttp3.*;
import java.io.IOException;
import java.util.Map;
import java.util.concurrent.TimeUnit;
import com.fasterxml.jackson.databind.ObjectMapper; // 用于JSON序列化/反序列化

public class RestApiClient {

    private static final MediaType JSON_MEDIA_TYPE = MediaType.get("application/json; charset=utf-8");
    private final OkHttpClient client;
    private final ObjectMapper objectMapper;

    /**
     * 默认构造函数，使用预设的超时时间创建OkHttpClient实例
     * 和默认的ObjectMapper。
     */
    public RestApiClient() {
        this.client = new OkHttpClient.Builder()
                .connectTimeout(10, TimeUnit.SECONDS) // 连接超时
                .readTimeout(30, TimeUnit.SECONDS)    // 读取超时
                .writeTimeout(30, TimeUnit.SECONDS)   // 写入超时
                .build();
        this.objectMapper = new ObjectMapper();
    }

    /**
     * 允许外部传入自定义的OkHttpClient和ObjectMapper实例，
     * 提升灵活性和可测试性。
     * @param customClient 自定义的OkHttpClient
     * @param customMapper 自定义的ObjectMapper
     */
    public RestApiClient(OkHttpClient customClient, ObjectMapper customMapper) {
        this.client = customClient;
        this.objectMapper = customMapper;
    }

    /**
     * 发送GET请求。
     * @param url 请求URL
     * @param headers 请求头，可为null
     * @param queryParams 查询参数，可为null
     * @return 响应体字符串
     * @throws IOException 网络或IO错误
     * @throws HttpRequestException HTTP请求失败（非2xx状态码）
     */
    public String get(String url, Map headers, Map queryParams) throws IOException, HttpRequestException {
        HttpUrl.Builder urlBuilder = HttpUrl.parse(url).newBuilder();
        if (queryParams != null) {
            queryParams.forEach(urlBuilder::addQueryParameter);
        }

        Request.Builder requestBuilder = new Request.Builder().url(urlBuilder.build());
        if (headers != null) {
            headers.forEach(requestBuilder::addHeader);
        }

        try (Response response = client.newCall(requestBuilder.build()).execute()) {
            return handleResponse(response);
        }
    }

    /**
     * 发送POST请求，请求体为JSON格式。
     * @param url 请求URL
     * @param headers 请求头，可为null
     * @param bodyObj 请求体对象，将被序列化为JSON
     * @return 响应体字符串
     * @throws IOException 网络或IO错误，或JSON序列化错误
     * @throws HttpRequestException HTTP请求失败（非2xx状态码）
     */
    public String postJson(String url, Map headers, Object bodyObj) throws IOException, HttpRequestException {
        String jsonBody = objectMapper.writeValueAsString(bodyObj);
        RequestBody requestBody = RequestBody.create(jsonBody, JSON_MEDIA_TYPE);

        Request.Builder requestBuilder = new Request.Builder().url(url).post(requestBody);
        if (headers != null) {
            headers.forEach(requestBuilder::addHeader);
        }

        try (Response response = client.newCall(requestBuilder.build()).execute()) {
            return handleResponse(response);
        }
    }

    /**
     * 发送PUT请求，请求体为JSON格式。
     * @param url 请求URL
     * @param headers 请求头，可为null
     * @param bodyObj 请求体对象，将被序列化为JSON