OKhttp3

概述

OKHttp 是一個當(dāng)前主流的網(wǎng)絡(luò)請求的開源框架，由 Square 公司開發(fā)，用于替代 HttpUrlConnection 和 Apache HttpClient

特性

  • 支持 HTTP2，對一臺機器的所有請求共享同一個 Socket
  • 內(nèi)置連接池，支持連接復(fù)用，減少延遲
  • 支持透明的 gzip 壓縮響應(yīng)體
  • 通過緩存避免重復(fù)的請求
  • 請求失敗時自動重試主機的其他 IP，自動重定向

依賴

<dependency>
    <groupId>com.squareup.okhttp3</groupId>
    <artifactId>okhttp</artifactId>
    <version>4.0.1</version>
</dependency>

測試請求

GET

測試 Get 請求

@Test
public void testGet() {
    String url = "https://www.baidu.com";
    OkHttpClient client = new OkHttpClient();
    Request request = new Request.Builder()
        .url(url)
        .build();
    Call call = client.newCall(request);
    try {
        Response response = call.execute();
        System.out.println(response.body().string());
    } catch (IOException e) {
        e.printStackTrace();
    }
}

POST

測試 POST 請求

@Test
public void testPost() {
    String url = "http://localhost:9001/oauth/token";
    OkHttpClient client = new OkHttpClient();
    RequestBody body = new FormBody.Builder()
        .add("username", "admin")
        .add("password", "123456")
        .add("grant_type", "password")
        .add("client_id", "client")
        .add("client_secret", "secret")
        .build();
    Request request = new Request.Builder()
        .url(url)
        .post(body)
        .build();
    Call call = client.newCall(request);
    try {
        Response response = call.execute();
        System.out.println(response.body().string());
    } catch (IOException e) {
        e.printStackTrace();
    }
}

工具類

OKHttp

為了簡化我們的構(gòu)建過程，可以封裝如下工具類

