框架【库】事务k8s

retrofit+rxjava 刷新token并发处理

2018-08-30  本文已影响425人  农田蚂蚁

1、引入:

最近项目中遇到一个很头疼的问题,由于多接口并发请求刷新token失败,导致app老是掉线要重新登录。
当token过期处理首先想到的是在请求回调中获取到token过期的信息,然后进行刷新操作,但是由于项目中使用到的网络请求接口众多,而且大多数接口都有可能会出现token过期的情况,如果多个接口同时去刷新token就会导致token失效,进而导致用户需要重新登录,对用户的体验非常不好。

2、实现思想:

由于项目中的token 是放在 http 请求的 header 中,所以这里使用okhttp 的拦截器来实现。当多个请求都出现了因 token过期而需要重新刷新 token的情况,那么需要判断当前是否有另一个请求正在刷新 token,如果有,那么就不要发起刷新token的请求和其他请求,而是等待刷新 token的请求返回后,直接进行重试。

3、实现如下:

拦截数据判断是否Token过期,并实现并发处理:

private Interceptor mTokenInterceptor = new Interceptor() {
    @Override
    public Response intercept(Chain chain) throws IOException {
        Request request = chain.request();
        Response originalResponse = chain.proceed(request);
        ResponseBody responseBody = originalResponse.body();
        BufferedSource source = responseBody.source();
        source.request(Long.MAX_VALUE);
        Buffer buffer = source.buffer();
        Charset charset = UTF8;
        MediaType contentType = responseBody.contentType();
        if (contentType != null) {
            charset = contentType.charset(UTF8);
        }
        String bodyStr = buffer.clone().readString(charset);
        Gson gson = new Gson();
        HttpResult httpResult = gson.fromJson(bodyStr, HttpResult.class);
        String requestUrl=request.url().encodedPath();
        Log.e("Api","------------>request start>   request_url="+requestUrl);
        synchronized (getInstance()){//同步代码块,当在刷新token的时候暂停其他的request,锁为当前类的单例对象
            //比较请求的token与本地存储的token   如果不一致还是直接重试   
            String request_token=request.header("token");
            String access_token=TokenManager.getTokenInfo().getAccess_token();
            if(request_token!=null&&access_token!=null&&!request_token.equals(access_token)){
                Log.e("Api","------------>request retry   request_url="+requestUrl);
                Request newRequest=request.newBuilder().header("token", TokenManager.getTokenInfo().getAccess_token()).build();//等待的request重新拼装请求头
                return chain.proceed(newRequest);//重试request
            }
            if (httpResult.getCode()==10003){//10003是服务器与客户端约定token过期的标识,在这里就执行刷新token的操作
                Log.e("Api","------------>token longger");
                RequestToken requestToken = new RequestToken();
                requestToken.setRefresh_token("123456789");
                Call<HttpResult<TokenInfo>> call= Api.getInstance().service.refreshTokenSync(requestToken);
                 Log.e("Api","------------>refreshToken start");
                retrofit2.Response<HttpResult<TokenInfo>> response = call.clone().execute();//刷新token必须使用同步请求
                TokenInfo tokenInfo = response.body().getData();
                Log.e("Api","------------>refreshToken end  access_token="+tokenInfo.getAccess_token());
                TokenManager.saveTokenInfo(tokenInfo);//保存token
                isAlreadyRefreshToken=true;//当前请求已经刷新完token了
                Request newRequest=request.newBuilder().header("token", TokenManager.getTokenInfo().getAccess_token()).build();//重新拼装请求头
                return chain.proceed(newRequest);//重试request
            }
        }
        Log.e("Api","------------>request end>   request_url="+requestUrl);
        return originalResponse;
    }
};

添加拦截器:

OkHttpClient client = new OkHttpClient.Builder()
                .addInterceptor(mTokenInterceptor)
                .build();

API

@PATCH("oauth/token")
Call<HttpResult<TokenInfo>> refreshTokenSync(@Body RequestToken requestToken);

并发请求的输出日志

09-03 18:00:48.410 4702-6432/com.test E/Api: ------------>request start>   request_url=/interface/app_active
09-03 18:00:48.410 4702-6432/com.test E/Api: ------------>request end>   request_url=/interface/app_active
09-03 18:00:48.410 4702-6432/com.test E/Api: ------------>token longger
09-03 18:00:48.410 4702-6432/com.test E/Api: ------------>refreshToken start
09-03 18:00:48.414 4702-6430/com.test E/Api: ------------>request start>   request_url=/interface/app_version
09-03 18:00:48.421 4702-6456/com.test E/Api: ------------>request start>   request_url=/interface/hello
09-03 18:00:48.711 4702-6432/com.test E/Api: ------------>request start>   request_url=/interface/oauth/token
09-03 18:00:48.711 4702-6432/com.test E/Api: ------------>request end>   request_url=/interface/oauth/token
09-03 18:00:48.718 4702-6432/com.test E/Api: ------------>refreshToken end  access_token=i m a new token
09-03 18:00:49.516 4702-6430/com.test E/Api: ------------>request retry>   request_url=/interface/app_version
09-03 18:00:51.530 4702-6456/com.test E/Api: ------------>request retry>   request_url=/interface/hello
09-03 18:01:07.295 4702-6432/com.test E/Api: ------------>request start>   request_url=/interface/bat
09-03 18:01:07.295 4702-6432/com.test E/Api: ------------>request end>  request_url=/interface/bat
09-03 18:01:07.777 4702-6456/com.test E/Api: ------------>request start>   request_url=/interface/app_active
09-03 18:01:07.777 4702-6456/com.test E/Api: ------------>request end>   request_url=/interface/app_active

End

经过大量并发请求测试刷新token之后都不再出现token失效的问题,到这里就大功告成了。

上一篇下一篇

猜你喜欢

热点阅读