okHttp介绍:

OkHttp是一个相对成熟的解决方案,据说Android4.4的源码中可以看到
HttpURLConnection已经替换成OkHttp实现了,所以决定选择采用okhttp。
官网地址:http://square.github.io/okhttp/
官方API地址:http://m.blog.csdn.net/article/details?id=50747352
github源码地址:https://github.com/square/okhttp

okHttp、volley、android-async-http对比

volley是一个简单的异步http库,仅此而已。缺点是不支持同步,这点会限制开发模式;不能post大数据,所以不适合用来上传文件
android-async-http。与volley一样是异步网络库,但volley是封装的httpUrlConnection,它是封装的httpClient,而android
    平台不推荐用HttpClient了,所以这个库已经不适合android平台了。
okhttp是高性能的http库,支持同步、异步,而且实现了spdy、http2、websocket协议,api很简洁易用,和volley一样实现了http协议的缓存。

okHttp使用步骤

1.)添加引用 build.gradle添加如下    
compile 'com.squareup.okhttp3:okhttp:3.2.0'

2.)请求类 RequestManager
全局属性说明:
//mdiatype 这个需要和服务端保持一致
private static final MediaType MEDIA_TYPE_JSON = MediaType.parse("application/x-www-form-urlencoded; charset=utf-8");
//mdiatype 这个需要和服务端保持一致
private static final MediaType MEDIA_TYPE_MARKDOWN = MediaType.parse("text/x-markdown; charset=utf-8");
private static final String TAG = RequestManager.class.getSimpleName();
private static final String BASE_URL = "http://172.16.50.95/infocenter";//请求接口根地址
//
private static volatile RequestManager mInstance;//单利引用
public static final int TYPE_GET = 0;//get请求
public static final int TYPE_POST_JSON = 1;//post请求参数为json
public static final int TYPE_POST_FORM = 2;//post请求参数为表单
private OkHttpClient mOkHttpClient;//okHttpClient 实例
private Handler okHttpHandler;//全局处理子线程和M主线程通信

获取操作对象:
/**
 * 初始化RequestManager
 */
private RequestManager(Context context) {
    //初始化OkHttpClient
    mOkHttpClient = new OkHttpClient().newBuilder()
            .connectTimeout(10, TimeUnit.SECONDS)//设置超时时间
            .readTimeout(10, TimeUnit.SECONDS)//设置读取超时时间
            .writeTimeout(10, TimeUnit.SECONDS)//设置写入超时时间
            .build();
    //初始化Handler
    okHttpHandler = new Handler(context.getMainLooper());
}
/**
 * 获取单例引用
 *
 * @return
 */
public static RequestManager getInstance(Context context) {
    RequestManager inst = mInstance;
    if (inst == null) {
        synchronized (RequestManager.class) {
            inst = mInstance;
            if (inst == null) {
                inst = new RequestManager(context.getApplicationContext());
                mInstance = inst;
            }
        }
    }
    return inst;
}

头信息:
 /**
 * 统一为请求添加头信息
 * @return
 */
private Request.Builder addHeaders() {
    Request.Builder builder = new Request.Builder()
            .addHeader("Connection", "keep-alive")
            .addHeader("platform", "2")
            .addHeader("phoneModel", Build.MODEL)
            .addHeader("systemVersion", Build.VERSION.RELEASE)
            .addHeader("appVersion", "3.2.0");
    return builder;
}

3.)同步请求
 /**
 *  okHttp同步请求统一入口
 * @param actionUrl  接口地址
 * @param requestType 请求类型
 * @param paramsMap   请求参数
 */
public void requestSyn(String actionUrl, int requestType, HashMap<String, String> paramsMap) {
    switch (requestType) {
        case TYPE_GET:
            requestGetBySyn(actionUrl, paramsMap);
            break;
        case TYPE_POST_JSON:
            requestPostBySyn(actionUrl, paramsMap);
            break;
        case TYPE_POST_FORM:
            requestPostBySynWithForm(actionUrl, paramsMap);
            break;
    }
}

/**
 * okHttp get同步请求
 * @param actionUrl  接口地址
 * @param paramsMap   请求参数
 */
