OkHttp封装网络请求

/**
* OkHttp封装网络请求
*/
public class OkHttpUtils {

    private static final String MEDIA_TYPE = "application/json;charset=utf-8";
    private static final String METHOD_GET = "GET";
    private static final String METHOD_POST = "POST";
    private static final String METHOD_PUT = "PUT";
    private static final String METHOD_DELETE = "DELETE";
    private static OkHttpClient okHttpClient;
    private static Gson gson = new Gson();

    /**
     * 私有化构造方法
     * 使用单例模式
     */
    private OkHttpUtils() {

    }

    public static void init(Map headers) {
        OkHttpClient.Builder builder = new OkHttpClient.Builder();
        builder.connectTimeout(3000, TimeUnit.MILLISECONDS);
        builder.readTimeout(3000, TimeUnit.MILLISECONDS);
        builder.writeTimeout(3000, TimeUnit.MILLISECONDS);
        builder.addInterceptor(new OKHeaderInterceptor(headers));//添加请求头
        builder.addInterceptor(new OkLogInterceptor());//添加log日志
        okHttpClient = builder.build();
    }

    /**
     * 创建request对象
     * @param url
     * @param method
     * @param baseRequest
     * @return
     */

    public static Request createRequest(String url, String method, BaseRequest baseRequest) {
        RequestBody requestBody = null;
        if (baseRequest != null) {
            String bodyJson = gson.toJson(baseRequest);
            MediaType JSON = MediaType.parse(MEDIA_TYPE);
            requestBody = RequestBody.create(JSON, bodyJson);
        }
        Request.Builder builder = new Request.Builder().url(url);

        Request request = null;

        switch (method) {
            case METHOD_GET:
                request = builder.build();
                break;
            case METHOD_POST:
                request = builder.post(requestBody).build();
                break;
            case METHOD_PUT:
                if (requestBody != null) {
                    request = builder.put(requestBody).build();
                }
                break;
            case METHOD_DELETE:
               if (requestBody!=null){
                   request = builder.delete(requestBody).build();
               }else {
                   request = builder.delete().build();
               }
                break;
        }
        return request;
    }

    /**
     * 异步post方法
     * @param url
     * @param baseRequest
     * @param callback
     */
    public static void enqueuePost(String url,BaseRequest baseRequest, Callback callback){
        Request request = createRequest(url,METHOD_POST,baseRequest);
        Call call = okHttpClient.newCall(request);
        call.enqueue(callback);
    }

    /**
     * 异步get方法
     * @param url
     * @param callback
     */
    public static void enqueueGet(String url,Callback callback){
        Request request = createRequest(url,METHOD_GET,null);
        Call call = okHttpClient.newCall(request);
        call.enqueue(callback);
    }

    /**
     * 同步post方法 不能再主线程中调用
     * @param url
     * @param baseRequest
     * @return
     * @throws IOException
     */
    public static Response executePost(String url,BaseRequest baseRequest) throws IOException {
        Request request = createRequest(url,METHOD_POST,baseRequest);
        Call call = okHttpClient.newCall(request);
        Response response = call.execute();
        return response;
    }

    public static Response executeGet(String url) throws IOException {
        Request request = createRequest(url, METHOD_GET, null);
        Call call = okHttpClient.newCall(request);
        Response response = call.execute();
        return response;
    }
}

请求日志拦截器

public class OkLogInterceptor implements Interceptor {
    @Override
    public Response intercept(Chain chain) throws IOException {
        Request request = chain.request();
        String method = request.method();
        HttpUrl url = request.url();
        Log.d("本次请求", "url:" + url.toString() + "=====method=====" + method);
        Log.d("本次json", "json" + request.toString());

        Headers headers = request.headers();
        Set<String> names = headers.names();
        Iterator<String> iterator = names.iterator();
        while (iterator.hasNext()) {
            String next = iterator.next();
            String value = headers.get(next);
            Log.d("=============",next + ":" + value);
        }

        return chain.proceed(request);
    }
}

请求头拦截器

public class OKHeaderInterceptor implements Interceptor {

    private Map<String,String> headers;

    public OKHeaderInterceptor(Map headers){
        if (headers!=null){
            this.headers = headers;
        }
    }
    @Override
    public Response intercept(Chain chain) throws IOException {

        Request request= chain.request();
        Request.Builder builder = request.newBuilder();
        if (headers!=null){
            Set set = headers.keySet();
            Iterator<String> iterator = set.iterator();
            while (iterator.hasNext()){
                String next = iterator.next();
                builder.addHeader(next,headers.get(next));
            }
        }
        request = builder.build();
        return chain.proceed(request);
    }
}
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。