OkHttp 源码解读 HTTP

本文主要介绍OkHttp如何使用，源码解读，如何实现HTTP请求？

package com.security.weichat.retrofit;
import android.content.Intent;import android.support.v4.content.LocalBroadcastManager;
import com.google.gson.Gson;import com.google.gson.GsonBuilder;import com.security.weichat.AppConfig;import com.security.weichat.BuildConfig;import com.security.weichat.util.RxBus;import com.security.weichat.volley.Result;
import java.io.IOException;import java.io.Reader;import java.nio.charset.Charset;import java.nio.charset.UnsupportedCharsetException;import java.util.concurrent.TimeUnit;
import okhttp3.Interceptor;import okhttp3.MediaType;import okhttp3.OkHttpClient;import okhttp3.Request;import okhttp3.Response;import okhttp3.ResponseBody;import okhttp3.internal.platform.Platform;import okhttp3.logging.HttpLoggingInterceptor;import okio.Buffer;import okio.BufferedSource;import retrofit2.Retrofit;import retrofit2.adapter.rxjava2.RxJava2CallAdapterFactory;import retrofit2.converter.gson.GsonConverterFactory;
import static com.alibaba.fastjson.util.IOUtils.UTF8;import static com.alibaba.fastjson.util.IOUtils.stringSize;import static com.security.weichat.activity.live.LiveListenerService.EXTRA_DELETE_USER;import static com.security.weichat.activity.live.LiveListenerService.SOCKET_DELETE_USER_EVENT;import static okhttp3.internal.platform.Platform.INFO;
/** * Created by Rabbpig on 2017/7/27. */public class IMSearchUserApi {    private IMSearchUserService mIMSearchUserService;    private Gson mGson;
    IMSearchUserApi(){        mGson = new GsonBuilder()                .setDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSS'Z'")                .serializeNulls()                .create();
        OkHttpClient.Builder builder = new OkHttpClient.Builder();        if (BuildConfig.DEBUG) {            HttpLoggingInterceptor interceptor = new HttpLoggingInterceptor();            interceptor.setLevel(HttpLoggingInterceptor.Level.BODY);            builder.addInterceptor(interceptor);        }// builder.addInterceptor(mInterceptor);        builder.retryOnConnectionFailure(true)                .connectTimeout(15, TimeUnit.SECONDS)                .readTimeout(15,TimeUnit.SECONDS);
        Retrofit retrofit = new Retrofit.Builder()                .baseUrl(AppConfig.getInstance().getServerConfig().getBaseUrl())                .client(builder.build())                .addCallAdapterFactory(RxJava2CallAdapterFactory.create())                .addConverterFactory(GsonConverterFactory.create(mGson))               // .addConverterFactory(FastJsonConverterFactory.create())                .build();
        mIMSearchUserService = retrofit.create(IMSearchUserService.class);        Platform.get().log(INFO, "这是IMSearchUserApi构造方法！！", null);    }
    public IMSearchUserService getIMSearchUserService() {        return mIMSearchUserService;    }
    private Interceptor mInterceptor = new Interceptor() {        @Override        public Response intercept(Chain chain) throws IOException {            Platform logger = Platform.get();            logger.log(INFO, "自定义拦截器！！", null);            Request request = chain.request();            Response response = chain.proceed(request);// Reader reader = response.body().charStream();// logger.log(INFO, "拦截器："+response.toString(), null);            ResponseBody responseBody = response.body();            BufferedSource source = responseBody.source();            source.request(Long.MAX_VALUE); // Buffer the entire body.            Buffer buffer = source.buffer();
            Charset charset = UTF8;            MediaType contentType = responseBody.contentType();            if (contentType != null) {                try {                    charset = contentType.charset(UTF8);                } catch (UnsupportedCharsetException e) {                    logger.log(INFO, "Couldn't decode the response body; charset is likely malformed.", null);                    return response;                }            }            String result = buffer.clone().readString(charset);            Platform.get().log(INFO, "请求结果："+result, null);
            Result resultObj = mGson.fromJson(result, Result.class);
            logger.log(INFO, "转换结果 getResultCode = "+resultObj.getResultCode(), null);
            if (null != resultObj && resultObj.getResultCode() == 1030102){                logger.log(INFO, "自定义拦截器 token 过期，调用 RxBus.getDefault().send(resultObj)", null);                RxBus.getDefault().send(resultObj);                logger.log(INFO, "自定义拦截器 token 过期，需要重新登陆", null);            }
            return response;        }    };