RxJava 和 RxAndroid 一 (基础)

1、RxJava 项目地址   https://github.com/ReactiveX/RxJava 2、RxAndroid 项目地址   https://github.com/ReactiveX/RxAndroid 3、RxJava 和 RxAndroid 的关系     RxAndroid是RxJava的一个针对Android平台的扩展，主要用于 Android 开发 4、RxJava和EventBus的区别？     https://www.zhihu.com/question/32179258/answer/54989242 5、RxAndroid的使用方法    compile 'io.reactivex:rxandroid:1.2.0'   6、如何查看RxAndroid最新版本？    http://search.maven.org/#search%7Cga%7C1%7Ca%3A%22rxandroid%22  7、RxAndroid具体使用方法

     http://gank.io/post/560e15be2dca930e00da1083#toc_14

     http://blog.csdn.net/theone10211024/article/details/50435325

    http://huxian99.github.io/tags/RxJava/    https://github.com/mcxiaoke/RxDocs 

 8、创建观察者

从上文可以看到，Subscriber继承Observer, 只是 Subscriber对Observer做了一些扩展。Subscriber的使用和Observer完全一样。
 Subscriber 多了一个 onStart 方法

onStart()

: 这是 

Subscriber

 增加的方法。它会在 subscribe 刚开始，而事件还未发送之前被调用，可以用于做一些准备工作，例如数据的清零或重置。这是一个可选方法，默认情况下它的实现为空。需要注意的是，如果对准备工作的线程有要求（例如弹出一个显示进度的对话框，这必须在主线程执行）， 

onStart()

 就不适用了，因为它总是在 subscribe 所发生的线程被调用，而不能指定线程。要在指定的线程来做准备工作，可以使用 

doOnSubscribe()

 方法，具体可以在后面的文中看到。
　　

9、创建被观察者

Call()方法：当 

Observable

 被订阅的时候，

OnSubscribe

 的 

call()

 方法会自动被调用，事件序列就会依照设定依次触发（对于上面的代码，就是观察者

Subscriber

 将会被调用三次 

onNext()

 和一次 

onCompleted()

）。这样，由被观察者调用了观察者的回调方法，就实现了由被观察者向观察者的事件传递，即观察者模式。
　　

 10、订阅

      由于观察者可以由两种方式被创建，所以订阅的方式也有两种

Observable.subscribe(Subscriber)

 的内部实现是这样的（仅核心代码）：
在subscribe() 中，首先会调用 onStart() 方法，这个方法前文已经介绍了，是可选的。接着会调用 call()方法，我们已经分析了在call()方法中会调用多次 onNext() ，最后调用 onCompleted().看到这里你就会突然明白原来subscribe() 方法其实相当于依次执行了：onStart() --> onNext（）--> onCompleted（）
从这也可以看出，在 RxJava 中，

Observable

 并不是在创建的时候就立即开始发送事件，而是在它被订阅的时候，即当 

subscribe()

 方法执行的时候。

Observer

 和 

Subscriber

 具有相同的角色，而且 

Observer

 在 

subscribe()

 过程中最终会被转换成 

Subscriber

对象
将传入的 

Subscriber

 作为 

Subscription

 返回。这是为了方便 

unsubscribe()

.   
 

 11、RxBus

         你是否听说过EventBus , 他是android 中的事件总线。用rxjava同样可以实现android的事件总线功能，也就是RxBus.        关于rxbus 的基本说明在这里 http://nerds.weddingpartyapp.com/tech/2014/12/24/implementing-an-event-bus-with-rxjava-rxbus/        然而这并没有什么卵用 ！         下面是RxBus的封装版    　   　　RxBus的使用在Activity销毁的时候，要取消订阅服务 。 否则 post() 次数会随着post()调用逐渐增加
除了上面的简单使用外，还可以使用  Schedulers 、AndroidSchedulers 进行线程切换