OkhttpUtils 工具类

记录一下OkhttpUtils工具类

/**
 * Created by IntelliJ IDEA.
 * User: 贝先 [ Cason mo ]
 * Date: 2022/5/20
 * Time: 10:56
 */
public class OkHttpUtils {

    private static final Logger logger = LoggerFactory.getLogger(OkHttpUtils.class);
    public int readTimeout = 100;
    public int connectTimeout = 60;
    public int writeTimeout = 60;
    public static final MediaType JSON = MediaType.parse("application/json; charset=utf-8");
    private static final byte[] LOCKER = new byte[0];
    private static OkHttpUtils mInstance;
    private OkHttpClient mOkHttpClient;

    public void setReadTimeout(int readTimeout) {
        this.readTimeout = readTimeout;
    }

    public void setConnectTimeout(int connectTimeout) {
        this.connectTimeout = connectTimeout;
    }

    public void setWriteTimeout(int writeTimeout) {
        this.writeTimeout = writeTimeout;
    }


    /**
     * 自定义网络回调接口
     */
    public interface NetCall {
        void success(Call call, Response response) throws IOException;

        void failed(Call call, IOException e);
    }

    private OkHttpUtils() {
        okhttp3.OkHttpClient.Builder clientBuilder = new okhttp3.OkHttpClient.Builder();
        clientBuilder.readTimeout(readTimeout, TimeUnit.SECONDS);//读取超时
        clientBuilder.connectTimeout(connectTimeout, TimeUnit.SECONDS);//连接超时
        clientBuilder.writeTimeout(writeTimeout, TimeUnit.SECONDS);//写入超时
        clientBuilder.hostnameVerifier(new HostnameVerifier() {
            @Override
            public boolean verify(String hostname, SSLSession session) {
                return true;
            }
        });
        mOkHttpClient = clientBuilder.build();
    }

    public static OkHttpUtils newInstance() {
        return new OkHttpUtils();
    }

    /**
     * 单例模式获取OkHttpUtil
     *
     * @return
     */
    public static OkHttpUtils getInstance() {
        if (mInstance == null) {
            synchronized (LOCKER) {
                if (mInstance == null) {
                    mInstance = new OkHttpUtils();
                }
            }
        }
        return mInstance;
    }

    public Response get(String url, Map<String, String> params, Headers headers) throws Exception {
        if (headers == null) {
            headers = new Headers.Builder().build();
        }
        Request.Builder builder = new Request.Builder();
        UriBuilder uriBuilder = UriBuilder.fromUri(url);
        if (params != null) {
            for (Map.Entry<String, String> param : params.entrySet()) {
                if (StringUtils.isNotBlank(param.getKey())) {
                    uriBuilder.queryParam(param.getKey(), param.getValue());
                }
            }
        }
        Request request = builder.get().url(uriBuilder.build().toString()).headers(headers).build();
        logger.info("okhttp url : [{}] {} \nheader : {} \nrequestBody : {}", request.method(), request.url(), request.headers(), getRequestBody(request));
        Call call = mOkHttpClient.newCall(request);
        return call.execute();
    }


    public <T> Response post(String url, T t, Headers headers) throws Exception {
        if (headers == null) {
            headers = new Headers.Builder().build();
        }
        Request.Builder requestBuilder = new Request.Builder();
        requestBuilder.post(RequestBody.create(JSON, "")).url(url).headers(headers);
        if (t != null) {
            RequestBody body = RequestBody.create(JSON, JsonUtils.toJSONString(t));
            requestBuilder.post(body);
        }
        Request request = requestBuilder.build();
        logger.info("okhttp url : [{}] {} \nheader : {} \nrequestBody : {}", request.method(), request.url(), request.headers(), getRequestBody(request));
        Call call = mOkHttpClient.newCall(request);
        return call.execute();
    }

