是时候学习 RxJava 了

644 查看

RxJava

从开始最开始学习RxJava到现在也有一段时间了，还记得去年第一次看RxJava的文章就是扔物线的的这篇文章给 Android 开发者的 RxJava 详解，那一次我看了整整一个下午，由于在那之前我完全没接触过RxJava，也不知道那是个什么，看完很多地方都还不是很理解，整个人都是晕晕的，当然收获也还是有的，至少对RxJava有了一个初步的概念。那次之后我就没再去碰过RxJava了，当时心里想的是，如果后面需要这方面的东西我再来学习也不迟。
时间差不多过了半年，RxJava也越来越火了，使用RxJava的开发者也是越来越多，github上关于的开源库中使用RxJava的也越来越多。当我再去看一些开源库的时候，由于很多地方都用到了RxJava，就发现很多代码都看不懂了，这也就激起了再次去学习RxJava的动力，随后就在网上各种的查找RxJava相关的学习资料，从头学习，我又去看了一遍给 Android 开发者的 RxJava 详解，收获还是很多的，本文也是对这段时间我学习RxJava的一个小结，以下知识点主要针对于Android开发者。

本文的学习目录

1.RxJava是什么
2.在Android中怎么去使用RxJava
3.RxJava操作符的介绍
4.RxJava在生产环境中的使用
5.RxJava学习的参考资料

1.RxJava是什么

要知道RxJava是什么，那么你应该先去了解一下Rx。Rx的全称是Reactive Extensions，直译过来就是响应式扩展。Rx基于观察者模式，他是一种编程模型，目标是提供一致的编程接口，帮助开发者更方便的处理异步数据流。ReactiveX.io给的定义是，Rx是一个使用可观察数据流进行异步编程的编程接口，ReactiveX结合了观察者模式、迭代器模式和函数式编程的精华。Rx已经渗透到了各个语言中，有了Rx所以才有了 RxJava，Rx.NET、RxJS、RxSwift、Rx.rb、RxPHP等等，更详细的可以去这里看看languages

那么RxJava到底是什么，我对于他的理解就针对于Java语言的一个异步的响应式编程库。

2.怎么去使用RxJava

在gradle文件的dependencies中加入以下代码即可（以下版本可能不是最新的，需要最新的可到RxAndroid查看）

1 2	compile 'io.reactivex:rxandroid:1.2.0' compile 'io.reactivex:rxjava:1.1.5'

3.RxJava操作符的介绍

有了以上的配置，我们就可以在Android中使用RxJava了。对于RxJava的使用，最重要的还是对于操作符的学习，熟悉了操作符才能更好的使用RxJava。RxJava中的操作符是非常丰富的，关于RxJava操作符介绍的文章已经是属于一搜就是一大堆的那种了，所以本文就不多做介绍了，在这里给大家推荐一个学习操作符比较好的地方Operaters

4.RxJava在生产环境中的使用

想必学习RxJava的同学，在学习完操作符之后，最想知道的是怎么将其用在我们平时的开发当中去，本节就带大家去了解一下怎么去应用RxJava。

RxBinding
节流(防止按钮的重复点击)
轮询，定时操作
RxPermissions
RxBus
RxJava与Retrofit
等待你们的补充~~~

(1) RxBinding

RxBinding是JakeWharton大牛用RxJava为Android控件编写的一个控件绑定库，并且为各个包下的控件都编写相应的库，如下所示

Platform bindings:

compile 'com.jakewharton.rxbinding:rxbinding:0.4.0'

'support-v4' library bindings:

compile 'com.jakewharton.rxbinding:rxbinding-support-v4:0.4.0'

'appcompat-v7' library bindings:

compile 'com.jakewharton.rxbinding:rxbinding-appcompat-v7:0.4.0'

'design' library bindings:

compile 'com.jakewharton.rxbinding:rxbinding-design:0.4.0'

'recyclerview-v7' library bindings:

compile 'com.jakewharton.rxbinding:rxbinding-recyclerview-v7:0.4.0'

'leanback-v17' library bindings:

compile 'com.jakewharton.rxbinding:rxbinding-leanback-v17:0.4.0'

我们只需引入对应地库就可以使用了。

比如我们对Button添加一个单击事件就可以这样做了

Button button = (Button) findViewById(R.id.button);

RxView.clicks(button).subscribe(new Action1<Void>() {

@Override

public void call(Void aVoid) {

Log.i("test", "clicked");

}

});

到这里，你肯定会说，这并没有没什么卵用，还不如直接设置一个setOnClickListener来的方便，直接。继续往下看