private void requestGetBySyn(String actionUrl, HashMap<String, String> paramsMap) {
    StringBuilder tempParams = new StringBuilder();
    try {
        //处理参数
        int pos = 0;
        for (String key : paramsMap.keySet()) {
            if (pos > 0) {
                tempParams.append("&");
            }
            //对参数进行URLEncoder
            tempParams.append(String.format("%s=%s", key, URLEncoder.encode(paramsMap.get(key), "utf-8")));
            pos++;
        }
        //补全请求地址
        String requestUrl = String.format("%s/%s?%s", BASE_URL, actionUrl, tempParams.toString());
        //创建一个请求
        Request request = addHeaders().url(requestUrl).build();
        //创建一个Call
        final Call call = mOkHttpClient.newCall(request);
        //执行请求
        final Response response = call.execute();
        response.body().string();
    } catch (Exception e) {
        Log.e(TAG, e.toString());
    }
}
/**
 * okHttp post同步请求
 * @param actionUrl  接口地址
 * @param paramsMap   请求参数
 */
private void requestPostBySyn(String actionUrl, HashMap<String, String> paramsMap) {
    try {
        //处理参数
        StringBuilder tempParams = new StringBuilder();
        int pos = 0;
        for (String key : paramsMap.keySet()) {
            if (pos > 0) {
                tempParams.append("&");
            }
            tempParams.append(String.format("%s=%s", key, URLEncoder.encode(paramsMap.get(key), "utf-8")));
            pos++;
        }
        //补全请求地址
        String requestUrl = String.format("%s/%s", BASE_URL, actionUrl);
        //生成参数
        String params = tempParams.toString();
        //创建一个请求实体对象 RequestBody
        RequestBody body = RequestBody.create(MEDIA_TYPE_JSON, params);
        //创建一个请求
        final Request request = addHeaders().url(requestUrl).post(body).build();
        //创建一个Call
        final Call call = mOkHttpClient.newCall(request);
        //执行请求
        Response response = call.execute();
        //请求执行成功
        if (response.isSuccessful()) {
            //获取返回数据 可以是String,bytes ,byteStream
            Log.e(TAG, "response ----->" + response.body().string());
        }
    } catch (Exception e) {
        Log.e(TAG, e.toString());
    }
}
/**
 * okHttp post同步请求表单提交
 * @param actionUrl 接口地址
 * @param paramsMap 请求参数
 */
private void requestPostBySynWithForm(String actionUrl, HashMap<String, String> paramsMap) {
    try {
        //创建一个FormBody.Builder
        FormBody.Builder builder = new FormBody.Builder();
        for (String key : paramsMap.keySet()) {
            //追加表单信息
            builder.add(key, paramsMap.get(key));
        }
        //生成表单实体对象
        RequestBody formBody = builder.build();
        //补全请求地址
        String requestUrl = String.format("%s/%s", BASE_URL, actionUrl);
        //创建一个请求
        final Request request = addHeaders().url(requestUrl).post(formBody).build();
        //创建一个Call
        final Call call = mOkHttpClient.newCall(request);
        //执行请求
        Response response = call.execute();
        if (response.isSuccessful()) {
            Log.e(TAG, "response ----->" + response.body().string());
        }
    } catch (Exception e) {
        Log.e(TAG, e.toString());
    }
}

4.)异步请求
/**
 * okHttp异步请求统一入口
 * @param actionUrl   接口地址
 * @param requestType 请求类型
 * @param paramsMap   请求参数
 * @param callBack 请求返回数据回调
 * @param <T> 数据泛型
 **/
public <T> Call requestAsyn(String actionUrl, int requestType, HashMap<String, String> paramsMap, ReqCallBack<T> callBack) {
    Call call = null;
    switch (requestType) {
        case TYPE_GET:
            call = requestGetByAsyn(actionUrl, paramsMap, callBack);
            break;
        case TYPE_POST_JSON:
            call = requestPostByAsyn(actionUrl, paramsMap, callBack);
            break;
        case TYPE_POST_FORM:
            call = requestPostByAsynWithForm(actionUrl, paramsMap, callBack);
            break;
    }
    return call;
}

/**
 * okHttp get异步请求
 * @param actionUrl 接口地址
 * @param paramsMap 请求参数
 * @param callBack 请求返回数据回调
 * @param <T> 数据泛型
 * @return
 */
private <T> Call requestGetByAsyn(String actionUrl, HashMap<String, String> paramsMap, final ReqCallBack<T> callBack) {
    StringBuilder tempParams = new StringBuilder();
    try {
        int pos = 0;
        for (String key : paramsMap.keySet()) {
            if (pos > 0) {
                tempParams.append("&");
            }
            tempParams.append(String.format("%s=%s", key, URLEncoder.encode(paramsMap.get(key), "utf-8")));
            pos++;
        }
        String requestUrl = String.format("%s/%s?%s", BASE_URL, actionUrl, tempParams.toString());
        final Request request = addHeaders().url(requestUrl).build();
        final Call call = mOkHttpClient.newCall(request);
        call.enqueue(new Callback() {
            @Override
            public void onFailure(Call call, IOException e) {
                failedCallBack("访问失败", callBack);
                Log.e(TAG, e.toString());
            }

            @Override
            public void onResponse(Call call, Response response) throws IOException {
                if (response.isSuccessful()) {
                    String string = response.body().string();
                    Log.e(TAG, "response ----->" + string);
                    successCallBack((T) string, callBack);
                } else {
                    failedCallBack("服务器错误", callBack);
                }
            }
        });
        return call;
    } catch (Exception e) {
        Log.e(TAG, e.toString());
    }
    return null;
}
/**
 * okHttp post异步请求
 * @param actionUrl 接口地址
 * @param paramsMap 请求参数
 * @param callBack 请求返回数据回调
 * @param <T> 数据泛型
 * @return
 */
