Rx是响应式编程的意思, 本质是观察者模式, 是以观察者(Observer)和订阅者(Subscriber)为基础的异步响应方式. 在Android编程时, 经常会使用后台线程, 那么就可以使用这种方式. 目前的异步编程方式都会导致一些问题, 如

(1) Asynctasks can easily lead to memory leaks

(2) CursorLoaders with a ContentProvider require a large amount of configuration and boilerplate code to setup.

(3) Services are intendedfor longer running background tasks and not fast-finishing operations, such as making a network call or loading content from a database.

RxAndroid来源于RxJava, 在RxJava的基础上扩展了一些Android的功能 来处理异步的任务处理,它可以使代码更加优雅，代码的可维护性更强。

下面简单介绍Rx_Android的几种实用方法

1.create方式(1)建立

/**

* 使用create方式

*/

public static void createObserable(){

Observableobservable=Observable.create(new Observable.OnSubscribe(){

@Override

public void call(Subscriber super String> subscriber) {

if(!subscriber.isUnsubscribed()){

subscriber.onNext("hello");

subscriber.onNext("world");

subscriber.onNext(downloadJson());

subscriber.onCompleted();

}

}

});

Subscribershowsub=new Subscriber() {

@Override

public void onCompleted() {

Log.e(TAG,"onCompleted");

}

@Override

public void onError(Throwable e) {

Log.e(TAG,e.getMessage());

}

@Override

public void onNext(String s) {

Log.e(TAG,"result->>"+s);

}

};

//关联被观察者

observable.subscribe(showsub);

}/**

* 调用下载方法

* @return

*/

public static String downloadJson(){

return "json success!";

}

cretae 方式(2)建立/**

* create的第2中方法

*/

public static void createPrint(){

Observable.create(new Observable.OnSubscribe() {

@Override

public void call(Subscriber super Integer> subscriber) {

if(!subscriber.isUnsubscribed()){

for(int i=0;i<10;i++){

subscriber.onNext(i);

}

subscriber.onCompleted();

}

}

}).subscribe(new Subscriber() {

@Override

public void onCompleted() {

Log.i(TAG,"onCompleted");

}

@Override

public void onError(Throwable e) {

Log.i(TAG,e.getMessage());

}

@Override

public void onNext(Integer integer) {

Log.i(TAG,"result-->>"+integer);

}

});

}