如何让人大致理解RxJava思想：第一节初步理解RxJava

首先，我们需要明确，一个人不可能一口气吃成一个胖子，你不可能仅仅花5分钟看完我这篇文章，然后一拍桌子，大叫一声，我知道了，然后赢取白富美，从此走上人生巅峰。很遗憾，一切东西都是需要循序渐进的！

为什么更多的人会选择前端，因为前端相对后端更加简单，而且有很多的框架，学习坡度也不陡峭。为什么Linux或者是C往往都让人望而却步，学习坡度陡峭啊，指数级增长。

不是很想说那些表象的，经验之谈，因为那些毫无意义，就好比，我做了一次实验，实验的结果是1+1=2，那么1+1就一定等于2吗？想理解事情永远都不能从表象去看，表象去研究什么多个observeOn()和subcribeOn()多个调用时，到底哪几个会有效果，这种实验说是实验，其实就是瞎猜，浪费时间罢了。

尝试去脱离代码吧，从思想开始，这时候你就会发现原本黑白色的代码世界就会刹那间拥有了色彩。

RxJava是什么，他是基于观察者模式的一根管道，将订阅者和被订阅者联系到了一起，他将被订阅者传输到了订阅者处。这里对于不知道观察者模式的童鞋深表遗憾，请自行百度。

在这里我问一个问题，为什么日常开发的时候，IDE会将整段RxJava代码标黄，极其恶心的标黄。当你加上.dispose()方法之后，你会惊讶地发现，黄色消失了，这又是为什么呢？贴心的我帮你把百度这个英语的翻译的时间都省了。

此单词的意思为处置，也就是处理的意思，其作用的对象是Disposable，意为可处理的东西，此处指代的意思就是管道。那么为什么要处理管道呢？因为三者之间的引用关系，这里的引用关系可能不只有一种，为了避免本篇的篇幅过于冗长，就不过多赘述。既然三者之间存在着互相引用的关系，那么在回收对象的时候就有可能不能很好的回收，所以需要通过dispose()方法来斩断三者之间的关系。

然后看到这里，有些可爱的人就暗暗下定决心，那好，今后我只要遇到subscribe()方法就万分自觉地加上dispose()方法，这样总不会出问题了吧，求表扬！好的，奖励你请全组人吃饭！

本末不能倒置！你需要考虑一下执行dispose()时，你的业务到底有没有执行完毕啊= =，如果观察者还没有接收到数据，你就把管道给处理掉了，那你这饭请的的确不冤。

那么什么时候，这套观察者模式就开始启动了呢？答：当三者都集齐时。

注意，并不是调用subscribe()时三者就集齐了，最常见的例子就是RxAndroid对于视图事件的监控，调用subscribe方法时，用户可能什么事情都还没有做，你这个时候直接掐掉管道，那用户真的什么事情都做不了了。

所以，RxJava提供了一个类用来专门管理Disposable：CompositeDisposable，在定义好一个管道后放入这个类中，然后在某个需要统一处理管道的时机（比如说Activity的onDestroy()），通过这个类统一进行处理就行了。你看这个类直接实现了Disposable，和Disposable一样调用dispose()方法就能回收了。