private <T> Call requestPostByAsyn(String actionUrl, HashMap<String, String> paramsMap, final ReqCallBack<T> callBack) {
    try {
        StringBuilder tempParams = new StringBuilder();
        int pos = 0;
        for (String key : paramsMap.keySet()) {
            if (pos > 0) {
                tempParams.append("&");
            }
            tempParams.append(String.format("%s=%s", key, URLEncoder.encode(paramsMap.get(key), "utf-8")));
            pos++;
        }
        String params = tempParams.toString();
        RequestBody body = RequestBody.create(MEDIA_TYPE_JSON, params);
        String requestUrl = String.format("%s/%s", BASE_URL, actionUrl);
        final Request request = addHeaders().url(requestUrl).post(body).build();
        final Call call = mOkHttpClient.newCall(request);
        call.enqueue(new Callback() {
            @Override
            public void onFailure(Call call, IOException e) {
                failedCallBack("访问失败", callBack);
                Log.e(TAG, e.toString());
            }

            @Override
            public void onResponse(Call call, Response response) throws IOException {
                if (response.isSuccessful()) {
                    String string = response.body().string();
                    Log.e(TAG, "response ----->" + string);
                    successCallBack((T) string, callBack);
                } else {
                    failedCallBack("服务器错误", callBack);
                }
            }
        });
        return call;
    } catch (Exception e) {
        Log.e(TAG, e.toString());
    }
    return null;
}
/**
 * okHttp post异步请求表单提交
 * @param actionUrl 接口地址
 * @param paramsMap 请求参数
 * @param callBack 请求返回数据回调
 * @param <T> 数据泛型
 * @return
 */
private <T> Call requestPostByAsynWithForm(String actionUrl, HashMap<String, String> paramsMap, final ReqCallBack<T> callBack) {
    try {
        FormBody.Builder builder = new FormBody.Builder();
        for (String key : paramsMap.keySet()) {
            builder.add(key, paramsMap.get(key));
        }
        RequestBody formBody = builder.build();
        String requestUrl = String.format("%s/%s", BASE_URL, actionUrl);
        final Request request = addHeaders().url(requestUrl).post(formBody).build();
        final Call call = mOkHttpClient.newCall(request);
        call.enqueue(new Callback() {
            @Override
            public void onFailure(Call call, IOException e) {
                failedCallBack("访问失败", callBack);
                Log.e(TAG, e.toString());
            }

            @Override
            public void onResponse(Call call, Response response) throws IOException {
                if (response.isSuccessful()) {
                    String string = response.body().string();
                    Log.e(TAG, "response ----->" + string);
                    successCallBack((T) string, callBack);
                } else {
                    failedCallBack("服务器错误", callBack);
                }
            }
        });
        return call;
    } catch (Exception e) {
        Log.e(TAG, e.toString());
    }
    return null;
}
/**
 * 统一同意处理成功信息
 * @param result
 * @param callBack
 * @param <T>
 */
private <T> void successCallBack(final T result, final ReqCallBack<T> callBack) {
    okHttpHandler.post(new Runnable() {
        @Override
        public void run() {
            if (callBack != null) {
                callBack.onReqSuccess(result);
            }
        }
    });
}
/**
 * 统一处理失败信息
 * @param errorMsg
 * @param callBack
 * @param <T>
 */
private <T> void failedCallBack(final String errorMsg, final ReqCallBack<T> callBack) {
    okHttpHandler.post(new Runnable() {
        @Override
        public void run() {
            if (callBack != null) {
                callBack.onReqFailed(errorMsg);
            }
        }
    });
}

回调:
public interface ReqCallBack<T> {
/**
 * 响应成功
 */
void onReqSuccess(T result);

/**
 * 响应失败
 */
void onReqFailed(String errorMsg);
}
Logo

瓜分20万奖金 获得内推名额 丰厚实物奖励 易参与易上手

更多推荐