说明

RxJava已经火了一段时间，在github上的star已经将近2万，可见，火的不得了，既然都这么火了，证明他应该很优秀，事实看来，的确很优秀呀，那么RxJava到底是什么呢？这让一层人感觉很懵逼，百度、谷歌了好多天还是不明白，他是个什么玩意，我也很苦恼呀，所以决定，来研究研究他，然后分享，简单来说RxJava就是一个实现异步操作的库，好吧，你肯定还是不明白，其实我也是不明白呀，那怎么办呢，这个问题就像我们当初做Android一样，对一切都不是很明白，但是呢，老子能干活呀，这不就行了！要的就是这个效果，能干活！！！所以在我看来，你先不要管他是个什么玩意，原理是什么，这些统统暂时不要管，一句话，会用就行，其实学习就是这样，从不知道到知道，从明白，到理解，谁都不是一步登天的,我是过来人，知道刚开始接触新知识是个什么感觉，上来就给我讲什么原理，what are you talk about？听不懂！！！附上一张图片，感觉特别适合这个场景。另外说明一下，可以搜索我们的微信公共号：AppCode来关注我们，我在微信里等你。

解释

咱们还是说下，他是干什么的，能干些什么事，RxJava 2.0无非就是推送和订阅，平常用得最多的推送Publisher是Flowable,也可以理解成数据发射器，主要用来向订阅者发送数据，然后订阅者拿到数据处理数据，流程就是这样，没有什么可神秘的，暂且这样理解，要不然你有懵逼了。

效果演示

提示

RxJava1.0 和RxJava2.0是不一样的，肯定得学习2.0呀，至于这二者有什么区别，我建议你暂时不要管，直接上手2.0就行了，要不然，你又得懵逼了

在你的gradle文件里添加依赖

compile ‘io.reactivex.rxjava2:rxjava:2.0.1’

实现步骤

1. 第一步：创建一个Flowable(数据发射器)

2. 第二步：创建一个Subscriber(订阅者)

注意：

在onSubscribe中，我们需要调用request去请求资源，参数就是要请求的数量，一般如果不限制请求数量，可以写成Long.MAX_VALUE。如果你不调用request，Subscriber的onNext和onComplete方法将不会被调用。

3. 第三步：建立订阅关系

observable.subscribe(observer);

完成以上三步即可实现数据发射，和数据接收处理，就是上面的效果图啦，但是这样做，代码也太多了吧，那咱们继续优化他

第二种写法

1. 创建Flowable

Flowableflowable = Flowable.just(“Hello RxJava 2.0”);//要发射的数据

2. 创建Consumer重写accept方法

3. 建立订阅关系

flowable.subscribe(consumer);

分析

第二种方法好像是比第一种方法的代码少了许多，但是区别好像是在第二步，换对象了，是没错换了，但是呢其实是一样的，因为我们在第一步的时候，subscribe在接受到数据之后处理数据都是在OnNext()方法中，其他方法好像没有用到，那么我们直接使用他的OnNext方法不就行了吗，正好Consumer可以做到，他的accept方法就相当于subscribe的OnNext()的方法，这样我们就不用重写那么多的方法了，多省事，别急，还有更省事的呢

第三种写法

完了，就这样完成了，我靠，有没有搞错，放心绝对没有搞错，上面的效果就这样实现啦，那么问题来了，我们以后用哪种方式呢？你是不是傻啊，当然是第三种啦，多简单啊

分析

1. 这几步的重点就是把Observer(观察者)和Observable(观察者)联系到了一起

2. 一旦Observable里的数据发生变化，那么Observer就会执行它里面相应的方法，前提是要建立订阅的关系(就是第三步)，其实是因为在Observable的subscribe的方法中我们调用了e.onNext()和e.onComplete()方法，所以呢，Observer才会执行相应的方法，暂时这样理解吧

3. 第三步调用之后，Observable的方法会立马执行，然后执行e.onNext()和e.onComplete()方法，其次Observer执行他自己的onNext()和onComplete()方法，那么这个时候，我们就能看到应用程序给我们弹出的吐司了

顺利完成

就这样很简单，一个hello world 版的RxJava就已经完成了你可以试试哦，有时候，不理解也是一种理解。