public class OkHttpClientUtil {
    private static final int READ_TIMEOUT = 100;
    private static final int CONNECT_TIMEOUT = 60;
    private static final int WRITE_TIMEOUT = 60;
    private static final MediaType JSON = MediaType.parse("application/json; charset=utf-8");
    private static final byte[] LOCKER = new byte[0];
    private static OkHttpClientUtil mInstance;
    private OkHttpClient okHttpClient;
    private OkHttpClientUtil() {
        okhttp3.OkHttpClient.Builder clientBuilder = new okhttp3.OkHttpClient.Builder();
        // 讀取超時
        clientBuilder.readTimeout(READ_TIMEOUT, TimeUnit.SECONDS);
        // 連接超時
        clientBuilder.connectTimeout(CONNECT_TIMEOUT, TimeUnit.SECONDS);
        //寫入超時
        clientBuilder.writeTimeout(WRITE_TIMEOUT, TimeUnit.SECONDS);
        okHttpClient = clientBuilder.build();
    }
    /**
     * 單例模式獲取 NetUtils
     *
     * @return {@link OkHttpClientUtil}
     */
    public static OkHttpClientUtil getInstance() {
        if (mInstance == null) {
            synchronized (LOCKER) {
                if (mInstance == null) {
                    mInstance = new OkHttpClientUtil();
                }
            }
        }
        return mInstance;
    }
    /**
     * GET，同步方式，獲取網(wǎng)絡(luò)數(shù)據(jù)
     *
     * @param url 請求地址
     * @return {@link Response}
     */
    public Response getData(String url) {
        // 構(gòu)造 Request
        Request.Builder builder = new Request.Builder();
        Request request = builder.get().url(url).build();
        // 將 Request 封裝為 Call
        Call call = okHttpClient.newCall(request);
        // 執(zhí)行 Call，得到 Response
        Response response = null;
        try {
            response = call.execute();
        } catch (IOException e) {
            e.printStackTrace();
        }
        return response;
    }
    /**
     * POST 請求，同步方式，提交數(shù)據(jù)
     *
     * @param url        請求地址
     * @param bodyParams 請求參數(shù)
     * @return {@link Response}
     */
    public Response postData(String url, Map<String, String> bodyParams) {
        // 構(gòu)造 RequestBody
        RequestBody body = setRequestBody(bodyParams);
        // 構(gòu)造 Request
        Request.Builder requestBuilder = new Request.Builder();
        Request request = requestBuilder.post(body).url(url).build();
        // 將 Request 封裝為 Call
        Call call = okHttpClient.newCall(request);
        // 執(zhí)行 Call，得到 Response
        Response response = null;
        try {
            response = call.execute();
        } catch (IOException e) {
            e.printStackTrace();
        }
        return response;
    }
    /**
     * GET 請求，異步方式，獲取網(wǎng)絡(luò)數(shù)據(jù)
     *
     * @param url       請求地址
     * @param myNetCall 回調(diào)函數(shù)
     */
    public void getDataAsync(String url, final MyNetCall myNetCall) {
        // 構(gòu)造 Request
        Request.Builder builder = new Request.Builder();
        Request request = builder.get().url(url).build();
        // 將 Request 封裝為 Call
        Call call = okHttpClient.newCall(request);
        // 執(zhí)行 Call
        call.enqueue(new Callback() {
            @Override
            public void onFailure(Call call, IOException e) {
                myNetCall.failed(call, e);
            }
            @Override
            public void onResponse(Call call, Response response) throws IOException {
                myNetCall.success(call, response);
            }
        });
    }
    /**
     * POST 請求，異步方式，提交數(shù)據(jù)
     *
     * @param url        請求地址
     * @param bodyParams 請求參數(shù)
     * @param myNetCall  回調(diào)函數(shù)
     */
    public void postDataAsync(String url, Map<String, String> bodyParams, final MyNetCall myNetCall) {
        // 構(gòu)造 RequestBody
        RequestBody body = setRequestBody(bodyParams);
        // 構(gòu)造 Request
        buildRequest(url, myNetCall, body);
    }
    /**
     * 同步 POST 請求，使用 JSON 格式作為參數(shù)
     *
     * @param url  請求地址
     * @param json JSON 格式參數(shù)
     * @return 響應(yīng)結(jié)果
     * @throws IOException 異常
     */
    public String postJson(String url, String json) throws IOException {
        RequestBody body = RequestBody.create(json, JSON);
        Request request = new Request.Builder()
                .url(url)
                .post(body)
                .build();
        Response response = okHttpClient.newCall(request).execute();
        if (response.isSuccessful()) {
            return response.body().string();
        } else {
            throw new IOException("Unexpected code " + response);
        }
    }
    /**
     * 異步 POST 請求，使用 JSON 格式作為參數(shù)
     *
     * @param url       請求地址
     * @param json      JSON 格式參數(shù)
     * @param myNetCall 回調(diào)函數(shù)
     * @throws IOException 異常
     */
    public void postJsonAsync(String url, String json, final MyNetCall myNetCall) throws IOException {
        RequestBody body = RequestBody.create(json, JSON);
        // 構(gòu)造 Request
        buildRequest(url, myNetCall, body);
    }
    /**
     * 構(gòu)造 POST 請求參數(shù)
     *
     * @param bodyParams 請求參數(shù)
     * @return {@link RequestBody}
     */
    private RequestBody setRequestBody(Map<String, String> bodyParams) {
        RequestBody body = null;
        okhttp3.FormBody.Builder formEncodingBuilder = new okhttp3.FormBody.Builder();
        if (bodyParams != null) {
            Iterator<String> iterator = bodyParams.keySet().iterator();
            String key = "";
            while (iterator.hasNext()) {
                key = iterator.next().toString();
                formEncodingBuilder.add(key, bodyParams.get(key));
            }
        }
        body = formEncodingBuilder.build();
        return body;
    }
    /**
     * 構(gòu)造 Request 發(fā)起異步請求
     *
     * @param url       請求地址
     * @param myNetCall 回調(diào)函數(shù)
     * @param body      {@link RequestBody}
     */
    private void buildRequest(String url, MyNetCall myNetCall, RequestBody body) {
        Request.Builder requestBuilder = new Request.Builder();
        Request request = requestBuilder.post(body).url(url).build();
        // 將 Request 封裝為 Call
        Call call = okHttpClient.newCall(request);
        // 執(zhí)行 Call
        call.enqueue(new Callback() {
            @Override
            public void onFailure(Call call, IOException e) {
                myNetCall.failed(call, e);
            }
            @Override
            public void onResponse(Call call, Response response) throws IOException {
                myNetCall.success(call, response);
            }
        });
    }
    /**
     * 自定義網(wǎng)絡(luò)回調(diào)接口
     */
    public interface MyNetCall {
        /**
         * 請求成功的回調(diào)處理
         *
         * @param call     {@link Call}
         * @param response {@link Response}
         * @throws IOException 異常
         */
        void success(Call call, Response response) throws IOException;
        /**
         * 請求失敗的回調(diào)處理
         *
         * @param call {@link Call}
         * @param e    異常
         */
        void failed(Call call, IOException e);
    }
}

