转载请注明出处：http://www.blog.csdn.net/zhyxuexijava/article/details/51597230.com
前段时间看了MVP架构和RxJava,最近也在重构一些项目（MVC架构），于是写一个简单的例子，好了，废不多说了，入坑开始。
一.RxJava是什么？
GitHub（[https://github.com/ReactiveX/RxJava]）(https://github.com/ReactiveX/RxJava)上是这样解释的：
RxJava is a Java VM implementation of Reactive Extensions: a library for composing asynchronous and event-based programs by using observable sequences.
RxJava是一个在Java虚拟机上的Reactive扩展程序：在Java虚拟机上使用可观测的序列来组成异步的，基于事件的程序的库。
简单的说：RxJava其实可以理解为一个普通的Java库。它的本质就是异步。
二.为什么要使用RxJava
两个字：简洁。它的异步调用随着程序逻辑变得越来越复杂，它的链式调用依然能够保持简洁。
三.API介绍和原理解析
1.概念
RxJava 的异步实现，是通过一种扩展的观察者模式来实现的。从纯Java的观点来看，RxJava Observable类源自于经典的观察者模式。
它添加了三个缺少的功能：
- 生产者在没有更多数据可用时能够发出通知信号：onCompleted事件。
- 生产者在发生错误时能够发出通知信号：onError()事件。
- RxJava Observables能够组合而不是嵌套，从而避免开发者陷入回调的地狱。
那么我们什么时候使用观察者模式（题外话）？
- 当你的架构有两个实体类，一个依赖另外一个，你想让它们互不影响或者是独立复用它们。
- 当一个变化的对象通知那些与它自身变化相关联的未知数量的对象时。
- 当一个变化的对象通知那些无需推断具体的对象是谁。
RxJava的观察者模式：
Observable (被观察者)、 Observer (观察者)、 subscribe (订阅)。Observable 和 Observer 通过 subscribe() 方法实现订阅关系，从而 Observable 可以在需要的时候发出事件来通知 Observer。
RxJava的回调方法主要有三个，onNext()，onError(),onCompleted()。
- onNext() 对于Subscribler我们可以理解为接收数据。
- onCompleted() 观测的事件的队列任务都完成了，当不再有onNext()发射数据时，onCompleted事件被触发。
- onError() 当事件异常时响应此方法，一旦此方法被触发，队列自动终止，不再发射任何数据。
（其实onCompleted()和onError()我们可以理解为网络请求框架中的onSuccess()和onError(),一个是服务器响应成功，一个是响应失败，这两个方法同时只有一个能够被执行，onCompleted()和onError()同理,onNext()可以理解为客户端接收数据，不同的是服务器必须一次性返回响应信息，而RxJava可以一个一个数据返回或者一次性返回整个列表之类的）
4.实践
下面举个例子：
package com.test.rxjava;
import android.os.Bundle; import android.support.v7.app.AppCompatActivity; import android.util.Log; import android.view.View; import android.widget.Button; import android.widget.TextView; import android.widget.Toast;
import butterknife.Bind; import butterknife.ButterKnife; import butterknife.OnClick; import rx.Observable; import rx.Subscriber; import rx.android.schedulers.AndroidSchedulers;
public class MainActivity extends AppCompatActivity {
@Bind(R.id.tv_show)
TextView tvShow;
@Bind(R.id.btnChange)
Button btnChange;
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
ButterKnife.bind(this);
}
@Override
protected void onDestroy() {
super.onDestroy();
ButterKnife.unbind(this);
}
@OnClick({R.id.btnChange})
public void click(View v){
changeView(); //改变TextView的内容，初始值为Hello wORLD
}
private void changeView() {
/**，被观察者**/
Observable<String> myObservable = Observable.create(
new Observable.OnSubscribe<String>() {
@Override
public void call(Subscriber<? super String> subscriber) {
subscriber.onNext("Hello Reactive Android!!");
subscriber.onCompleted();
}
}
);
/**接观察者**/
Subscriber<String> mySubscriber = new Subscriber<String>() {
@Override
public void onCompleted() {
Toast.makeText(MainActivity.this, "更换内容成功", Toast.LENGTH_SHORT).show();
}
@Override
public void onError(Throwable e) {
Toast.makeText(MainActivity.this, "更换内容失败", Toast.LENGTH_SHORT).show();
}
@Override
public void onNext(String s) {
Log.d("danxx", "onNext--->" + s);
tvShow.setText(s.toString());
}
};
/**订阅事件**/
myObservable.observeOn(AndroidSchedulers.mainThread()).subscribe(mySubscriber);
} }
在builde.gradle中的配置配置：
运行结果：
说明：1.observeOn(AndroidSchedulers.mainThread())主要是由于android必须在主线程中更新UI
2.本例中用了ButterKnife。