<a href="http://www.jianshu.com/p/f4af4752cd26">RxJava 从入门到爱上它 - 源码分析线程控制</a>
<a href="http://www.jianshu.com/p/ffb6c25f472b">RxJava 从入门到爱上它 - "变换"的深入理解</a>
关于Backpressure 作者也将在后续的文章中做出解析。
RxJava
RxJava 是什么
官方的解释是： RxJava是 ReactiveX 在JVM上的一个实现，ReactiveX使用Observable序列组合异步和基于事件的程序。
Rx 是一个多语言实现
RxJava 支持Java 6或者更新的版本，以及其它的JVM语言如 Groovy, Clojure, JRuby, Kotlin 和 Scala。RxJava 可用于更多的语言环境，而不仅仅是Java和Scala，而且它致力于尊重每一种JVM语言的习惯。
为什么要使用 RxJava
- 函数式风格：对可观察数据流使用无副作用的输入输出函数，避免了程序里错综复杂的状态
- 简化代码：Rx的操作符通通常可以将复杂的难题简化为很少的几行代码
- 异步错误处理：传统的try/catch没办法处理异步计算，Rx提供了合适的错误处理机制
- 轻松使用并发：Rx的Observables和Schedulers让开发者可以摆脱底层的线程同步和各种并发问题
传统的调用方法 (此例子来自: https://gank.io/post/560e15be2dca930e00da1083#toc_32)
new Thread() {
@Override
public void run() {
super.run();
for (File folder : folders) {
File[] files = folder.listFiles();
for (File file : files) {
if (file.getName().endsWith(".png")) {
final Bitmap bitmap = getBitmapFromFile(file);
getActivity().runOnUiThread(new Runnable() {
@Override
public void run() {
imageCollectorView.addImage(bitmap);
}
});
}
}
}
}
}.start();
此例子就是异步遍历文件，如果是以png结尾的就转换成位图，然后在主线程中显示。
如果我们换成RxJava来写呢
Observable.from(folders)
.flatMap(new Func1<File, Observable<File>>() {
@Override
public Observable<File> call(File file) {
return Observable.from(file.listFiles());
}
})
.filter(new Func1<File, Boolean>() {
@Override
public Boolean call(File file) {
return file.getName().endsWith(".png");
}
})
.map(new Func1<File, Bitmap>() {
@Override
public Bitmap call(File file) {
return getBitmapFromFile(file);
}
})
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Action1<Bitmap>() {
@Override
public void call(Bitmap bitmap) {
imageCollectorView.addImage(bitmap);
}
});
是不是这样子写逻辑清晰多了。其实上面的例子还是简单的遍历筛选显示，如果再加上更加复杂的逻辑的话，代码将变得十分混乱，大家都是程序员，这种复杂的逻辑就算加了注释，隔几天不看，回头再来，也有可能看不懂。
所以RxJava是很必要学习并使用的。
RxJava 怎么使用呢？
-
简单的使用
Observable.just("hello", "my", "name", "is", "nichool") .subscribe(new Action1<String>() { @Override public void call(String s) { LogUtils.LogW(s); } });通过
just来创建一个被观察者，被观察者中决定将会做的事情，然后subscribe进行注册观察者。以下为在观察者中将会打印的 :
RxJavaDemo: hello RxJavaDemo: my RxJavaDemo: name RxJavaDemo: is RxJavaDemo: nichool -
复杂的操作
Student[] students= new Student[]{ new Student("nichool", 100), new Student("li", 54), new Student("wang", 64), new Student("wu", 70), new Student("liu", 59), new Student("liu", 60), }; Observable.from(students).filter(new Func1<Student, Boolean>() { @Override public Boolean call(Student student) { return student.score >= 60; } }).map(new Func1<Student, String>() { @Override public String call(Student student) { return student.mName + " is a qualified student"; } }).subscribe(new Action1<String>() { @Override public void call(String s) { LogUtils.LogW(s); } });以上代码为：在学生中查找及格的学生，并打印合格学生表。
RxJavaDemo: nichool is a qualified student RxJavaDemo: wang is a qualified student RxJavaDemo: wu is a qualified student RxJavaDemo: liu is a qualified student
如果想了解更多的操作符使用 请查看操作方法这篇文章
- 在Android上的配置与使用
在需要使用RxJava的对应模块下的build.gradle 中添加这几句 (如需使用其他的版本，请修改版本号)。使用RxAndroid时最好带着RxJava，官方的解释是RxAndroid的版本还很少，需要用RxJava来弥补它的不足。compile 'io.reactivex:rxandroid:1.2.1' // Because RxAndroid releases are few and far between, it is recommended you also // explicitly depend on RxJava's latest version for bug fixes and new features. compile 'io.reactivex:rxjava:1.1.6'
RxAndroid
解释： rxjava-android 模块包含RxJava的Android特定的绑定代码。它给RxJava添加了一些类，用于帮助在Android应用中编写响应式(reactive)的组件。
- 它提供了一个可以在给定的Android Handler 上调度 Observable 的调度器 Scheduler，特别是在UI主线程上 (
AndroidSchedulers.mainThread()、AndroidSchedulers.handlerThread(handler))。 - 它提供了一些操作符，让你可以更容易的处理 Fragment 和 Activity 的生命周期方法。
// MyActivity private Subscription subscription; protected void onCreate(Bundle savedInstanceState) { this.subscription = observable.subscribe(this); } ... protected void onDestroy() { this.subscription.unsubscribe(); super.onDestroy(); } - 它提供了很多Android消息和通知组件的包装类，用于与Rx的调用链搭配使用。
- 针对常见的Android用例和重要的UI，它提供了可复用的、自包含的响应式组件。（即将到来）
Android中使用 RxLifecycle 更好的保证及时的注册与解除注册。
.compose(this.<Long>bindToLifecycle()) //这个订阅关系跟Activity绑定，Observable 和activity生命周期同步
RxLifecycle更多方法请自行百度
↓↓↓↓↓如果觉得可以的话，请点击下面的喜欢。或者打赏哦，我会更加努力的。↓↓↓↓↓
