技术标签: android
目前打算选用Retrofit2+RxJava2作为网络请求框架,下面从源码角度分析下这两个框架是怎么粘合在一起的。
看完本文,你将会看到:
- 动态代理模式在Retrofit中的运用。
- 抽象工厂模式在Retrofit中的运用。
- RxJava2如何和Retrofit结合实现网络请求模块。
//https://api.douban.com/v2/book/1220562
public interface IDoubanService {
@GET("/v2/{book}/{bookId}")
Call<Book> getBookInfo(@Path("book") String book, @Path("bookId") String bookId);
@GET("/v2/{book}/{bookId}")
Observable<Book> getBookInfoObservable(@Path("book") String book, @Path("bookId") String bookId);
}
接口中的方法就是我们实际要执行的网络请求,方法的返回值就是CallAdapter的返回值,如果没有的话,默认返回Call对象。
如果我们自定义了一个返回类型,并且没有加上对应的CallAdapterFactory的话,那么抛出异常,如下:
Caused by: java.lang.IllegalArgumentException: Unable to create call adapter for class java.lang.String
final String bookId = "1220562";
Retrofit retrofit = new Retrofit.Builder()
.baseUrl("https://api.douban.com/")
// 将Response通过GSON转成POJO
.addConverterFactory(GsonConverterFactory.create())
// 将接口方法根据类型返回
.addCallAdapterFactory(RxJava2CallAdapterFactory.create())
.client(new OkHttpClient())
.build();
// 使用Retrofit创建接口的代理对象
IDoubanService service = retrofit.create(IDoubanService.class);
Call<Book> call = service.getBookInfo("book", bookId);
// 使用Call对象获取网络请求结果
Response<Book> response = call.execute();
Book book = response.body();
上面的示例中使用的Call进行获取的网络请求,实际上我们可以通过CallAdapterFactory这种抽象工厂来创建我们自己的返回类型,稍后详细分析。
public <T> T create(final Class<T> service) {
Utils.validateServiceInterface(service);
if (validateEagerly) {
eagerlyValidateMethods(service);
}
return (T) Proxy.newProxyInstance(service.getClassLoader(), new Class<?>[] { service },
new InvocationHandler() {
private final Platform platform = Platform.get();
@Override public Object invoke(Object proxy, Method method, @Nullable Object[] args)
throws Throwable {
// If the method is a method from Object then defer to normal invocation.
if (method.getDeclaringClass() == Object.class) {
return method.invoke(this, args);
}
// Platform这个类用来区分平台,如果是Java8的话,接口中会有default方法
if (platform.isDefaultMethod(method)) {
return platform.invokeDefaultMethod(method, service, proxy, args);
}
// 将这个反射的方法封装成ServiceMethod
// ServiceMethod会将接口中的注解进行解析
ServiceMethod<Object, Object> serviceMethod =
(ServiceMethod<Object, Object>) loadServiceMethod(method);
// 创建真实的Call对象
OkHttpCall<Object> okHttpCall = new OkHttpCall<>(serviceMethod, args);
return serviceMethod.callAdapter.adapt(okHttpCall);
}
});
}
private CallAdapter<T, R> createCallAdapter() {
// 获取接口方法的返回值
Type returnType = method.getGenericReturnType();
// 检查返回类型
if (Utils.hasUnresolvableType(returnType)) {
throw methodError(
"Method return type must not include a type variable or wildcard: %s", returnType);
}
// 返回值不能是void
if (returnType == void.class) {
throw methodError("Service methods cannot return void.");
}
Annotation[] annotations = method.getAnnotations();
try {
//noinspection unchecked
// 最终会从Retrofit的CallAdapter中进行查找,还记得之前的addCallAdapterFactroy()抽象工厂么?
return (CallAdapter<T, R>) retrofit.callAdapter(returnType, annotations);
} catch (RuntimeException e) { // Wide exception range because factories are user code.
throw methodError(e, "Unable to create call adapter for %s", returnType);
}
}
最终会调到Retrofit#nextCallAdapter(),在这个方法中,会进行遍历,将Annotion和returnType传入,直到有一个Factroy能够返回非空的CallAdapter
/**
* Returns a call adapter for interface methods that return {@code returnType}, or null if it
* cannot be handled by this factory.
*/
// 这个方法需要返回非空的CallAdapter
public abstract @Nullable CallAdapter<?, ?> get(Type returnType, Annotation[] annotations,
Retrofit retrofit);
核心的get()
@Override
public CallAdapter<?, ?> get(Type returnType, Annotation[] annotations, Retrofit retrofit) {
Class<?> rawType = getRawType(returnType);
if (rawType == Completable.class) {
// Completable is not parameterized (which is what the rest of this method deals with) so it
// can only be created with a single configuration.
return new RxJava2CallAdapter(Void.class, scheduler, isAsync, false, true, false, false,
false, true);
}
boolean isFlowable = rawType == Flowable.class;
boolean isSingle = rawType == Single.class;
boolean isMaybe = rawType == Maybe.class;
if (rawType != Observable.class && !isFlowable && !isSingle && !isMaybe) {
return null;
}
boolean isResult = false;
boolean isBody = false;
Type responseType;
if (!(returnType instanceof ParameterizedType)) {
String name = isFlowable ? "Flowable"
: isSingle ? "Single"
: isMaybe ? "Maybe" : "Observable";
throw new IllegalStateException(name + " return type must be parameterized"
+ " as " + name + "<Foo> or " + name + "<? extends Foo>");
}
Type observableType = getParameterUpperBound(0, (ParameterizedType) returnType);
Class<?> rawObservableType = getRawType(observableType);
if (rawObservableType == Response.class) {
if (!(observableType instanceof ParameterizedType)) {
throw new IllegalStateException("Response must be parameterized"
+ " as Response<Foo> or Response<? extends Foo>");
}
responseType = getParameterUpperBound(0, (ParameterizedType) observableType);
} else if (rawObservableType == Result.class) {
if (!(observableType instanceof ParameterizedType)) {
throw new IllegalStateException("Result must be parameterized"
+ " as Result<Foo> or Result<? extends Foo>");
}
responseType = getParameterUpperBound(0, (ParameterizedType) observableType);
isResult = true;
} else {
responseType = observableType;
isBody = true;
}
// 一般情况返回一个 RxJava2CallAdapter
return new RxJava2CallAdapter(responseType, scheduler, isAsync, isResult, isBody, isFlowable,
isSingle, isMaybe, false);
}
CallAdapter中有一个核心方法是adapt(),作用是将Call对象转化成任意的类型
/**
* Returns an instance of {
@code T} which delegates to {
@code call}.
* <p>
* For example, given an instance for a hypothetical utility, {
@code Async}, this instance would
* return a new {
@code Async<R>} which invoked {
@code call} when run.
* <pre><code>
* @Override
* public <R> Async<R> adapt(final Call<R> call) {
* return Async.create(new Callable<Response<R>>() {
* @Override
* public Response<R> call() throws Exception {
* return call.execute();
* }
* });
* }
* </code></pre>
*/
T adapt(Call<R> call);
RxJava2CallAdapter中的实现
// 此处就将Call对象转换成Observable了
@Override public Object adapt(Call<R> call) {
// 先创建一个Observable对象,根据是否是异步,默认情况下不是异步
Observable<Response<R>> responseObservable = isAsync
? new CallEnqueueObservable<>(call)
: new CallExecuteObservable<>(call);
Observable<?> observable;
if (isResult) {
observable = new ResultObservable<>(responseObservable);
} else if (isBody) {
observable = new BodyObservable<>(responseObservable);
} else {
observable = responseObservable;
}
if (scheduler != null) {
observable = observable.subscribeOn(scheduler);
}
if (isFlowable) {
return observable.toFlowable(BackpressureStrategy.LATEST);
}
if (isSingle) {
return observable.singleOrError();
}
if (isMaybe) {
return observable.singleElement();
}
if (isCompletable) {
return observable.ignoreElements();
}
return observable;
}
RxJava接受网络请求的过程如下
observable
// 网络请求在IO线程执行
.subscribeOn(Schedulers.io())
// 回调到主线程
.observeOn(AndroidSchedulers.mainThread())
.subscribe((book) -> {
mTvText.setText(String.valueOf(book));
});
Retrofit+Factory将网络请求抽象成了一个Observable对象,那么我们可以通过RxJava这样的方法操作网络请求了。
Retrofit返回Observable的实现是CallExecuteObservable或者CallEnqueueObservable,我们看下这个Observable的实现。
final class CallExecuteObservable<T> extends Observable<Response<T>> {
private final Call<T> originalCall;
CallExecuteObservable(Call<T> originalCall) {
this.originalCall = originalCall;
}
// 如果在Observeable中进行订阅操作,那么实际会调用到这个方法
@Override protected void subscribeActual(Observer<? super Response<T>> observer) {
// Since Call is a one-shot type, clone it for each new observer.
Call<T> call = originalCall.clone();
observer.onSubscribe(new CallDisposable(call));
boolean terminated = false;
try {
// 会调用Call执行网络请求,获取Response对象
Response<T> response = call.execute();
if (!call.isCanceled()) {
observer.onNext(response);
}
if (!call.isCanceled()) {
terminated = true;
observer.onComplete();
}
} catch (Throwable t) {
Exceptions.throwIfFatal(t);
if (terminated) {
RxJavaPlugins.onError(t);
} else if (!call.isCanceled()) {
try {
observer.onError(t);
} catch (Throwable inner) {
Exceptions.throwIfFatal(inner);
RxJavaPlugins.onError(new CompositeException(t, inner));
}
}
}
}
private static final class CallDisposable implements Disposable {
private final Call<?> call;
CallDisposable(Call<?> call) {
this.call = call;
}
@Override public void dispose() {
call.cancel();
}
@Override public boolean isDisposed() {
return call.isCanceled();
}
}
}
文章浏览阅读1.2w次,点赞2次,收藏6次。PyCharm 的初始设置(知道)目标恢复 PyCharm 的初始设置第一次启动 PyCharm新建一个 Python 项目设置 PyCharm 的字体显示PyCharm 的升级以及其他PyCharm 的官方网站地址是:https://www.jetbrains.com/pycharm/01. 恢复 PyCharm 的初始设置PyCharm 的 配置信息 是保存在 用户家目录下 的 .PyCharmxxxx.x 目录下的,xxxx.x 表示当前使用的 PyCharm 的版本号如果要恢_1、编写一个名为char.sh的脚本,功能如下(40分): a)由用户输入一个字符 b)判断
文章浏览阅读4.8k次。前言:①取消task任务之CancellationTokenSource的用法;②task的线程管控方法Task..Wait(time),Task.WaitAll(),Task.Wait..._c# task.start cancel token
文章浏览阅读435次。描述As head of the Accessible Commuting Movement (ACM), you've been lobbying the mayor to build a new highway in your city. Today is your lucky day, because your request was approved. There is one c..._最短路 树的直径
文章浏览阅读110次。微信作为中国最受欢迎的社交媒体平台之一,提供了一个独特的机会,即通过搭建个人微信公众号查券返利机器人,帮助用户省钱购物,同时实现自身佣金收入。本文将为您提供一个详细的教程,指导您如何在微赚淘客系统的支持下,搭建您自己的查券返利机器人。通过以上步骤,您的微信公众号将具备查券与返利的功能。您的粉丝将能够通过您的公众号找到商品的最佳优惠券,从而实现省钱购物。同时,您将获得佣金,因为您的粉丝通过您的链接购买商品。链接:https://juejin.cn/post/7288517000581578806。
文章浏览阅读1.9k次。Description有一天,小猫rainbow和freda来到了湘西张家界的天门山玉蟾宫,玉蟾宫宫主蓝兔盛情地款待了它们,并赐予它们一片土地。 这片土地被分成N*M个格子,每个格子里写着’R’或者’F’,R代表这块土地被赐予了rainbow,F代表这块土地被赐予了freda。 现在freda要在这里卖萌。。。它要找一块矩形土地,要求这片土地都标着’F’并且面积最大。 但是rainbow和fr_rainbow和freda来到了湘
文章浏览阅读1.7w次。package mainimport ( "fmt" "time")func main() { t := time.Now() //2019-07-31 13:55:21.3410012 +0800 CST m=+0.006015601 fmt.Println(t.Format("20060102150405")) //当前时间戳 t1 := time.Now().Unix() //1564552562 fmt.Println(t1_go 获取当前时间 t
文章浏览阅读1.8k次。Linux ssh命令ssh远程登录ssh讲解示例ssh登录限制_远程登录 xauth 是什么
文章浏览阅读8.8k次,点赞10次,收藏83次。UltraFastYoloV5发布!基于剪枝技术的模型压缩,3ms推理的YoloV5mAP60+_怎么看yolov5剪枝效果
文章浏览阅读440次。许多渗透测试人员和攻击者通常都会使用一种被称为“密码喷洒(Password Spraying)”的技术来进行测试和攻击。对密码进行喷洒式的攻击,这个叫法很形象,因为它属于自动化密码猜测的一种。这种针对所有用户的自动密码猜测通常是为了避免帐户被锁定,因为针对同一个用户的连续密码猜测会导致帐户被锁定。所以只有对所有用户同时执行特定的密码登录尝试,才能增加破..._事件4771 错误代码0x18
文章浏览阅读79次。Vue.js作为目前最热门最具前景的前端框架之一,其提供了一种帮助我们快速构建并开发前端项目的新的思维模式。本文旨在帮助大家认识Vue.js,了解Vue.js的开发流程,并进一步理解如何通过Vue.js来构建一个中大型的前端项目,同时做好相应的部署与优化工作。文章将以PPT图片附加文字介绍的形式展开,不会涉及知识点的具体代码,点到为止。有兴趣的同学可以..._前端vue可以输入图或文字
文章浏览阅读7.1k次,点赞15次,收藏14次。软考中级——系统集成项目管理工程师备考干货第十一章:项目人力资源管理。_软考 项目人力资源管理
文章浏览阅读2.1w次,点赞4次,收藏34次。定时开机的方法windows定时开机是利用任务计划来实现的,具体的步骤如下(Win7为例):右击【计算机】 —> 管理 —> 依次按下图顺序点击,创建基本任务任务基本信息触发器根据需要自选选择操作。这里是关键性的一步,要选择启动程序,然后根据自己的需要启动某个脚本(如果只是想开机的话,就随便选一个浏览器之类的可执行程序 *.exe),下一步,点击完成。双击任务,选..._定时开机脚本怎么写