[ 好久没有写博客了，这一段时间一个新的项目上线了，想写一写我在项目中用到的RxJava 库]
Rxjava
第一次接触
RxJava我在去年才第一次接触到，那时是公司同事引进的，不过在那次之后，RxJava就深深的吸引了我。
现在还记得，当时RxJava的编码风格对我的影响特别的大，喜欢那种瀑布流样式的代码。
第一次接触，RxJava中throttleFirst操作符也是让我影响深刻的一点，通过throttleFirst，完美的实现点击事件的拦截处理。
新项目中
这次我做的项目并不是一个独立的APP，而是以SDK的形式提供给第三方的开发者使用。在项目架构过程中，是不是使用RxJava是我比较纠结的。不过考虑到RxJava的优点以及项目中涉及的内容和项目的开发周期，我还是在项目中集成RxJava。
- 项目中涉及比较多的网络请求。通过RxJava + Retrofit可以很快的实现和管理这些网络请求
- 项目中涉及比较多的线程处理。RxJava的线程管理和线程切换，这个是我最喜爱的一点。通过subscribeOn、observeOn，去实现线程的切换，省去了大量的编写线程和管理线程的时间
- 一些好用的操作符，虽然现在的我，使用Map操作符最多，这种转换效果，可以让我很好的处理代码的耦合关系
- 使用RxJava可以极大的缩短开发的时间。RxJava处理的大多重复、无意义的交互。
使用
1. 自定义界面去耦合
在项目中，有很多自定义UI，这些UI中又包含很多按钮，我期望的是：按钮有自己的动作，当这些动作发生是，自己有相应的改变，也会把这些动作同步的通知给其他UI。
例如：录制视频过程中.
- 点击录制按钮
- 录制按钮改变颜色和图片
- 在其他界面中开启视频录制功能
在实现这种功能时，使用RxJava可以很容易的做到。
Observable observable = Observable.create(new ObservableOnSubscribe<View>() {
@Override
public void subscribe(ObservableEmitter<View> emitter) throws Exception {
mEmitter = emitter;
}
})
.throttleFirst(500, TimeUnit.MILLISECONDS)
.observeOn(AndroidSchedulers.mainThread())
.map(Function<View, View> function)
.subscribe( Consumer<View>);
}
其中：
- 在Map变幻时，改变按钮自身的颜色等
- 在Consumer调用时，去开启其他功能
亦或者
- 在Map变化时去调用其他功能，返回结果
- 在Consumer中判断返回的结果在改变按钮的样式
2. Disposable
有线程的使用，那么就不可避免的会遇到线程需要紧急停止的情况。
比如发起一系列的网络请求，但是用户此时退出界面，此时不在希望这些网络请求调用或者不在希望这些请求的结果去改变什么。
喜欢用Disposable去主动停止这些事件。
Rxjava2.0中增加onSubscribe方法，这个方法我觉得弥补了我在1.0使用过程中的遗憾。
通过Disposable停止正在进行中的任务，管理线程和用户主动事件发生冲突的情况。
// 创建List<Disposable>管理正在执行中或者还未执行中的网络请求
List<Disposable> mDisposables;
// 实现Observer接口，把每一个Disposable记录的List中
synchronized (mDisposables) {
mDisposables.add(mDisposable);
}
// 在onError、onComplete移除已经执行完成的mDisposable对象
synchronized (mDisposables) {
if (mDisposables.contains(mDisposable)) {
mDisposables.remove(mDisposable);
}
}
// 当遇到紧急停止时，比如调用release方法时，清理掉所有的mDisposable对象
public void release() {
if (mDisposables.size() > 0) {
for (Disposable disposable : mDisposables) {
disposable.dispose();
}
}
synchronized (mDisposables) {
mDisposables.clear();
}
}
3. 定时器
项目中不可避免的要用到很多定时器，这个RxJava也可以很轻松的搞定,不需要我在一步一步的去创建定时器。
Disposable disposable = Observable.interval(500, 500, TimeUnit.MILLISECONDS)
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Consumer<Long>() {
// 每隔500毫秒执行一次任务
}
});
// 同样，要取消一个定时器也可以去管理Disposable
disposable.dispose();
Rxjava 提供了很多关于时间方面的操作符。比如有：timer()、interval()、delay()、defer()等等
4. 线程切换
在Android开发过程中，最常用的线程切换就是在UI线程中改变View。
为了改变这些View，我不知道写了多少Handler。尤其是在网络请求过程中，每一个网络请求的结果势必要改变一系列View的样式。
RxJava中的线程切换，这个减少了我大多的工作。
就如一个简简单单的删除缓存的文件，我就可以通过RxJava很容易的去实现
Observable.fromArray(path1,path2)
.subscribeOn(Schedulers.computation())
.observeOn(Schedulers.computation())
.subscribe(new Consumer<String>() {
@Override
public void accept(String s) throws Exception {
deleteFiles(s);
}
});
}
不用在把时间花在线程管理上。
5. 其他
RxJava 还有很多有趣的、好玩的、高大上的功能，不过我也是才开始认真的关注它，所以用到的不是很深。
后记
新手，文章写的不好。但是RxJava绝对是一个好东西！！！
