在前三部分,我在通用层面介绍了RxJava的工作原理。但是作为一个Android开发者,如何在工作中使用它呢?下面是一些给Android开发者的RxJava的具体应用。
RxAndroid
RxAndroid是RxJava在Android开发中的拓展。它包含能节省我们大量时间的特殊bindings。
首先,其中有AndroidSchedulers
,它能提供专门为Android线程系统提供的schedulers。需要在UI线程运行代码?没问题——只需要使用AndroidSchedulers.mainThread()
方法即可:
retrofitService.getImage(url)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(bitmap -> myImageView.setImageBitmap(bitmap));
如果你拿到的是Handler
,可以通过HandlerThreadScheduler
创建一个scheduler绑定在Handler上。
接下来介绍的是AndroidObservable
,它能提供很多在Android生命周期中的特色功能。bindActivity()
和bindFragment()
方法能停止发出items,在Activity
或Fragment
结束的时候。另外会自动为订阅使用AndroidSchedulers.mainThread()
。(因此你不需要在Activity或Fragment无效的时候来改变状态)。
AndroidObservable.bindActivity(this, retrofitService.getImage(url))
.subscribeOn(Schedulers.io())
.subscribe(bitmap -> myImageView.setImageBitmap(bitmap));
我也喜欢AndroidObservable.fromBroadcast()
,它让我们可以创建一个像BroadcastReceiver
那样工作的Observable
。以下是无论什么时候网络连接发生变化时通知的方法。
IntentFilter filter = new IntentFilter(ConnectivityManager.CONNECTIVITY_ACTION);
AndroidObservable.fromBroadcast(context, filter)
.subscribe(intent -> handleConnectivityChange(intent));
最后介绍的是ViewObservable
,它能为Views
添加bindings
。如果你想要得到View
每次被点击的事件,可以通过ViewObservable.clicks()
方法。也可以通过ViewObservable.text()
方法来监测TextView
的内容发生的任何变化。
ViewObservable.clicks(mCardNameEditText, false)
.subscribe(view -> handleClick(view));
Retrofit
有一个知名并且支持RxJava的库:Retrofit,它是Android开发中的非常出名的REST风格的网络库。通常,我们定义一个异步方法并添加Callback
:
@GET("/user/{id}/photo")
void getUserPhoto(@Path("id") int id, Callback<Photo> cb);
用了RxJava,可以用Observable
代替Callback
作为返回值。
@GET("/user/{id}/photo")
Observable<Photo> getUserPhoto(@Path("id") int id);
现在可以对Observable
做你想要的操作了,不仅可以获得数据,也能变换它。
Retrofit支持Observable
,也使得合并多个REST请求变得容易。例如,假设我们有一个请求获得图片,另一个请求获得元数据(metadata)。我们可以把结果组合到一起:
Observable.zip(
service.getUserPhoto(id),
service.getPhotoMetadata(id),
(photo, metadata) -> createPhotoWithData(photo, metadata))
.subscribe(photoWithData -> showPhoto(photoWithData));
我在第二部分展示了相似的例子(使用flatMap()
)。这便证明使用RxJava+Retrofit合并多个REST请求有多简单。
旧的,耗时长的代码
Retrofit能返回Observerables
这固然非常好,但是如果你用的其他的库不支持它呢?或者你想要将一些内部代码转换为Observables
?总之,你如何将旧的代码和新的代码联系在一起,而不用重写所有代码?
Observable.just()
和Observable.from()
大多数时候足以将以前的代码转换为Observable
:
private Object oldMethod() { ... }
public Observable<Object> newMethod() {
return Observable.just(oldMethod());
}
这在oldMethod()
耗时少的情况下能正常工作,但是如果耗时长呢?因为调用oldMethod()
,在它被传递到Observable.just()
方法前就会阻塞了线程。
为了对付这个问题,以下是我一直使用的方法——使用defer
方法将耗时长的部分包装起来。
private Object slowBlockingMethod() { ... }
public Observable<Object> newMethod() {
return Observable.defer(() -> Observable.just(slowBlockingMethod()));
}
现在, 直到你订阅Observable
才会去调用slowBlockMethod()
方法。
生命周期
我把最难的部分留在了最后。你是如何处理RxJava与Activity的生命周期的(配合使用的)?以下两个问题会多次出现:
-
1.Activity的配置发生变化后继续订阅一个
Subscribtion
假设你用Retrofit做了一次REST请求,想要把请求结果展示在
ListView
上。如果用户旋转了屏幕怎么办?如果你想要继续相同的请求,但是如何做呢? -
2.
Observables
持有Context
引用会造成内存泄漏。这个问题是由于创建了一个以某种方式持有
Context
的subscribtion
,特别是你和Views
交互的时候容易出现。如果Observable
没有准时完成,最后可能持有非常多的额外内存。
不幸的是,两个问题都没有很好的解决办法。但是有一些能节约你时间的指导方针。
第一个问题能用一些RxJava内置的缓存机制解决,因此你可以取消订阅/再订阅同一个Observable
,而不需要重复它之前的(准备)工作。特别的,cache()
(或是replay()
)方法将继续在(方法)之下的请求(即使你取消订阅)。这意味着Activity重新生成时,你能重新开始新的subscription。
Observable<Photo> request = service.getUserPhoto(id).cache();
Subscription sub = request.subscribe(photo -> handleUserPhoto(photo));
// ...When the Activity is being recreated...
sub.unsubscribe();
// ...Once the Activity is recreated...
request.subscribe(photo -> handleUserPhoto(photo));
注意我们在两种情况下,用的是同一个缓存的请求(request
),那种方式隐含的调用只会发生一次。存放请求的地方你自己决定,但是像所有的生命周期解决方案一样,它必须存放在生命周期之外的地方(一个保存的fragment,单例等等)。
第二问题可以通过根据生命周期正确的取消订阅来实现。通用的方法是用一个CompositeSubscription
来持有所有的Subscription
,然后在onDestroy()
或onDestroyView()
方法中取消所有的订阅。
private CompositeSubscription mCompositeSubscription
= new CompositeSubscription();
private void doSomething() {
mCompositeSubscription.add(
AndroidObservable.bindActivity(this, Observable.just("Hello, World!"))
.subscribe(s -> System.out.println(s)));
}
@Override
protected void onDestroy() {
super.onDestroy();
mCompositeSubscription.unsubscribe();
}
更进一步,你可以创建一个根Activity
或Fragment
,顺带添加一个CompositeSubscription
,随后可以相应的取消订阅。
注意,只要你调用了CompositeSubscription.unsubscribe()
,该对象(`CompositeSubscription`)就不能用了。因为它会自动取消订阅随后你添加的任何事物。如果你今后想要使用这种方法,你必须创建一个新的CompositeSubscription
作为替代。
两个问题的解决方法都涉及到添加代码,我希望有一天能出现不需要写这些样板代码就能解决这些问题的天才。
本文翻译自Grokking RxJava, Part 4: Reactive Android,著作权归原作者danlew所有。译文由JohnTsai翻译。转载请注明出处,并保留此段声明。
理解RxJava:(四)Reactive Android的更多相关文章
-
理解RxJava:(三)RxJava的优点
理解RxJava:(三)RxJava的优点 在第一部分,讲解了RxJava的基本结构.在第二部分,展示了operators的强大之处.但是你们可能仍然没有被说服,也没有足够的理由信服.下面是一些能让你 ...
-
理解RxJava:(一)基础知识
理解RxJava:(一)基础知识 本文翻译自Grokking RxJava, Part 1: The Basics,著作权归原作者danlew所有.译文由JohnTsai翻译.转载请注明出处,并保留此 ...
-
【原创】NIO框架入门(四):Android与MINA2、Netty4的跨平台UDP双向通信实战
概述 本文演示的是一个Android客户端程序,通过UDP协议与两个典型的NIO框架服务端,实现跨平台双向通信的完整Demo. 当前由于NIO框架的流行,使得开发大并发.高性能的互联网服务端成为可能. ...
-
四、Android学习第四天——JAVA基础回顾(转)
(转自:http://wenku.baidu.com/view/af39b3164431b90d6c85c72f.html) 四.Android学习第四天——JAVA基础回顾 这才学习Android的 ...
-
20162330 实验四 《Android程序设计》 实验报告
2016-2017-2 实验报告目录: 1 2 3 4 5 20162330 实验四 <Android程序设计> 实验报告 课程名称:<程序设计与数据结构> 学生班级:1623 ...
-
理解 RxJava 的线程模型
来源:鸟窝, colobu.com/2016/07/25/understanding-rxjava-thread-model/ 如有好文章投稿,请点击 → 这里了解详情 ReactiveX是React ...
-
20145207《Java程序设计》实验四( Android程序设计)实验报告
<Java 程序设计>实验四( Android程序设计)实验报告 目录 改变 Android开发基础实验要求 实验成果 课后思考 改变 修改了之前仅仅是贴了图片,连代码都没粘的状态.增加了 ...
-
实验四《Android程序设计》实验报告封面
实验四<Android程序设计>实验报告封面 课程:Java程序设计 班级:1753班 姓名:许钰玮 学号:20175329 指导教师:娄嘉鹏 实验日期:2019年5月13日 实验时间:1 ...
-
20145206实验四《Android开发基础》
20145206 实验四<Android开发基础> 实验内容 ·安装Android Studio ·运行安卓AVD模拟器 ·使用安卓运行出虚拟手机并显示HelloWorld以及自己的学号 ...
随机推荐
-
const let,console.log(&#39;a&#39;,a)跟console.log(&#39;a&#39;+a)的区别
const 创建一个只读的常量 let块级作用域 const let重复赋值都会报错 console.log('a',a) a console.log('a'+a) a2 逗号的值会有空格:用加号的值 ...
-
【Android】自定义控件让TextView的drawableLeft与文本一起居中显示
前言 TextView的drawableLeft.drawableRight和drawableTop是一个常用.好用的属性,可以在文本的上下左右放置一个图片,而不使用更加复杂布局就能达到,我也常常喜欢 ...
-
DotNetBar v14.0.0.3 Fully Cracked
更新信息: http://www.devcomponents.com/customeronly/releasenotes.asp?p=dnbwf&v=14.0.0.3 如果遇到破解问题可以与我 ...
-
Java Swing 使用总结(转载)
随笔转载自:此去经年ぢ 地址:http://www.cnblogs.com/FLFL/p/5369756.html 1. GUI编程引言 以前的学习当中,我们都使用的是命令交互方式: 例如:在 ...
-
KEIL C51中的_at_关键字
绝对位置变量 变量可以在你的C程序中的绝对内存地址位于源模块使用_at_关键字.此功能的用法是: 类型 _ memory_space _ 变量名 _at _ 常数 ; 其中:memory_space ...
-
Leetcode题解(十二)
33.Search in Rotated Sorted Array 题目 这道题目如果没有其他要求,直接遍历一遍就可以知道答案,但是,题目给出了是排序了数组,但是数组有可能经过了旋转得到,其解题思路仍 ...
-
CocosCreator 小知识
最近在自学creator,有些小坑和解决方案,想记录下来: 1. 防止点击穿透 场景:在游戏界面有功能按钮,上层弹出layer之后,加入了遮罩,但是游戏界面的功能按钮还可以点击,穿透了! 方案1:遮罩 ...
-
学习C++后感
c++是一门系统级语言,记得大一是要学习这门课时还上网找过学习方法.但网上很多学习方法看的我都头晕,都说学习C++很难,有的说学C++前最好先学C语言,有的说学C++最好不要学C语言,当翻了C++课本 ...
-
vue开发中vue-resource + canvas 图片压缩、上传、预览
1.使用vue-resource上传,也可以自定义ajax上传: 2.使用<input type="file" @change="submit()" na ...
-
C简介与环境配置
C 语言是一种通用的高级语言,最初是由丹尼斯·里奇在贝尔实验室为开发 UNIX 操作系统而设计的.C 语言最开始是于 1972 年在 DEC PDP-11 计算机上被首次实现. 在 1978 年,布莱 ...