Jackson

請求的響應(yīng)結(jié)果通常是 JSON 數(shù)據(jù)格式，此時我們還可以封裝一個 Jackson 工具類，簡化我們的 JSON 解析過程

public class MapperUtils {
    private final static ObjectMapper objectMapper = new ObjectMapper();
    public static ObjectMapper getInstance() {
        return objectMapper;
    }
    /**
     * 轉(zhuǎn)換為 JSON 字符串
     *
     * @param obj
     * @return
     * @throws Exception
     */
    public static String obj2json(Object obj) throws Exception {
        return objectMapper.writeValueAsString(obj);
    }
    /**
     * 轉(zhuǎn)換為 JSON 字符串，忽略空值
     *
     * @param obj
     * @return
     * @throws Exception
     */
    public static String obj2jsonIgnoreNull(Object obj) throws Exception {
        ObjectMapper mapper = new ObjectMapper();
        mapper.setSerializationInclusion(JsonInclude.Include.NON_NULL);
        return mapper.writeValueAsString(obj);
    }
    /**
     * 轉(zhuǎn)換為 JavaBean
     *
     * @param jsonString
     * @param clazz
     * @return
     * @throws Exception
     */
    public static <T> T json2pojo(String jsonString, Class<T> clazz) throws Exception {
        objectMapper.configure(DeserializationFeature.ACCEPT_SINGLE_VALUE_AS_ARRAY, true);
        return objectMapper.readValue(jsonString, clazz);
    }
    /**
     * 字符串轉(zhuǎn)換為 Map<String, Object>
     *
     * @param jsonString
     * @return
     * @throws Exception
     */
    public static <T> Map<String, Object> json2map(String jsonString) throws Exception {
        ObjectMapper mapper = new ObjectMapper();
        mapper.setSerializationInclusion(JsonInclude.Include.NON_NULL);
        return mapper.readValue(jsonString, Map.class);
    }
    /**
     * 字符串轉(zhuǎn)換為 Map<String, T>
     */
    public static <T> Map<String, T> json2map(String jsonString, Class<T> clazz) throws Exception {
        Map<String, Map<String, Object>> map = objectMapper.readValue(jsonString, new TypeReference<Map<String, T>>() {
        });
        Map<String, T> result = new HashMap<String, T>();
        for (Map.Entry<String, Map<String, Object>> entry : map.entrySet()) {
            result.put(entry.getKey(), map2pojo(entry.getValue(), clazz));
        }
        return result;
    }
    /**
     * 深度轉(zhuǎn)換 JSON 成 Map
     *
     * @param json
     * @return
     */
    public static Map<String, Object> json2mapDeeply(String json) throws Exception {
        return json2MapRecursion(json, objectMapper);
    }
    /**
     * 把 JSON 解析成 List，如果 List 內(nèi)部的元素存在 jsonString，繼續(xù)解析
     *
     * @param json
     * @param mapper 解析工具
     * @return
     * @throws Exception
     */
    private static List<Object> json2ListRecursion(String json, ObjectMapper mapper) throws Exception {
        if (json == null) {
            return null;
        }
        List<Object> list = mapper.readValue(json, List.class);
        for (Object obj : list) {
            if (obj != null && obj instanceof String) {
                String str = (String) obj;
                if (str.startsWith("[")) {
                    obj = json2ListRecursion(str, mapper);
                } else if (obj.toString().startsWith("{")) {
                    obj = json2MapRecursion(str, mapper);
                }
            }
        }
        return list;
    }
    /**
     * 把 JSON 解析成 Map，如果 Map 內(nèi)部的 Value 存在 jsonString，繼續(xù)解析
     *
     * @param json
     * @param mapper
     * @return
     * @throws Exception
     */
    private static Map<String, Object> json2MapRecursion(String json, ObjectMapper mapper) throws Exception {
        if (json == null) {
            return null;
        }
        Map<String, Object> map = mapper.readValue(json, Map.class);
        for (Map.Entry<String, Object> entry : map.entrySet()) {
            Object obj = entry.getValue();
            if (obj != null && obj instanceof String) {
                String str = ((String) obj);
                if (str.startsWith("[")) {
                    List<?> list = json2ListRecursion(str, mapper);
                    map.put(entry.getKey(), list);
                } else if (str.startsWith("{")) {
                    Map<String, Object> mapRecursion = json2MapRecursion(str, mapper);
                    map.put(entry.getKey(), mapRecursion);
                }
            }
        }
        return map;
    }
    /**
     * 將 JSON 數(shù)組轉(zhuǎn)換為集合
     *
     * @param jsonArrayStr
     * @param clazz
     * @return
     * @throws Exception
     */
    public static <T> List<T> json2list(String jsonArrayStr, Class<T> clazz) throws Exception {
        JavaType javaType = getCollectionType(ArrayList.class, clazz);
        List<T> list = (List<T>) objectMapper.readValue(jsonArrayStr, javaType);
        return list;
    }
    /**
     * 獲取泛型的 Collection Type
     *
     * @param collectionClass 泛型的Collection
     * @param elementClasses  元素類
     * @return JavaType Java類型
     * @since 1.0
     */
    public static JavaType getCollectionType(Class<?> collectionClass, Class<?>... elementClasses) {
        return objectMapper.getTypeFactory().constructParametricType(collectionClass, elementClasses);
    }
    /**
     * 將 Map 轉(zhuǎn)換為 JavaBean
     *
     * @param map
     * @param clazz
     * @return
     */
    public static <T> T map2pojo(Map map, Class<T> clazz) {
        return objectMapper.convertValue(map, clazz);
    }
    /**
     * 將 Map 轉(zhuǎn)換為 JSON
     *
     * @param map
     * @return
     */
    public static String mapToJson(Map map) {
        try {
            return objectMapper.writeValueAsString(map);
        } catch (Exception e) {
            e.printStackTrace();
        }
        return "";
    }
    /**
     * 將 JSON 對象轉(zhuǎn)換為 JavaBean
     *
     * @param obj
     * @param clazz
     * @return
     */
    public static <T> T obj2pojo(Object obj, Class<T> clazz) {
        return objectMapper.convertValue(obj, clazz);
    }
    /**
     * 將指定節(jié)點的 JSON 數(shù)據(jù)轉(zhuǎn)換為 JavaBean
     *
     * @param jsonString
     * @param clazz
     * @return
     * @throws Exception
     */
    public static <T> T json2pojoByTree(String jsonString, String treeNode, Class<T> clazz) throws Exception {
        JsonNode jsonNode = objectMapper.readTree(jsonString);
        JsonNode data = jsonNode.findPath(treeNode);
        return json2pojo(data.toString(), clazz);
    }
    /**
     * 將指定節(jié)點的 JSON 數(shù)組轉(zhuǎn)換為集合
     *
     * @param jsonStr  JSON 字符串
     * @param treeNode 查找 JSON 中的節(jié)點
     * @return
     * @throws Exception
     */
    public static <T> List<T> json2listByTree(String jsonStr, String treeNode, Class<T> clazz) throws Exception {
        JsonNode jsonNode = objectMapper.readTree(jsonStr);
        JsonNode data = jsonNode.findPath(treeNode);
        return json2list(data.toString(), clazz);
    }
}
最后編輯于 ：
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成，瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明：文章內(nèi)容（如有圖片或視頻亦包括在內(nèi)）由作者上傳并發(fā)布，文章內(nèi)容僅代表作者本人觀點，簡書系信息發(fā)布平臺，僅提供信息存儲服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容