OkHttp3二次封装

1.HttpUtil 网络访问工具类

import org.json.JSONObject;

import java.io.IOException;
import java.net.URLEncoder;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.TimeUnit;

import okhttp3.Call;
import okhttp3.Callback;
import okhttp3.MediaType;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.RequestBody;
import okhttp3.Response;

public class HttpUtil {
    private static final MediaType MEDIA_TYPE_JSON = MediaType.parse("application/json; charset=utf-8");//mdiatype 这个需要和服务端保持一致
    private static Handler mainHandler = new Handler(Looper.getMainLooper());
    private static OkHttpClient okHttpClient;
    private static JSONObject jsonObject;
    private static OkHttpClient getInstance() {
        if (okHttpClient == null) {
            synchronized (HttpUtil.class) {
                if (okHttpClient == null) {
                    okHttpClient = new OkHttpClient.Builder()
                            .connectTimeout(10, TimeUnit.SECONDS)//10秒连接超时
                            .writeTimeout(10, TimeUnit.SECONDS)//10m秒写入超时
                            .readTimeout(10, TimeUnit.SECONDS)//10秒读取超时
                            //.addInterceptor(new HttpHeaderInterceptor())//头部信息统一处理
                            //.addInterceptor(new CommonParamsInterceptor())//公共参数统一处理
                            .build();
                }
            }
        }
        return okHttpClient;
    }

    /**
     * @param url      url地址
     * @param callBack 请求回调接口
     */
    public static void get(String url, HttpCallBack callBack) {
        commonGet(getRequestForGet(url, null, null), CommonJson.class, callBack);
    }

    /**
     * @param url      url地址
     * @param cls      泛型返回参数
     * @param callBack 请求回调接口
     */
    public static <T extends CommonJson> void get(String url, Class<T> cls, HttpCallBack<T> callBack) {
        commonGet(getRequestForGet(url, null, null), cls, callBack);
    }

    /**
     * @param url      url地址
     * @param params   HashMap<String, String> 参数
     * @param callBack 请求回调接口
     */
    public static void get(String url, HashMap<String, String> params, HttpCallBack callBack) {
        commonGet(getRequestForGet(url, params, null), CommonJson.class, callBack);
    }

    /**
     * @param url      url地址
     * @param params   HashMap<String, String> 参数
     * @param cls      泛型返回参数
     * @param callBack 请求回调接口
     */
    public static <T extends CommonJson> void get(String url, HashMap<String, String> params, Class<T> cls, HttpCallBack<T> callBack) {
        commonGet(getRequestForGet(url, params, null), cls, callBack);
    }

    /**
     * @param url      url地址
     * @param params   HashMap<String, String> 参数
     * @param callBack 请求回调接口
     * @param tag      网络请求tag
     */
    public static void get(String url, HashMap<String, String> params, HttpCallBack callBack, Object tag) {
        commonGet(getRequestForGet(url, params, tag), CommonJson.class, callBack);
    }

    /**
     * @param url      url地址
     * @param params   HashMap<String, String> 参数
     * @param callBack 请求回调接口
     * @param cls      泛型返回参数
     * @param tag      网络请求tag
     */
    public static <T extends CommonJson> void get(String url, HashMap<String, String> params, Class<T> cls, HttpCallBack<T> callBack, Object tag) {
        commonGet(getRequestForGet(url, params, tag), cls, callBack);
    }


    /**
     * @param url      url地址
     * @param callBack 请求回调接口
     */
    public static void post(String url, HttpCallBack callBack) {
        commonPost(getRequestForPost(url, null, null), CommonJson.class, callBack);
    }

    /**
     * @param url      url地址
     * @param cls      泛型返回参数
     * @param callBack 请求回调接口
     */
    public static <T extends CommonJson> void post(String url, Class<T> cls, HttpCallBack<T> callBack) {
        commonPost(getRequestForPost(url, null, null), cls, callBack);
    }