通常情况下，如果我们要防止一个按钮重复点击会怎么做？设置一个第一次按下的时间，然后在第二次点击的时候去判断？NO NO NO，这样做都太low了，我们来看看用RxBing怎样去实现

RxView.clicks(button).debounce(300, TimeUnit.MILLISECONDS).subscribe(new Action1<Void>() {

@Override

public void call(Void aVoid) {

Log.i("test", "clicked");

}

});

很爽吧，这里过滤掉了在300ms内的重复点击，只需加一个操作符就可以了，而不用我们去编写一大堆并且还容易出错的逻辑代码了。

这里使用最多的一个地方就是在我们做搜索的时候，再结合filter操作，去过滤掉那些没必要的查询操作，来减小服务器的压力和客户端的流量输出。

(2) 轮询，定时操作
在做App的时候，有些地方我们可能会时不时的去请求服务器，以至于客户端的数据是最新的，在RxJava中可以这样做

//每隔两秒执行一次

Observable.interval(2, 2, TimeUnit.SECONDS).subscribe(new Action1<Long>() {

@Override

public void call(Long aLong) {

//TODO WHAT YOU WANT

}

});

在两秒后去执行一些操作（比如启动页跳转到主页面）

RxJava

简书地址：是时候学习RxJava了

本文的学习目录

1.RxJava是什么
2.在Android中怎么去使用RxJava
3.RxJava操作符的介绍
4.RxJava在生产环境中的使用
5.RxJava学习的参考资料

1.RxJava是什么

那么RxJava到底是什么，我对于他的理解就针对于Java语言的一个异步的响应式编程库。

2.怎么去使用RxJava

在gradle文件的dependencies中加入以下代码即可（以下版本可能不是最新的，需要最新的可到RxAndroid查看）

1 2	compile 'io.reactivex:rxandroid:1.2.0' compile 'io.reactivex:rxjava:1.1.5'

3.RxJava操作符的介绍

4.RxJava在生产环境中的使用

想必学习RxJava的同学，在学习完操作符之后，最想知道的是怎么将其用在我们平时的开发当中去，本节就带大家去了解一下怎么去应用RxJava。

RxBinding
节流(防止按钮的重复点击)
轮询，定时操作
RxPermissions
RxBus
RxJava与Retrofit
等待你们的补充~~~

(1) RxBinding

RxBinding是JakeWharton大牛用RxJava为Android控件编写的一个控件绑定库，并且为各个包下的控件都编写相应的库，如下所示

Platform bindings:

compile 'com.jakewharton.rxbinding:rxbinding:0.4.0'

'support-v4' library bindings:

compile 'com.jakewharton.rxbinding:rxbinding-support-v4:0.4.0'

'appcompat-v7' library bindings:

compile 'com.jakewharton.rxbinding:rxbinding-appcompat-v7:0.4.0'

'design' library bindings:

compile 'com.jakewharton.rxbinding:rxbinding-design:0.4.0'

'recyclerview-v7' library bindings:

compile 'com.jakewharton.rxbinding:rxbinding-recyclerview-v7:0.4.0'

'leanback-v17' library bindings:

compile 'com.jakewharton.rxbinding:rxbinding-leanback-v17:0.4.0'

我们只需引入对应地库就可以使用了。

比如我们对Button添加一个单击事件就可以这样做了

Button button = (Button) findViewById(R.id.button);

RxView.clicks(button).subscribe(new Action1<Void>() {

@Override

public void call(Void aVoid) {

Log.i("test", "clicked");

}

});

到这里，你肯定会说，这并没有没什么卵用，还不如直接设置一个setOnClickListener来的方便，直接。继续往下看

RxView.clicks(button).debounce(300, TimeUnit.MILLISECONDS).subscribe(new Action1<Void>() {

@Override

public void call(Void aVoid) {

Log.i("test", "clicked");

}

});

很爽吧，这里过滤掉了在300ms内的重复点击，只需加一个操作符就可以了，而不用我们去编写一大堆并且还容易出错的逻辑代码了。

这里使用最多的一个地方就是在我们做搜索的时候，再结合filter操作，去过滤掉那些没必要的查询操作，来减小服务器的压力和客户端的流量输出。

(2) 轮询，定时操作
在做App的时候，有些地方我们可能会时不时的去请求服务器，以至于客户端的数据是最新的，在RxJava中可以这样做

//每隔两秒执行一次

Observable.interval(2, 2, TimeUnit.SECONDS).subscribe(new Action1<Long>() {

@Override

public void call(Long aLong) {

//TODO WHAT YOU WANT

}