什么是RxJava
- RxJava 就是异步
- RxJava 的异步实现,是通过一种扩展的观察者模式来实现的。
- 一个响应式编程框架
响应式编程
在说响应式编程的概念之前,我们先从这篇文章《用工厂流水线的方式来理解 RxJava 的概念》理解一下RxJava的意义。这里面说到的流水线的例子很确切,对于RxJava的响应式编程的思想是一个很好地类比。
从这个例子中,我们可以抽象出如下的流程
流水线——->操作工1—–>操作工2—–>…..操作工n–>产品经理
这也十分切合响应式编程的流程
Observable -> Operator 1 -> Operator 2 -> Operator 3 -> Subscriber
如文中所讲,产品经理很重要,推动了整个事件的方法,这一点也是RxJava 区别于传统的观察者模式的地方,没有订阅者(subscriber)时,Observeable 是不会发送事件的。
作为操作符,就像流水线上的工人,既要各司其职的完成各种工作,同时也要保证事件的处理永远处于流水线上,这也是RxJava响应式编程的关键点,“流”的概念。
在这里,产品经理(Subscriber )也会完成一些重要的工作,但它希望流水线上的每个操作工(RxJava的操作符)也能完成一些重要的事情,能最大程度的确保产品经理已经完成的工作不需要再做修改。
下面结合一个简单的例子说明一下,RxJava中响应式编程的优点。
RxJava 事件处理
假设,现有如下需求,输出下面数组中每个数与 10 的余数
List<Integer> numbers = new ArrayList<>();
for (int i = 5; i >= 0; i--) { numbers.add(i); }
用RxJava实现如下:
Observable.from(numbers)
.map(new Func1<Integer, Integer>() {
@Override
public Integer call(Integer integer) {
return 10 % integer;
}
})
.subscribe(new Subscriber<Integer>() {
@Override
public void onCompleted() {
Log.e(MainActivity.class.getSimpleName(), "onCompleted");
}
@Override
public void onError(Throwable e) {
Log.e(MainActivity.class.getSimpleName(), "onError---->" + e.getMessage());
}
@Override
public void onNext(Integer integer) {
Log.e(MainActivity.class.getSimpleName(), "onNext---- >Remainder is " + integer);
}
});
输出:
可以看到,这里出错了,数组中有一项为0 ,导致了除数为0,发生了异常,但是程序并没有崩溃,而是抛出了异常信息。同时onError方法执行了,而onComplete()方法没有执行。
我们修复一下这个错误(这里假设我们无法修改初始数据,也就是这里的numbers数组)
Observable.from(numbers)
.filter(new Func1<Integer, Boolean>() {
@Override
public Boolean call(Integer integer) {
return integer!=0;
}
})
.map(new Func1<Integer, Integer>() {
@Override
public Integer call(Integer integer) {
return 10 % integer;
}
})
.subscribe(new Subscriber<Integer>() {
@Override
public void onCompleted() {
Log.e(MainActivity.class.getSimpleName(), "onCompleted");
}
@Override
public void onError(Throwable e) {
Log.e(MainActivity.class.getSimpleName(), "onError---->" + e.getMessage());
}
@Override
public void onNext(Integer integer) {
Log.e(MainActivity.class.getSimpleName(), "onNext---- >Remainder is " + integer);
}
});
输出如下:
我们使用RxJava的操作符filter 过滤掉了0,这样就不会有错误,最终执行了onCompleted方法。
从上面的例子中,我们得出如下结论:
- 在一次完整的事件中,onNext可能会执行0-n次,而onError() 和 onCompleted()中必有一个方法会执行。
- 有异常发生,onError就会调用
- 订阅者如果完成了所有事件的处理,onCompleted就会执行,使得我们可以得知整个事件结束了
- 操作符不负责处理异常,而是由订阅者处理。
这里想一下,按照以往的方式,发生错误时,通常是在每个回调中处理错误。这不仅导致了重复的代码,并且意味着每个回调都必须知道如何处理错误,你的回调代码将和调用者紧耦合在一起。
使用RxJava,Observable对象根本不需要知道如何处理错误!操作符也不需要处理错误状态-一旦发生错误,就会跳过当前和后续的操作符。所有的错误处理都交给订阅者来做。
但是,这种机制也不是完美,有时候我们可能需要对不同的错误做出不同的处理,RxJava的机制反而不适合了。
这里只是对响应式编程思想的简单了解!