    /**
     * @param url      url地址
     * @param params   HashMap<String, Object> 参数
     * @param callBack 请求回调接口
     */
    public static void post(String url, HashMap<String, Object> params, HttpCallBack callBack) {
        commonPost(getRequestForPost(url, params, null), CommonJson.class, callBack);
    }

    /**
     * @param url      url地址
     * @param params   HashMap<String, Object> 参数
     * @param callBack 请求回调接口
     * @param tag      网络请求tag
     */
    public static void post(String url, HashMap<String, Object> params, HttpCallBack callBack, Object tag) {
        commonPost(getRequestForPost(url, params, tag), CommonJson.class, callBack);
    }

    /**
     * @param url      url地址
     * @param params   HashMap<String, Object> 参数
     * @param cls      泛型返回参数
     * @param callBack 请求回调接口
     */
    public static <T extends CommonJson> void post(String url, HashMap<String, Object> params, Class<T> cls, final HttpCallBack<T> callBack) {
        commonPost(getRequestForPost(url, params, null), cls, callBack);
    }

    /**
     * GET请求 公共请求部分
     */
    private static <T extends CommonJson> void commonGet(Request request, final Class<T> cls, final HttpCallBack<T> callBack) {
        if (request == null) return;
        Call call = getInstance().newCall(request);
        call.enqueue(new Callback() {
            @Override
            public void onFailure(@NonNull Call call, @NonNull final IOException e) {
                try {
                    if (callBack != null && mainHandler != null) {
                        mainHandler.post(new Runnable() {
                            @Override
                            public void run() {
                                callBack.onFailure(e.getMessage());
                            }
                        });
                    }
                } catch (Exception e1) {
                    Log.e("caoliang", "HttpUtil----commonGet()---onFailure()--->" + e.getMessage());
                }
            }

            @Override
            public void onResponse(@NonNull Call call, @NonNull Response response) {
                try {
                    final T json = GsonUtil.parseJson(response.body().string(), cls);
                    if (callBack != null && mainHandler != null && json != null) {
                        mainHandler.post(new Runnable() {
                            @Override
                            public void run() {
                                callBack.onSuccess(json);
                            }
                        });
                    } else {
                        Log.e("caoliang", "HttpUtil----commonGet()---onResponse()--->" + json.toString());
                    }
                } catch (Exception e) {
                    Log.e("caoliang", "HttpUtil----commonGet()---onResponse()--->" + e.getMessage());
                }
            }
        });
    }

    /**
     * POST请求 公共请求部分
     */
    private static <T extends CommonJson> void commonPost(Request request, final Class<T> cls, final HttpCallBack<T> callBack) {
        if (request == null) return;
        Call call = getInstance().newCall(request);
        call.enqueue(new Callback() {
            @Override
            public void onFailure(@NonNull Call call, @NonNull final IOException e) {
                try {
                    if (callBack != null && mainHandler != null) {
                        mainHandler.post(new Runnable() {
                            @Override
                            public void run() {
                                callBack.onFailure(e.getMessage());
                            }
                        });
                    }
                } catch (Exception e1) {
                    Log.e("caoliang", "HttpUtil----commonPost()---onFailure()--->" + e1.getMessage());
                }
            }

            @Override
            public void onResponse(@NonNull Call call, @NonNull Response response) {
                try {
                    if (callBack != null && mainHandler != null) {
                        final T json = GsonUtil.parseJson(response.body().string(), cls);
                        mainHandler.post(new Runnable() {
                            @Override
                            public void run() {
                                callBack.onSuccess(json);
                            }
                        });
                    }
                } catch (Exception e) {
                    Log.e("caoliang", "HttpUtil----commonPost()---onResponse()--->" + e.getMessage());
                }
            }

        });
    }

