RxJava 在 GitHub 主页上的自我介绍是 "a library for composing asynchronous and event-based programs using observable sequences for the Java VM"（一个在 Java VM 上使用可观测的序列来组成异步的、基于事件的程序的库）。
参考博客：http://gank.io/post/560e15be2dca930e00da1083
http://www.jianshu.com/p/5e93c9101dc5
github地址：https://github.com/ReactiveX/RxJava
https://github.com/ReactiveX/RxAndroid
本文针对的rxjava：1.0.14版本的，在moulde中的build.gradle的dependencies中添加如下依赖
compile 'io.reactivex:rxjava:1.0.14'
compile 'io.reactivex:rxandroid:1.0.1'
基本概念梳理
在Rxjava中，典型的思想就是就是观察者模式，如果对其不是其他熟悉的话，建议参考博客。
下面直接先介绍一些基本的概念。
**Observable **：英语翻译为：可观察的。在Rxjava中，Observable被用作可观察的对象。（可以这么理解，在button.setOnClick(new OnClickListener(){;;;})中，Observable对象就类似于button，即被监听的对象）
Observer：英语翻译为：观察者。同翻译一样，Observer就是来充当观察者的角色的，可以接收来自于Observable发送的数据（类似于button.setOnClick(new OnClickListener(){;;;}）中的new OnClickListener｛；；；｝，即要实现的动作）
Subscriber：英语翻译为：订阅者。Observer的增强版，主要功能同Observer，但相对Observer，subscriber多了一些方法。如取消订阅
unsubscribe( )。一般来说，使用的比较多的是Subscriber。建议使用Subscriber来当作观察者。
最基础的概念弄清楚了，接下来的代码就好理解了。
最简单的使用样例。
都说使用Rxjava可以使的代码的思路变得很清晰，那么首先尝试使用Rxjava来解决一些问题把。
eg：尝试将一张图片显示在imageView中。
public class NextActivity extends AppCompatActivity {
private ImageView mImageView;
private int drawRes = R.mipmap.ic_launcher;
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_next);
mImageView = (ImageView) findViewById(R.id.imageview);
Observable observable = Observable.just(drawRes);
//创建Observable对象，这里使用just创建，传入图片的id。
observable.subscribe(subscriber);
//绑定服务，通过subscribe将observale和subsciber连接起来。
}
//创建订阅者，实现具体逻辑
Subscriber<Integer> subscriber = new Subscriber<Integer>() {
@Override
public void onCompleted() {
//完成之后执行的回调
}
@Override
public void onError(Throwable e) {
//发生错误时执行的回调
}
@Override
public void onNext(Integer o) {
//普通事件，发出就需要执行完毕
mImageView.setImageResource(o);
}
};
}
运行上面的代码后，会发现image会正常的显示在imageview中。下面对其中的一些代码进行补充说明。
Observable的创建
Observable 即被观察者，他决定了什么时候触发事件已经触发什么样的事件。下面几种创建Observable的方法。
** 1. 利用create来创造 **
Observable observable1 = Observable.create(new Observable.OnSubscribe<Integer>() {
@Override
public void call(Subscriber<? super Integer> subscriber) {
subscriber.onNext(123);
subscriber.onNext(1223);
subscriber.onCompleted();
}
});
使用onSubscibe对象作为参数传入。OnSubscribe 的 call() 方法会自动被调用，事件序列就会依照设定依次触发（对于上面的代码，就是观察者Subscriber 将会被调用两次 onNext() 和一次 onCompleted()）。这样，由被观察者调用了观察者的回调方法，就实现了由被观察者向观察者的事件传递，即观察者模式。
** 2. 利用just（T ···）快捷创建**
Observable observable = Observable.just(123,1223);
just会将参数依次发送给subscibe
3. 利用from(T ```)快捷创建
Integer[] ids = {123,1223};
Observable observable1 = Observable.from(ids);
from会将将传入的数据或者Iterable拆分成具体对象后，依次发送。
上面1、2、3三种创建方法在效果上是等效的。
Observer的创建
Observer即观察者，它决定事件触发时候将会有怎么样的行为。Rxjava创建Observer的方式如下：
Observer<Integer> observer = new Observer <Integer>(){
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable e) {
}
@Override
public void onNext(Integer integer) {
}
};
对于Observer，Rxjava还提供了功能更加强大的Subscriber进行实现。通过Subscriber可以实现对Observer的扩展。
Subscriber<Integer> subscriber = new Subscriber<Integer>() {
@Override
public void onCompleted() {
//完成之后执行的回调
}
@Override
public void onError(Throwable e) {
//发生错误时执行的回调
}
@Override
public void onNext(Integer o) {
//普通事件，发出就需要执行完毕
mImageView.setImageResource(o);
}
@Override
public void onStart() {
super.onStart();
//开始之前的准备工作在这里执行(在Subscriber增加的方法)
}
};
其实两者的差别并不大，基本的使用方式一样。下面介绍以下两者之间细小的差别。
-
Observer完全可以用Subscriber来代替，事实上，Observer也是通过Subscriber来实现的，可以将Observer看做是简单化的Subscriber。 -
Subscriber添加在onStart()方法。。它会在 subscribe 刚开始，而事件还未发送之前被调用，可以用于做一些准备工作，例如数据的清零或重置。这是一个可选方法，默认情况下它的实现为空。
3.unsubscribe()是Subscriber实现的另一个接口。用于取消订阅。所以在这个方法调用之前，最好需要先使用isUnsubscribed()先判断一下状态，避免内存泄露。
创建关联
observable.subscribe(subscriber);
// observable.subscribe(observer);
将订阅者和观察者关联起来很简单，一行打码就解决了。
至此，创建一个简单的Rxjava模式的代码链就整理完毕。现在还没有看出Rxjava的威力，因为我们目前还只是简单的使用他显示一张图片而已。下面先介绍Rxjava更加简便的使用，下一篇博客介绍Rxjava真正牛逼的地方。
不完整的回调的实现
上面介绍的都是完整的回调实现，事实上，Rxjava为我们提供了更加方便快捷的不完整回调，Rxjava会自动创建Subscriber
形如：
Action0 action0 = new Action0() {
@Override
public void call() {
//要执行的回调
}
};
// 自动创建 Subscriber ，并使用action0 来定义 onNext()
observable.subscribe(action0);
Rxjava提供了10个Action，分别从Action0到Action9，后面的0-9代码这Action有几个参数，如果带有两个参数的话，可以这么写：
Action2<String ,Integer> action2 = new Action2<String, Integer>() {
@Override
public void call(String s, Integer integer) {
//要执行的回调
}
};
完整的实例：打印字符串数组。
String[] names = ...;
Observable.from(names)
.subscribe(new Action1<String>() {
@Override
public void call(String name) {
Log.d(tag, name);
}
});
至此，对Rxjava应该已经有了一个初步的了解，下一篇博客将介绍Rxjava真正强大的地方。
