Rxjava2浅析

最近在Android开发阵营中RxJava被经常提起，似乎不看看RxJava马上就会被Out一样，本人也抽时间研究一番，并写下一些思考。

首先，想先解释下RxJava是什么，为什么需要使用它，或者可以理解我它有什么好处？RxJava即Reactive

Programmingjava字面意思就是java响应式编程。

响应式编程(Reactive Programming)：是一种面向数据流和变化传播的一种编程范式。其中变化传播在程序中也是转换为数据流的形式进行处理。其实，响应式编程便是发射，流转，监听，响应数据流的一套编程范式。在流转的过程中可以对数据流进行过滤，转变，合并，去重等方式的处理响应式编程的终极思想，一切皆流（everything is stream）。根据唯物辩证法的思想，物质世界是普遍联系和不断运动变化的统一整体，而一切‘运动变化’这一‘客观现象’都可以通过数据流进行‘抽象描述’，也可以说，物质世界是数据流的客观存在。在程序中数据流是轻量而常见的，变量，数组，集合，对象，事件都可当做数据流来发送处理。以上来之个人百度，具体是（作者：冯丰枫链接：http://www.jianshu.com/p/15b2f3d7141a）。看完之后还是云里雾里，不知所以然，估计很多码农同志和小弟有同感。

所以，我认为学习Rxjava第一个要解决的问题是Rxjava解决了什么问题，响应式编程，从字面意思就是等待action响应，然后做出处理。也就是Rxjava解决的就是异步的问题。为什么怎么说呢，很多码农同志可能觉得异步，我们使用Callback不就可以了，为什么还需要费劲用Rxjava。因为很多时候，我们不仅仅需要异步，还需要异步串行，什么事异步串行。如下例子：

publicUri saveTheCutestCat(String query){

List cats =api.queryCats(query);

Cat cutest = findCutest(cats);

Uri savedUri = api.store(cutest);

returnsavedUri;

}

在一个方法中，我们调用了三个方法，下一个方法的输入需要上一个方法的输出，若是每一个方法都是同步阻塞的，那如上面写是没有问题的，若要每一个方法都是异步如何：

如上发现，我们需要在回调中嵌套回调，随着异步方法数不断增多，回调层级也越深，对于代码的维护和调试简直是无法想象的。但是当你使用Rxjava时，发现它已经很好的解决了这一问题，回国头来在看响应式编程的定义，一种面向数据流和变化传播的一种编程范式，在数据流转的过程中可以对数据流进行过滤，转变，合并，去重等方式的处理，而这些处理可以是异步也可以是同步，但是整个数据的流转是串行，也就是说过滤，转变，合并都可以是异步的，但是转变一定是在过滤完成后才开始执行，合并也一定是在转变完成后执行。第一个关键问题已经解释完成，那下面我们就可以揭开Rxjava使用的神秘面纱了。

基本概念

在Rxjava中，我们经常会遇到如下说法，一个观察者（Observer）订阅（Subscribe）一个可观察对象（Observable），通过创建可观察对象发射数据流，经过一系列操作符（Operators）加工处理和线程调度器（Scheduler）在不同线程间的转发，最后由观察者接受并做出响应的一个过程，….巴拉巴拉。那么关键是Observer是什么Observable是什么，具体怎么用。

我们可以对比的来看一下，在Android中大家可能都使用过AsyncTask，在AysncTask中，我们需要重写几个方法，来实现异步，我们借鉴AsyncTask，自定义一个AsyncJob，实现异步，在start的时候需要传入Callback。Observable就是AsyncJob，Observer就是callback，我们在启动AsyncJob时，一般会使用start之类的方法，现在清晰了，subscribe就是对应的这start，使整个数据流转启动。很多人都在强调RxJava的观察者模式，但是很多人都不是很明白为什么时被观察者（Observable）去Subscrible观察者（Observer），其实换在上面对应关系角度理解，Subscrible其实就是start，那就好理解了为什么是观察者（Observable）去Subscrible观察者（Observer），实际的行为不是订阅或注册就是启动Job，并传入回调。还是最初上面那个三个异步方法的例子，若是使用Rxjava去实现应该是个什么样子。