    private static Request getRequestForPost(String url, Map<String, Object> params, Object tag) {
        if (url == null || "".equals(url)) {
            Log.e("caoliang", "HttpUtil----getRequestForPost()---->" + "url地址为空 无法执行网络请求!!!");
            return null;
        }
        if (params == null) {
            params = new HashMap<>();
        }
        //判断用户是否登录 登录带上用户基础参数 如只需要userId token接口无需传参数
        if (UserManager.getIsLogined()) {
            params.put("userId", UserManager.getUserId());
            params.put("token", UserManager.getToken());
        }
        RequestBody body = RequestBody.create(MEDIA_TYPE_JSON, GsonUtil.toJson(params));
        Request request;
        if (tag != null) {
            request = new Request.Builder().url(url).post(body).tag(tag).build();
        } else {
            request = new Request.Builder().url(url).post(body).build();
        }
        return request;
    }

    private static Request getRequestForGet(String url, HashMap<String, String> params, Object tag) {
        if (url == null || "".equals(url)) {
            Log.e("caoliang", "HttpUtil----getRequestForGet()---->" + "url地址为空 无法执行网络请求!!!");
            return null;
        }
        Request request;
        if (tag != null) {
            request = new Request.Builder()
                    .url(paramsToString(url, params))
                    .tag(tag)
                    .build();
        } else {
            request = new Request.Builder()
                    .url(paramsToString(url, params))
                    .build();
        }
        return request;
    }

    private static String getCommonParamsForGet(StringBuilder sb) {
        if (UserManager.getIsLogined()) {
            sb.append("&").append("userId").append("=").append(String.valueOf(UserManager.getUserId()));
            sb.append("&").append("token").append("=").append(UserManager.getToken());
        }
        return sb.toString();

    }

    /**
     * Post 添加公共参数
     */
    private static JSONObject getCommonParamsForPost() {
        jsonObject = new JSONObject();
        try {
            if (UserManager.getIsLogined()) {
                jsonObject.put("userId", UserManager.getUserId());
                jsonObject.put("token", UserManager.getToken());
            }
        } catch (Exception e) {
            Log.e("caoliang", "HttpUtil----getCommonParamsForPost()---->" + e.getMessage());
            return jsonObject;
        }
        return jsonObject;
    }


    private static String paramsToString(String url, HashMap<String, String> params) {
        StringBuilder url_builder = new StringBuilder();
        url_builder.append(url);
        url_builder.append("?");
        if (params != null && params.size() > 0) {
            for (Map.Entry<String, String> entry : params.entrySet()) {
                try {
                    url_builder.append("&").append(entry.getKey()).append("=").append(URLEncoder.encode(entry.getValue(), "UTF-8"));
                } catch (Exception e) {
                    e.printStackTrace();
                    url_builder.append("&").append(entry.getKey()).append("=").append(entry.getValue());
                }
            }
        }
        return getCommonParamsForGet(url_builder);
    }

    /**
     * 根据tag标签取消网络请求
     */
    public static void cancelTag(Object tag) {
        if (tag == null) return;
        for (Call call : getInstance().dispatcher().queuedCalls()) {
            if (tag.equals(call.request().tag())) {
                call.cancel();
            }
        }
        for (Call call : getInstance().dispatcher().runningCalls()) {
            if (tag.equals(call.request().tag())) {
                call.cancel();
            }
        }
    }


    /**
     * 取消所有请求请求
     */
    public static void cancelAll() {
        for (Call call : getInstance().dispatcher().queuedCalls()) {
            call.cancel();
        }
        for (Call call : getInstance().dispatcher().runningCalls()) {
            call.cancel();
        }
    }

}

2.CommonJson 公共参数返回集合 其他实体类继承该类

package com.example.administrator.okhttp;

import java.io.Serializable;

public class CommonJson implements Serializable {

    private int status;//0为成功
    private String des;

    /**
     * 是否正常相应
     * @return  true or false
     */
    public boolean isOk() {
        return 0 == this.status;
    }

    public int getStatus() {
        return status;
    }

    public void setStatus(int status) {
        this.status = status;
    }

    public String getDes() {
        return des;
    }

    public void setDes(String des) {
        this.des = des;
    }


    @Override
    public String toString() {
        return "CommonJson{" +
                "status=" + status +
                ", des='" + des + '\'' +
                '}';
    }
}