    public <T> Response patch(String url, T t, Headers headers) throws Exception {
        if (headers == null) {
            headers = new Headers.Builder().build();
        }
        Request.Builder requestBuilder = new Request.Builder();
        requestBuilder.patch(RequestBody.create(JSON, "")).url(url).headers(headers);
        if (t != null) {
            RequestBody body = RequestBody.create(JSON, JsonUtils.toJSONString(t));
            requestBuilder.patch(body);
        }
        Request request = requestBuilder.build();
        logger.info("okhttp url : [{}] {} \nheader : {} \nrequestBody : {}", request.method(), request.url(), request.headers(), getRequestBody(request));
        Call call = mOkHttpClient.newCall(request);
        return call.execute();
    }

    public Response postJson(String url, String json, Headers headers) throws Exception {
        if (headers == null) {
            headers = new Headers.Builder().build();
        }
        RequestBody body = RequestBody.create(JSON, json);
        Request request = new Request.Builder()
                .url(url)
                .post(body)
                .headers(headers)
                .build();
        logger.info("okhttp url : [{}] {} \nheader : {} \nrequestBody : {}", request.method(), request.url(), request.headers(), getRequestBody(request));
        return mOkHttpClient.newCall(request).execute();
    }

    public <T> Response put(String url, T t, Headers headers) throws Exception {
        if (headers == null) {
            headers = new Headers.Builder().build();
        }
        Request.Builder requestBuilder = new Request.Builder();
        requestBuilder.put(RequestBody.create(JSON, "")).url(url).headers(headers);
        if (t != null) {
            RequestBody body = RequestBody.create(JSON, JsonUtils.toJSONString(t));
            requestBuilder.put(body);
        }
        Request request = requestBuilder.build();
        logger.info("okhttp url : [{}] {} \nheader : {} \nrequestBody : {}", request.method(), request.url(), request.headers(), getRequestBody(request));
        Call call = mOkHttpClient.newCall(request);
        return call.execute();
    }

    public Response putJson(String url, String json, Headers headers) throws Exception {
        if (headers == null) {
            headers = new Headers.Builder().build();
        }
        RequestBody body = RequestBody.create(JSON, json);
        Request request = new Request.Builder()
                .url(url)
                .put(body)
                .headers(headers)
                .build();
        logger.info("okhttp url : [{}] {} \nheader : {} \nrequestBody : {}", request.method(), request.url(), request.headers(), getRequestBody(request));
        return mOkHttpClient.newCall(request).execute();
    }

    public <T> Response delete(String url, T t, Headers headers) throws Exception {
        if (headers == null) {
            headers = new Headers.Builder().build();
        }
        Request.Builder requestBuilder = new Request.Builder();
        requestBuilder.delete().url(url).headers(headers);
        if (t != null) {
            RequestBody body = RequestBody.create(JSON, JsonUtils.toJSONString(t));
            requestBuilder.delete(body);
        }
        Request request = requestBuilder.build();
        logger.info("okhttp url : [{}] {} \nheader : {} \nrequestBody : {}", request.method(), request.url(), request.headers(), getRequestBody(request));
        Call call = mOkHttpClient.newCall(request);
        return call.execute();
    }

    public Response deleteJson(String url, String json, Headers headers) throws Exception {
        if (headers == null) {
            headers = new Headers.Builder().build();
        }
        RequestBody body = RequestBody.create(JSON, json);
        Request request = new Request.Builder()
                .url(url)
                .delete(body)
                .headers(headers)
                .build();
        logger.info("okhttp url : [{}] {} \nheader : {} \nrequestBody : {}", request.method(), request.url(), request.headers(), getRequestBody(request));
        return mOkHttpClient.newCall(request).execute();
    }

    private static String getRequestBody(Request request) throws IOException {
        Buffer buffer = new Buffer();
        if (request.body() != null) {
            request.body().writeTo(buffer);
            return buffer.clone().readUtf8();
        }
        return "";
    }

}