RxJava简介：

可以使代码变的简洁，增加代码的可读性可维护性。

响应式编程，对于要处理的数据，从Observable（被观察者、发布者）发射出去，在操作符中进行一些限定或者处理，最后在Observer（观察者）中，进行最后的处理。

代码1

使用的是观察者模式，又叫订阅发布模式实现的。

传统的观察者模式

与传统的观察者模式区别，避免入坑：

1.在RxJava中这两种名字经常混用，所有要弄清楚谁是观察者（Observer）被观察者（Observable）订阅者（Subscriver）发布者（publisher 暂时没有见到），这也是RxJava容易对初学者造成的困惑。

2.RxJava中在subscrib（）之后根据操作符来完成回调方法中的不同方式的响应，传统观察者是在订阅后处于等待的状态，待被观察者发布消息后再进行回调。

被观察者：Observable     

观察者（订阅者）：Observer （Subscriber）Observer与Subscriber是继承关系，实现细节不一样

操作符：lift() Map() flatMap(），就是Observble实现响应式编程的方法

二、几个例子

第一个例子：使用的步骤（基本使用）

 这是一个最简单的使用例子，RxJava使用的是观察者模式（订阅发布模式）实现的，subscribe之后根据需要回调其中的回到方法，很容易根据名字来判断回到顺序，onStart（），onNext（），onComplete（）为正常顺序，onError（）为异常时调用。

代码2

以上是默认的Observable回调顺序，Observable提供create操作符来创建新的Observable自定义回调。也可以使用RxJava库提供的一些类Action1等。

这里只是最简单的实现，后面的编程都是根据 obServable1.subscribe（subscribe）的扩展，或者说所有的RxJava响应式编程的结构都是  

Obserable

代码3

第二个例子：线程的切换（subscribeOn observeOn操作符的使用 ）

代码4

这里使用的是一个例子实现的是类似于Handler或者AsyncTask的异步过程，在工作线程中加载资源文件（当然也可以换做网络请求），在主线程中set图片。

第三个例子：Retrofit结合RxJava做网络请求框架

Retrofit是对Okhttp的封装，将请求返回的io流转化为Retrofit的Servcie接口，再通过Gson解析到实体类。

Retrofit中本身不使用RxJava，retrofit的addCallAdatperFactorty（）中传入RxJavaCallAdapterFactory.Create()后，异步调用接口可以转化为RxJava的模式，进而使用RxJava的各种操作符。

以下是一个使用Okhttp+Retrofit+RxJava获取百度天气的一个例子

代码5

第四个例子：转换（Map操作符的使用）

代码6

以上是一对一的转换，当一个学生有多门课程的时候, 即一对多

代码7

第五个例子：RxJava代替EventBus进行数据传递：RxBus

IM举例来说，服务器推送来消息，更新消息的方法有如下几个：

1. 只更新当前页面，如有其他页面在onCreate()的时候传入值更新

2. 设置广播事件。来消息的时候发送广播提示更新

3. 设置接口。

4. 使用观察者模式。也就是Eventbus以及Rxbus实现的功能，或者Java中的Observable

上面的四种方式，

第一种差评，可以直接排除。

第二种，每条消息都要创建Intent，频繁的发广播

第三种，新房帮以前的就是类似这样做的，每个需要更新的页面都有一个refresh（）方法，维护起来十分麻烦（这种也是最原始的观察者模式了，只是没有使用API那么好用）

因此，在这里就可以使用Eventbus或者Rxbus了。

http://blog.csdn.net/liuye066/article/details/53924957

小结：

计算机基本功能就是处理数据，这种编程风格符合既符合计算机处理数据的方式，又有助人类阅读。

比如我们在读一段代码的时候，一般先去找核心语句，再去读其他的辅助语句，例如读httplient的时候先去找 excute（）语句，再去看上面参数设置之类的。RxJava是将要处理的数据从Observable发射到Observer，中间通过操作符来控制数据分发的方式。是一条线下来的。