RxJava+RxAndroid+MVP入坑实践（基础篇）

转载请注明出处：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。