Rxjava笔记.docxVIP

什么是Rxjava一个词：异步。一个实现异步操作的库，而别的定语都基于这之上。Rxjava好处逻辑简洁。一条从上到下的链式调用。扩展的观察者模式先介绍一个名词：Observable(被观察者)，Observer(观察者)，subscribe(订阅)，事件(onNext(),onError(),onCompleted())。onCompleted():事件队列完结。Rxjava不仅把每个事件单独处理，还会把他们看成一个队列。Rxjava规定，不会再有新的。onNext():发出时，需要onCompleted()方法作为标志。onError():事件队列异常。在事件处理过程中抛出异常则会被触发，同时队列自动终止，不允许再有事件发出。在一个正确运行的事件序列中，onCompleted()和onError()有切只有一个，并且是事件序列的最后一个，两者并且是互斥的，只会调用一个。Rxjava的基本实现主要有三点：创建Observer(观察者)：Observer接口的实现方式：ObserverString observer = new ObserverString(){@Overridepublic void onNext(String s){}@Overridepublic void onCompleted(){}@Overridepublic void onError(Throwable e){}}除Observer接口之外，Rxjava还内置了一个实现了Observer的抽象类：Subscriber。Subsvriber对Observer接口进行了一些扩展，但是他们的基本使用方法完全一致：SubscriberString subsvriber= new SubscriberString(){@Overridepublic void onNext(String s){}@Overridepublic void onCompleted(){}@Overridepublic void onError(Throwable e){}}新增的两点类容：onStart():这是Subscriber增加的方法。他会在subscriber刚开始，而事件还未发出之前被调用，可以用于做一些准备工作。unSubscriber():这是Subscriber所实现的另一个接口Subscription的方法，用于取消订阅。创建Observabel(被观察者)Observable observable = Observable.create(new Observeable.OnSubscirbeString(){@OverridePublic void call(Subscribe? Super String subscribe){subscribe.onNext(“hi”) ;subscribe.onNext(“hello world”) ;subscribe.onCompleted() ;}});可以看到这里传入了Onsubscribe对象作为参数。create()方法是Rxjava最基本的创建事件的序列方法。基于这个方法，Rxjava还提供 了一些方法来快捷创建事件队列，例如：Observable observable = Observable.just(“hi”,”hello world”) ;或者：String[] words = {“hi”,”hello world”} ;Observable observable = Observable.from(words) ;上面两种分别会调用subscribe.onNext(“hi”) ;subscribe.onNext(“hello world”) ;subscribe.onCompleted() ;Subscribe(订阅)创建了Observable(被观察者)和Observer(观察者)之后，就是把他们两个用subscribe()方法关联起来，则可以开始工作了。Observable.subscribe(observer) ;或者：Observable.subscribe(subscriber) ;线程控制----Scheduler(一)Schedulers.immdiate():直接在当前线程运行，相当于不指定线程。这是默认的Scheduler。Schedulers.newThread():启用新线程，并在新线程执行操作Schedulers.io():I/O操作所有的Scheduler。行为模式和newThread()差不多，区别在于io()内部实现是用一个无数量上线的线程池，可以重用空闲的线程，因此多数情况io()比newThread()更有效率。不要把计算工作放在io()中，可以避免创建不