RxJava 最简单的入门

celuda 7年前
   <h2><strong>一,RxJava的概述</strong></h2>    <p><strong>1.0 什么是RxJava</strong></p>    <p>要知道RxJava是什么,那么你应该先去了解一下Rx。Rx的全称是Reactive Extensions,直译过来就是响应式扩展。Rx基于观察者模式,他是一种编程模型,目标是提供一致的编程接口,帮助开发者更方便的处理异步数据流。</p>    <p>那么到底什么是RxJava呢?我对它的定义是:RxJava本质上是一个异步操作库,是一个能让你用极其简洁的逻辑去处理繁琐复杂任务的 异步 事件库。</p>    <p><strong>1.1 RxJava的好处</strong></p>    <ol>     <li>规范项目成员的代码实现</li>     <li>让复杂的逻辑变得有条理性</li>    </ol>    <p><strong>1.2 必须要了解的观察者模式</strong></p>    <p>TODO This</p>    <p>在这个事件中, 台灯作为观察者,开关作为被观察者,台灯透过电线来观察开关的状态来并做出相应的处理</p>    <p style="text-align: center;"><img src="https://simg.open-open.com/show/6d47c3fafb124576fc12e1206824512b.png"></p>    <p style="text-align:center">观察者.png</p>    <p><strong>1.3 RxJava的基本元素</strong></p>    <ol>     <li>Observable :被观察者,事件源</li>     <li>Subscriber/Observer :观察者</li>     <li>OnSubscribe :一个接口类,是连接被观察者和观察者的桥梁,另外要说明的是onSubscribe是Observable的一个局部变量</li>    </ol>    <h2><strong>二,RxJava的简单使用</strong></h2>    <p><strong>2.1 使用步骤</strong></p>    <ol>     <li> <p>导包: 在build.gradle中导入如下:</p> <pre>  <code class="language-java">compile 'io.reactivex:rxandroid:1.2.0'   compile 'io.reactivex:rxjava:1.1.5'</code></pre> </li>     <li>创建 被观察者(Observerable<>)对象</li>     <li>创建 观察者 (Subscriber或者Observer)对象</li>     <li>通过订阅:把观察者和被观察者进行相互关联</li>    </ol>    <p><strong>2.2 最简单的实例演示</strong></p>    <p>TODO This</p>    <h2><strong>三,RxJava的操作符详解</strong></h2>    <p><strong>3.1 创建操作:创建Observable(被观察者)的操作符</strong></p>    <ol>     <li><strong>create</strong> : 使用OnSubscribe从头创建一个Observable,这种方法比较简单。需要注意的是,使用该方法创建时,建议在OnSubscribe#call方法中检查订阅状态,以便及时停止发射数据或者运算。</li>     <li><strong>from</strong> :将一个Iterable, 一个Future, 或者一个数组,内部通过代理的方式转换成一个Observable。代码如下: <pre>  <code class="language-java">String[] array = {"hello", "rxJava"};   Observable<String> observable = Observable.from(array);</code></pre> </li>     <li> <p>just:将一个或多个对象转换成发射这个或这些对象的一个Observable。如果是单个对象,内部创建的是ScalarSynchronousObservable对象。如果是多个对象,则是调用了from方法创建。</p> <pre>  <code class="language-java">Observable<String> observable1 = Observable.just("hello", "rxjava");</code></pre> </li>     <li><strong>empty</strong> : 创建一个什么都不做直接通知完成的Observable</li>     <li><strong>error</strong> : 创建一个什么都不做直接通知错误的Observable</li>     <li><strong>never</strong> : 创建一个什么都不做的Observable</li>    </ol>    <p><strong>3.2变换操作符:</strong></p>    <ol>     <li> <p><strong>map : 所谓变换,就是将事件序列中的对象或整个序列进行加工处理,转换成不同的事件或事件序列。</strong></p> <pre>  <code class="language-java">//举个栗子   //比如被观察者产生的事件中只有图片文件路径;但是在观察者这里只想要bitmap,那么就需要**类型变换**。    Observable.create(new Observable.just(getFilePath()) //使用map操作来完成类型转换    .map(new Func1<String, Bitmap>() {              @Override public Bitmap call(String s) { //显然自定义的createBitmapFromPath(s)方法,是一个极其耗时的操作                        return createBitmapFromPath(s); } })    .subscribe( //创建观察者,作为事件传递的终点处理事件               new Subscriber<Bitmap>() {                      @Override                     public void onCompleted() {                                                                               Log.d("DDDDDD","结束观察...\n");                       }                     @Override                      public void onError(Throwable e) {                              //出现错误会调用这个方法                      }                    @Override                    public void onNext(Bitmap s) {                              //处理事件 showBitmap(s)                   }          );</code></pre> </li>    </ol>    <p>未完待续。。。</p>    <h2><strong>四,关于异步(线程调度)Scheduler</strong></h2>    <p><strong>4.1 线程环境</strong></p>    <p><img src="https://simg.open-open.com/show/85953617e57eef4eb196ecd287964fcb.png"></p>    <p style="text-align:center">RxJava的线程.png</p>    <pre>  <code class="language-java">Observable.just(1, 2, 3, 4) // IO 线程,由 subscribeOn() 指定           .subscribeOn(Schedulers.io())           .observeOn(Schedulers.newThread())          .map(mapOperator) // 新线程,由 observeOn() 指定           .observeOn(Schedulers.io()) .map(mapOperator2) // IO 线程,由 observeOn() 指定           .observeOn(AndroidSchedulers.mainThread)           .subscribe(subscriber); // Android 主线程,由 observeOn() 指定</code></pre>    <ul>     <li>这里注意的是: 有两个重要的api      <ul>       <li>subscribeOn( )</li>       <li>observeOn( )</li>      </ul> </li>     <li>需要注意的是(对于初学者,先了解到此就足够使用了):      <ul>       <li>subscribeOn()它指示Observable在一个指定的调度器上 <strong>创建</strong> (只作用于被观察者创建阶段)。只能指定一次,如果指定多次则以第一次为准</li>       <li>observeOn()指定在事件传递(加工变换)和最终被处理(观察者)的发生在哪一个调度器。可指定多次,每次指定完都在下一步生效。</li>      </ul> </li>    </ul>    <p> </p>    <p>来自:http://www.jianshu.com/p/1c5800b3ff39</p>    <p> </p>