摘要:接下来,主要以其中的为例,提一下的用法。多请求的代理为所有的请求都添加的错误验证,还要做统一的处理。另外,其中的则是实现来实现。
我们在做客户端的设计实现底层网络架构时候,常常不可避免的一个问题:token的有效验证,若是token过期,则需要先执行refresh token的操作,若是执行refresh token也无效,则需要用户再执行登陆的过程中;而这个refresh token的操作,按理来说,对用户是不可见的。这样的话,我们应该是怎么解决这个问题呢?
本文是采用RxJava + Retrofit来实现网络请求的封装的,则主要讨论这种情况的实现;一般的写法,则主要是在回调中,做一些拦截的判断,这里就不叙述了。
单个请求添加token失效的判断再使用Rxjava的时候,针对单个API出错,再进行重试机制,这里应该使用的操作符是retryWhen, 通过检测固定的错误信息,然后进行retryWhen中的代码,执行重试机制。这里有个很好的例子,就是扔物线写的RxJavaSamples中提到的非一次token的demo。接下来,主要以其中的demo为例,提一下retryWhen的用法。
在Demo中的TokenAdvancedFragment中,可查到如下的代码:
Observable.just(null) .flatMap(new Func1
代码中retryWhen执行体中,主要对throwable做的判断是检测是否为NullPointerException和IllegalArgumentException,其中前者的抛出是在flatMap的代码体中,当用户的token为空抛出的,而IllegalArgumentException是在什么时候抛出来的呢?而retryWhen中的代码体还有fakeApi.getFakeData的调用,看来就是在它之中抛出的,来看一下他的代码:
public ObservablegetFakeData(FakeToken fakeToken) { return Observable.just(fakeToken) .map(new Func1 () { @Override public FakeThing call(FakeToken fakeToken) { ... if (fakeToken.expired) { throw new IllegalArgumentException("Token expired!"); } FakeThing fakeData = new FakeThing(); fakeData.id = (int) (System.currentTimeMillis() % 1000); fakeData.name = "FAKE_USER_" + fakeData.id; return fakeData; } }); }
这里的代码示例中可以看出,当fakeToken失效的时候,则抛出了之前提到的异常。
所以,对token失效的错误信息,我们需要把它以固定的error跑出来,然后在retryWhen中进行处理,针对token失效的错误,执行token重新刷新的逻辑,而其他的错误,必须以Observable.error的形式抛出来,不然它继续执行之前的代码体,陷入一个死循环。
多个请求token失效的处理逻辑当集成了Retrofit之后,我们的网络请求接口则变成了一个个多带带的方法,这时我们需要添加一个全局的token错误抛出,之后还得需要对所有的接口做一个统一的retryWhen的操作,来避免每个接口都所需要的token验证处理。
token失效错误抛出在Retrofit中的Builder中,是通过GsonConvertFactory来做json转成model数据处理的,这里我们就需要重新实现一个自己的GsonConvertFactory,这里主要由三个文件GsonConvertFactory,GsonRequestBodyConverter,GsonResponseBodyConverter,它们三个从源码中拿过来新建即可。主要我们重写GsonResponseBodyConverter这个类中的convert的方法,这个方法主要将ResponseBody转换我们需要的Object,这里我们通过拿到我们的token失效的错误信息,然后将其以一个指定的Exception的信息抛出。
多请求的API代理为所有的请求都添加Token的错误验证,还要做统一的处理。借鉴Retrofit创建接口的api,我们也采用代理类,来对Retrofit的API做统一的代理处理。
建立API代理类
public class ApiServiceProxy { Retrofit mRetrofit; ProxyHandler mProxyHandler; public ApiServiceProxy(Retrofit retrofit, ProxyHandler proxyHandler) { mRetrofit = retrofit; mProxyHandler = proxyHandler; } publicT getProxy(Class tClass) { T t = mRetrofit.create(tClass); mProxyHandler.setObject(t); return (T) Proxy.newProxyInstance(tClass.getClassLoader(), new Class>[] { tClass }, mProxyHandler); } }
这样,我们就需要通过ApiServiceProxy中的getProxy方法来创建API请求。另外,其中的ProxyHandler则是实现InvocationHandler来实现。
public class ProxyHandler implements InvocationHandler { private Object mObject; public void setObject(Object obj) { this.mObject = obj; } @Override public Object invoke(Object proxy, final Method method, final Object[] args) throws Throwable { Object result = null; result = Observable.just(null) .flatMap(new Func1
这里的invoke方法则是我们的重头戏,在其中通过将method.invoke方法包装在Observable中,并添加retryWhen的方法,在retryWhen方法中,则对我们在GsonResponseBodyConverter中暴露出来的错误,做一判断,然后执行重新获取token的操作,这段代码就很简单了。就不再这里细述了。
还有一个重要的地方就是,当token刷新成功之后,我们将旧的token替换掉呢?笔者查了一下,java8中的method类,已经支持了动态获取方法名称,而之前的Java版本则是不支持的。那这里怎么办呢?通过看retrofit的调用,可以知道retrofit是可以将接口中的方法转换成API请求,并需要封装参数的。那就需要看一下Retrofit是如何实现的呢?最后发现重头戏是在Retrofit对每个方法添加的@interface的注解,通过Method类中的getParameterAnnotations来进行获取,主要的代码实现如下:
Annotation[][] annotationsArray = method.getParameterAnnotations(); Annotation[] annotations = null; Annotation annotation = null; if (annotationsArray != null && annotationsArray.length > 0) { for (int i = 0; i < annotationsArray.length; i++) { annotations = annotationsArray[i]; for (int j = 0; j < annotations.length; j++) { annotation = annotations[j]; if (annotation instanceof Query) { if (ACCESS_TOKEN_KEY.equals(((Query) annotation).value())) { args[i] = newToken; } } } } }
这里,则遍历我们所使用的token字段,然后将其替换成新的token.
后记这里,整个完整的代码没有给出,但是思路走下来还是很清晰的。笔者这里的代码是结合了Dagger2一起来完成的,不过代码是一步步完善的。另外,我们还是有许多点可以扩展的,例如,将刷新token的代码变成同步块,只允许单线程的访问,这就交给读者们去一步步完成了。
PS: 转载请注明原文链接
文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。
转载请注明本文地址:https://www.ucloud.cn/yun/12768.html
摘要:注和是当下非常火爆的开源框架,均来自神一般的公司。特点比使用更简单更易用。默认初始化如果使用默认始化后,一切采用默认设置。为单个请求设置超时,比如涉及到文件的需要设置读写等待时间多一点。 github源码地址:https://github.com/zhou-you/RxEasyHttp RxEasyHttp 本库是一款基于RxJava2+Retrofit2实现简单易用的网络请求框架,结...
摘要:使用编写,基于的极速开发框架我们在开发应用程序的时候其实会有很多通用的代码,比方说很常见的页面的几种基本状态的切换正常加载失败加载中空页面。当然,这也是促使我开源出这个使用编写的,基于架构的极速开发框架的主要原因。 KCommon-使用Kotlin编写,基于MVP的极速开发框架 我们在开发Android应用程序的时候其实会有很多通用的代码,比方说很常见的页面的几种基本状态的切换:正常、...
摘要:完成网络请求添加依赖。新的配置获取对象请求在新的线程中执行请求完成后在线程中执行保存用户信息到本地最后在主线程中执行请求失败请求成功形式的时候,把请求封装进,在请求结束后调用或在请求失败后调用。 showImg(https://segmentfault.com/img/remote/1460000018253018); 前言 本文基于RxJava、Retrofit的使用,若是对RxJa...
摘要:完成网络请求添加依赖。新的配置获取对象请求在新的线程中执行请求完成后在线程中执行保存用户信息到本地最后在主线程中执行请求失败请求成功形式的时候,把请求封装进,在请求结束后调用或在请求失败后调用。 showImg(https://segmentfault.com/img/remote/1460000018253018); 前言 本文基于RxJava、Retrofit的使用,若是对RxJa...
摘要:无网读缓存,有网根据过期时间重新请求使用和实现网络缓存。浅析的你了解过吗为什么每次请求都用了长连接完成一次网络请求都经历了什么感兴趣的不妨可以看下。 Android OKHttp3.0 以上使用方法 Android OKHttp3.0 以上使用方法详解 Retrofit 之日志拦截 Retrofit 日志拦截相关介绍 Retrofit源码解析 Retrofit的源码分析将从基本的使用方...
阅读 616·2021-11-22 15:25
阅读 1755·2021-11-16 11:39
阅读 900·2021-10-11 10:56
阅读 1157·2021-09-08 09:45
阅读 1427·2021-09-02 09:46
阅读 1051·2019-08-30 15:56
阅读 1384·2019-08-29 15:14
阅读 1020·2019-08-29 13:06