我'm working on networking for my app. So I decided to try out Square' s Retrofit . 我看到他们支持简单 Callback
@GET("/user/{id}/photo")
void getUserPhoto(@Path("id") int id, Callback<Photo> cb);
和RxJava的 Observable
@GET("/user/{id}/photo")
Observable<Photo> getUserPhoto(@Path("id") int id);
乍一看两者看起来都非常相似,但是当它实现时它变得有趣......
虽然简单的回调实现看起来类似于:
api.getUserPhoto(photoId, new Callback<Photo>() {
@Override
public void onSuccess() {
}
});
这非常简单明了 . 随着 Observable
,它很快变得冗长而且相当复杂 .
public Observable<Photo> getUserPhoto(final int photoId) {
return Observable.create(new Observable.OnSubscribeFunc<Photo>() {
@Override
public Subscription onSubscribe(Observer<? super Photo> observer) {
try {
observer.onNext(api.getUserPhoto(photoId));
observer.onCompleted();
} catch (Exception e) {
observer.onError(e);
}
return Subscriptions.empty();
}
}).subscribeOn(Schedulers.threadPoolForIO());
}
那不是它 . 你仍然需要做这样的事情:
Observable.from(photoIdArray)
.mapMany(new Func1<String, Observable<Photo>>() {
@Override
public Observable<Photo> call(Integer s) {
return getUserPhoto(s);
}
})
.subscribeOn(Schedulers.threadPoolForIO())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Action1<Photo>() {
@Override
public void call(Photo photo) {
//save photo?
}
});
我在这里错过了什么吗?或者这是一个错误的情况使用 Observable
?何时/应该更喜欢 Observable
而不是简单的回调?
更新
使用改造比上面的例子简单得多,正如@Niels在他的回答或杰克沃顿的示例项目_1719873中所示 . 但基本上问题保持不变 - 何时应该使用某种方式?
7 回答
对于简单的网络内容,RxJava优于Callback的优势非常有限 . 简单的getUserPhoto示例:
RxJava:
Callback:
RxJava变体并不比Callback变体好多少 . 现在,让我们忽略错误处理 . 我们来看一张照片清单:
RxJava:
Callback:
现在,RxJava变体仍然不小,虽然使用Lambdas它会更接近Callback变体 . 此外,如果您有权访问JSON提要,那么当您只显示PNG时检索所有照片会有点奇怪 . 只需调整Feed即可显示PNG .
第一个结论
当您加载一个准备好格式正确的简单JSON时,它不会使您的代码库变小 .
现在,让我们让事情变得更有趣 . 假设您不仅要检索userPhoto,而且还有Instagram克隆,并且要检索2个JSON:1 . getUserDetails()2 . getUserPhotos()
您希望并行加载这两个JSON,并且当两个JSON都加载时,应该显示该页面 . 回调变体将变得有点困难:您必须创建2个回调,将数据存储在活动中,如果加载了所有数据,则显示页面:
Callback:
RxJava:
我们到了某个地方! RxJava的代码现在与回调选项一样大 . RxJava代码更健壮;想想如果我们需要加载第三个JSON(比如最新的视频)会发生什么? RxJava只需要很小的调整,而Callback变量需要在多个位置进行调整(在每个回调中我们需要检查是否检索了所有数据) .
另一个例子;我们想要创建一个自动完成字段,它使用Retrofit加载数据 . 每当EditText具有TextChangedEvent时,我们都不想进行网络搜索 . 快速键入时,只有最后一个元素应该触发调用 . 在RxJava上我们可以使用debounce运算符:
我不会创建Callback变体但你会明白这是更多的工作 .
结论:当数据作为流发送时,RxJava非常好 . Retrofit Observable同时推送流上的所有元素 . 与回调相比,这本身并不特别有用 . 但是当流上推送多个元素且时间不同时,你需要做与时序相关的事情,RxJava使代码更易于维护 .
Observable的东西已经在Retrofit中完成了,所以代码可能是这样的:
在getUserPhoto()的情况下,RxJava的优势并不大 . 但是,当你为用户获取所有照片时,让我们再举一个例子,但只有当图像是PNG时,你才能访问JSON以在服务器端进行过滤 .
现在,JSON返回Photo的列表 . 我们将它们平面映射到单个项目 . 通过这样做,我们将能够使用过滤方法忽略不是PNG的照片 . 之后,我们将订阅,并在所有行完成后为每张单独的照片,错误处理程序和回调获取回调 .
TLDR 点在这里;回调只返回成功和失败的回调; RxJava Observable允许你做 Map ,缩小,过滤等等 .
使用rxjava,您可以使用更少的代码执行更多操作 .
假设您想在应用中实现即时搜索 . 使用回调,您担心取消订阅上一个请求并订阅对于新的,自己处理方向改变...我认为这是很多代码和太冗长 .
使用rxjava非常简单 .
如果你想实现即时搜索,你只需要监听TextChangeListener并调用
photoModel.setUserId(EditText.getText());
在片段或活动的onCreate方法您订阅的返回photoModel.subscribeToPhoto()可观察的,它返回一个可观察总是发出的最新观察,(要求)emited的项目 .
此外,例如,如果PhotoModel是Singleton,则无需担心方向更改,因为无论您何时订阅,BehaviorSubject都会发出最后一次服务器响应 .
通过这行代码,我们实现了即时搜索并处理方向更改 . 您是否认为可以使用较少代码的回调实现此功能?我对此表示怀疑 .
我们通常采用以下逻辑:
如果这是一个简单的单响应调用,那么Callback或Future会更好 .
如果它's a call with multiple responses (stream), or when there are complex interaction between different calls (see @Niels' answer),则Observables更好 .
看起来你正在重新发明轮子,你正在做的事情已经在改造中实施 .
举个例子,你可以看一下改装的RestAdapterTest.java,其中define an interface以Observable作为返回类型,然后是use it .
通过其他答案中的样本和结论,我认为简单的一步或两步任务没有太大区别 . 但是,Callback简单明了 . RxJava更复杂,对于简单的任务来说太大了 . 有第三种解决方案:AbacusUtil . 让我用以上三种解决方案实现上述用例:Callback,RxJava,CompletableFuture(AbacusUtil)和Retrolambda:
Fetch photo from network and save/display on device:
Load user details and photo in parallel