okHttp之intercepter应用场景

总结下okhttp里Intercepter的应用场景：
一.刷新token：
先介绍下token的机制，客户端通过username，password获取token和refreshToken，token的有效期为2小时，refreshToken的有效期为15天，如果服务器端判断token过期，而refreshToken未过期，就返回错误码给客户端，则客户端通过一个特定的接口传入refreshToken参数获取新的token和refreshToken，如果连续15天未使用app或者用户修改了密码，则表示refreshToken过期了，则跳到登录界面，重新登录获取token和refreshToken，refreshToken存在的意义就是不用每次都要用username和password去刷新token。
1.使用okhttp提供的Authenticator接口：
如果接口返回的错误码为401,则可以使用这种方式

public class TokenAuthenticator implements Authenticator {
    @Override
    public Request authenticate(Proxy proxy, Response response) throws IOException {
        if (responseCount(response) >= 3) {
             return null; // 返回空表示不再重试，避免未知情况下的多次请求
        }
        //取出本地的refreshToken
        String refreshToken = "123456789";
        // 通过某个同步方法获取到最新的token
        String newToken =asycGetToken(refreshToken);
        return response.request().newBuilder()
                .header("Authorization", newToken)
                .build();
    }    
}

OkHttpClient client = new OkHttpClient();
client.setAuthenticator(new TokenAuthenticator());

2.使用intercepter拦截

public class TokenInterceptor implements Interceptor {

    @Override
    public Response intercept(Chain chain) throws IOException {
        Request request = chain.request();
        Response originalResponse = chain.proceed(request);
        //获取返回的json字符串（originalResponse.body().string()好像有问题）
        ResponseBody responseBody = originalResponse.body();
        BufferedSource source = responseBody.source();
        source.request(Long.MAX_VALUE); // Buffer the entire body.
        Buffer buffer = source.buffer();
        MediaType contentType = responseBody.contentType();
        if (contentType != null) {
            charset = contentType.charset( Charset.forName("UTF-8"));
        }
        String bodyString = buffer.clone().readString( Charset.forName("UTF-8"));
        if (isExpired (bodyString)){//判断是否过期
            //取出本地的refreshToken
            String refreshToken = "123456789";
            // 通过某个同步方法获取到最新的token
            String newToken = asycGetToken(refreshToken);
            Request newRequest = request.newBuilder().header("Authorization", newToken)
                    .build();
            originalResponse.body().close();
            return chain.proceed(newRequest);
        }
        return originalResponse;
    }
}

二.添加公共头信息
注意okhttp的Header不能添加null，我们需要判空，否则会报空指针

public class HeaderInterceptor implements Interceptor {
    public static final String AUTHORIZATION = "Authorization";

    @Override
    public Response intercept(Chain chain) throws IOException {
        Request original = chain.request();

        String ihuid = ConfigCompat.getIHUID() == null ? "" : ConfigCompat.getIHUID();
        String iccid = ConfigCompat.getICCID() == null ? "" : ConfigCompat.getICCID();
        String msisdn = "";
        String env_type = ConfigCompat.getTspEnv() == null ? "" : ConfigCompat.getTspEnv();
        String model = Build.PRODUCT== null ? "" : Build.PRODUCT;

        String authorization = ConfigCompat.getAccessToken();
        Request.Builder requestBuilder = original.newBuilder()
                .addHeader("Accept", "application/json")
                .addHeader("Content-type", "application/json")
                .addHeader("X-CLIENT-ID", ihuid)
                .addHeader("X-ICCID", iccid)
                .addHeader("X-VEHICLE-IDENTIFIER", "")
                .addHeader("X-ENV-TYPE", env_type)
                .addHeader("X-DEVICE-TYPE", "ihu")
                .addHeader(AUTHORIZATION, authorization)
                .addHeader("X-IHU-ID", ihuid)
                .addHeader("X-MSISDN", msisdn)
                .addHeader("X-APP-ID","M820igii5lL4tcy")
                .addHeader("X-VEHICLE-MODEL",model);

        Request request = requestBuilder.build();

        return chain.proceed(request);
    }
}

三.添加公共请求参数：
现在有个需求需要在get请求里添加参数，post请求的json里添加参数

public class ParamsInterceptor implements Interceptor {
    @Override
    public Response intercept(Chain chain) throws IOException {
        Request request = chain.request();
        String method = request.method();
        if (method.equalsIgnoreCase("GET")) {
            HttpUrl model = request.url().newBuilder().addQueryParameter("model", Build.PRODUCT).build();
            request = request.newBuilder().url(model).build();
        }else if (method.equalsIgnoreCase("POST")) {
            RequestBody requestBody = request.body();
            if (requestBody instanceof FormBody) {
                //application/x-www-form-urlencoded的方式提交
            } else {
                //application/json的方式提交
                Buffer buffer = new Buffer();
                requestBody.writeTo(buffer);
                String oldParamsJson = buffer.readUtf8();
                HashMap<String, Object> rootMap = new Gson().fromJson(oldParamsJson, HashMap.class);
                rootMap.put("model", Build.PRODUCT);
                String newJsonParams = new Gson().toJson(rootMap);

                request = request.newBuilder().post(RequestBody.create(MediaType.parse("application/json"), newJsonParams)).build();
            }
        }
        return chain.proceed(request);
    }
}