当钢铁侠反应更灵敏-RxJava
MartiLyles
9年前
<p>本系列的这个部分主要是讲一些函数式技巧能给我们的项目带来的好处。</p> <p><a href="/misc/goto?guid=4958979542149358570" rel="nofollow,noindex">ReactiveX</a> 中的 <code>RxJava</code> 是一个可以帮助我们轻松处理不同运行环境下的后台线程或UI线程任务的框架。这在 Android 上一直是我们所有人的噩梦。</p> <p>这篇文章主要会谈谈其中（RxJava）的一些 operators 如何能在常见开发任务中为我们节省时间， <a href="/misc/goto?guid=4958979542149358570" rel="nofollow,noindex">Reactive Extensions</a> 提供了很多种类的 operators 来让我们用的更方便。</p> <p>像以前一样，大部分代码和片段都已经上传到了 Github, 请随意评论、提 issue 或吐槽！</p> <p><a href="/misc/goto?guid=4959652738489516809" rel="nofollow,noindex">Avengers app on Github</a></p> <p>在本系列 <a href="/misc/goto?guid=4959661700402100909" rel="nofollow,noindex">第一部分</a> 中我们介绍了 <a href="/misc/goto?guid=4958873636911828578" rel="nofollow,noindex">Dagger 2</a> ，现在我们更进一步会看到如何降低各层代码逻辑之间的耦合、增加可扩展性。</p> <p>RetroLambda</p> <p>有时，在 Java 开发的大型应用程序中，或 Android 这样的大型框架中，使用 Java 8 中的 Lambda 表达式这类特性是非常困难或是几乎不可能的(Android中)。</p> <p>Retrolambda 就是来解决这个问题的，它会把 Java 8 的字节码翻译成低版本 Java 像v7甚至v5、v6的字节码，这样可以让我们在这些低版本中使用到 Lambda 表达式的特性。</p> <p><img src="https://simg.open-open.com/show/8b8ce4379ddba1bd6105dcc7b83f79d4.png" alt="当钢铁侠反应更灵敏-RxJava" width="550" height="242"></p> <p><a href="/misc/goto?guid=4958988011886584490" rel="nofollow,noindex">Retrolambda</a> 可以通过 Gradle 或 Maven 的方式来使用，我选择 Gradle 是因为 Android Studio 对其支持的很好。要使用它你只需要将 <code>[Retrolambda](https://github.com/orfjackal/retrolambda)</code> 插件加到项目根目录的<code>build.gradle</code> ， 同时在 module 的 build 脚本中应用它，再设置 Android Studio 的语言级别到 <code>1.8</code> ，这就完成了。</p> <p>build.gradle (root)</p> <pre> <code class="language-java">dependencies { classpath 'me.tatarka:gradle-retrolambda:3.1.0' }</code></pre> <p>{your module}/build.gradle</p> <pre> <code class="language-java">apply plugin: 'me.tatarka.retrolambda' android { ... compileOptions { sourceCompatibility JavaVersion.VERSION_1_8 targetCompatibility JavaVersion.VERSION_1_8 } }</code></pre> <p><a href="/misc/goto?guid=4958988011886584490" rel="nofollow,noindex">Retrolambda</a> 可以让你少写很多重复的代码，同时理顺我们的代码让它有更好的可读性。在 <a href="/misc/goto?guid=4959631833554996799" rel="nofollow,noindex">Dan Lew</a> 给出的这个例子中，你可以感受到它所带来的不同。</p> <p>没有 Retrolambda</p> <pre> <code class="language-java">Observable.just("Hello, world!") .subscribe(new Action1<String>() { @Override public void call(String s) { System.out.println(s); } });</code></pre> <p>有 Retrolambda</p> <pre> <code class="language-java">Observable.just("Hello, world!") .subscribe( s -> System.out.println(s) );</code></pre> <p>在我们的 Avengers 示例中</p> <pre> <code class="language-java">mCharacterSubscription = mGetCharacterInformationUsecase .execute().subscribe( character -> onAvengerReceived(character), error -> manageError(error) ); mComicsSubscription = mGetCharacterComicsUsecase .execute().subscribe( comics -> Observable.from(comics).subscribe( comic -> onComicReceived(comic)), error -> manageError(throwable) );</code></pre> <p>ReactiveX</p> <p><a href="/misc/goto?guid=4958979542149358570" rel="nofollow,noindex">ReactiveX</a> 是一个开源项目的集合，它们所遵循的主要原则都是 <a href="/misc/goto?guid=4958332597231543679" rel="nofollow,noindex">Observer</a> 模式、<a href="/misc/goto?guid=4959671484034154344" rel="nofollow,noindex">Iterator</a> 模式以及函数式编程。</p> <p><a href="/misc/goto?guid=4958979542149358570" rel="nofollow,noindex">ReactiveX</a> 同时也提供了可用于异步编程的API，事实上使用这些框架来实现异步任务非常简单。</p> <p>ReactiveX 的异步客户端用法</p> <p>在使用 <a href="/misc/goto?guid=4958979542149358570" rel="nofollow,noindex">ReactiveX</a> 时最棒的是你可以创建一个完全异步的API或客户端，在实现具体逻辑的时候再决定是把代码写成异步的、放到线程池中的一个独立线程执行、还是同步来执行。</p> <p>因此我们可以得到一个观察者模式的API而不是一个阻塞调用的API。</p> <pre> <code class="language-java">public interface Usecase<T> { Observable<T> execute(); } public interface Repository { Observable<Character> getCharacter (final int characterId); Observable<List<Comic>> getCharacterComics (final int characterId); }</code></pre> <p>RxJava是什么</p> <p><a href="/misc/goto?guid=4958865750209621132" rel="nofollow,noindex">RxJava</a> 是一个由 <strong>Netflix</strong> 开发的 <a href="/misc/goto?guid=4959671484161948470" rel="nofollow,noindex">Reactive Extensions</a> 的(Java版)实现。其他还有大量主流编程语言的实现，包括 Javascript, Python, Ruby, Go 等等。</p> <p>Observables 和 Observers</p> <p>一个 <code>Observable</code> 可以输出一个或一系列的 objects，这些 objects 会被订阅到这个<code>Observable</code> 的 <code>Observer</code> 所处理或接收。</p> <p><img src="https://simg.open-open.com/show/6b4e03bd4be72e9a8240907545d2ddf9.png" alt="当钢铁侠反应更灵敏-RxJava" width="452" height="499"></p> <p>把一个 <code>Observer</code> 注册到一个 <code>Observable</code> 上是很必要的，如果不这么做的话<code>Observable</code> 什么都不会输出。当 <code>Observer</code> 注册之后，一个 <code>Subscription</code> 类型的实例会创建，它可以用来取消对 <code>Observable</code> 的订阅，这通常在 <code>Activities</code> 和<code>Fragments</code> 的 <code>onStop</code> 或 <code>onPause</code> 方法中非常有用，例如：</p> <pre> <code class="language-java">mCharacterSubscription = mGetCharacterInformationUsecase .execute().subscribe( ... ); @Override public void onStop() { if (!mCharacterSubscription.isUnsubscribed()) mCharacterSubscription.unsubscribe(); if (!mComicsSubscription.isUnsubscribed()) mComicsSubscription.unsubscribe(); }</code></pre> <p>无论何时 <code>Observer</code> 订阅 <code>Observable</code> 的消息，它都需要考虑处理3个方法：</p> <p>– <code>onNext (T)</code> 方法用来接收 <code>Observable</code> 发出的 objects.</p> <p>– <code>onError (Exception)</code> ，这个方法会在内部抛出异常的时候调用。</p> <p>– <code>onCompleted()</code> ，这个方法会在 <code>Observable</code> 停止释放 objects 的时候调用。</p> <p>我喜欢这张图 <img src="https://simg.open-open.com/show/1e4c647076e9f658366f780780fab45b.png" alt="当钢铁侠反应更灵敏-RxJava" width="72" height="72"><img src="https://simg.open-open.com/show/c8f1cdb6c4e0b7589b2303e646fb81c7.png" alt="当钢铁侠反应更灵敏-RxJava" width="550" height="394"></p> <p>组件间通信</p> <p>让我们来看看如何使用 <code>GetCharacterInformationUsecase</code> 这个用例，所有的用例都实现了 <code>Usecase <T></code> 接口。</p> <pre> <code class="language-java">public interface Usecase<T> { Observable<T> execute(); }</code></pre> <p>这个例子被调用的时候会返回一个 <code>Observable</code> 类型的实例，它可以轻松的和其他的 observables 和 operators 组合成链式结构，我们很快将会看到这些 operators 的强大威力。</p> <p>当我们调用 <code>GetCharacterInformationUsecase</code> 的时候请求我们的仓库产生一个对应类型的数据源：</p> <pre> <code class="language-java">@Override public Observable<Character> execute() { return mRepository.getCharacter(mCharacterId); // .awesomeRxStuff(); }</code></pre> <p><code>AvengerDetailPresenter</code> 这个 presenter 将会成为我们这个用例的 <code>Observer</code>，它将会订阅这个 <code>Observable</code> 发出的所有事件，这个操作可以通过调用<code>subscribe</code> 方法来完成，这样就把 <code>Observer</code> 和 <code>Observable</code> 关联在一起了。</p> <p>实现 <code>onNext</code> 和 <code>onError</code> 方法可以来处理操作结果。 <code>onCompleted</code> 方法并没有实现，因为在这个例子中不需要。</p> <pre> <code class="language-java">mCharacterSubscription = mGetCharacterInformationUsecase .execute().subscribe( character -> onAvengerReceived(character), error -> manageError(error));</code></pre> <p>Retrofit 和 RxJava</p> <p><a href="/misc/goto?guid=4958822644670803368" rel="nofollow,noindex">Square</a> 出品了 <a href="/misc/goto?guid=4958964956869128717" rel="nofollow,noindex">Retrofit</a> ， <a href="/misc/goto?guid=4958865750209621132" rel="nofollow,noindex">RxJava</a> 支持其中的 <code>rx.Observable</code> 方法，这样网络请求的结果就可以通过 <code>Observer</code> 的方式来订阅、修改或通过 operators 加工。</p> <p>你一定得十分清楚在什么地方来调用它， <a href="/misc/goto?guid=4958964956869128717" rel="nofollow,noindex">Retrofit</a> 的请求会在 <code>Observable</code> 所在线程上来执行，因此当你在 UI 线程(Activity 或 Fragment 中)来调用的话就会报错。接下来我们讲讲 <code>Schedulers</code> !</p> <p>Schedulers</p> <p><a href="/misc/goto?guid=4959646508626849535" rel="nofollow,noindex">Schedulers</a> 可以让你在多线程中使用 <code>operators</code> 和 <code>Observables</code> 。它可以被用在不同的线程、一个 线程 Executor 或是预设的 <code>[Schedulers](http://reactivex.io/documentation/scheduler.html)</code> 中。例如，对于输入或输出这类操作会在 <code>Schedulers.io ()</code> 来执行。</p> <p><a href="/misc/goto?guid=4958873637259306454" rel="nofollow,noindex">RxAndroid</a> 是由 <a href="/misc/goto?guid=4959550705488979968" rel="nofollow,noindex">Jake Wharton</a> 和 <a href="/misc/goto?guid=4959671484407145216" rel="nofollow,noindex">Matthias Käppler</a> 开发的一些 Android 下专用的 <a href="/misc/goto?guid=4958865750209621132" rel="nofollow,noindex">RxJava</a> 的工具，其中包括一些用来处理 Android 平台下多进程调用的<code>Schedulers</code> 。</p> <p>它也提供了使用 Android 的 <code>Handler</code> 来处理并发的方式。</p> <pre> <code class="language-java">@Override public Observable<Character> execute() { return mRepository.getCharacter(mCharacterId) .subscribeOn(Schedulers.newThread()) .observeOn(AndroidSchedulers.mainThread()); }</code></pre> <p>这个例子演示了 Rx 提供的处理 Android 中多进程调用的方式，这真是非常的炫酷 ��</p> <p>Operators</p> <p><a href="/misc/goto?guid=4958979542149358570" rel="nofollow,noindex">ReactiveX</a> 最厉害的要数它的 <code>operators</code> 了，它们可以用来操作、变换、合并<code>Observables</code> 输出的 objecs。</p> <p>我们来看看一个漫画列表的例子，漫画都有一个特定的出版年份，我们想要展示特定年份出版的漫画，这时 <a href="/misc/goto?guid=4958979542149358570" rel="nofollow,noindex">ReactiveX</a> 就能大显身手了！</p> <p>这个过滤过程是通过 <code>filter</code> 这个 operator 来完成的，它可以作为漫画的一个约束条件来加以判断。在这个过程中，询问用户要过滤出哪一年，然后使用这个年份来判定一个漫画是否允许被展示。</p> <pre> <code class="language-java">public Observable<Comic> filterByYear(String year) { if (mComics != null) { return Observable.from(mComics).filter( comic -> { for (ComicDate comicDate : comic.getDates()) if (comicDate.getDate().startsWith(year)) return true; return false; }); } return null; }</code></pre> <p>异常处理</p> <p>另一个很好的 Rx 的 operators 能帮我们节省时间提升效率的例子是异常处理的 operators。</p> <p>设想一个用户要请求网络，但是在网络通道上发生了一些偶然因素，网络连接在这种情况下受到了影响。</p> <p>当我们接收到了 <a href="/misc/goto?guid=4958837204152834453" rel="nofollow,noindex">Retrofit</a> 抛出的 <code>SocketTimeoutException</code> 异常时，我们可以利用 <a href="/misc/goto?guid=4959671484538522513" rel="nofollow,noindex">retry</a> 这个 operator 来处理。</p> <p><a href="/misc/goto?guid=4959671484538522513" rel="nofollow,noindex">retry</a> 可以接收一个判定条件，就像之前我们在 <a href="/misc/goto?guid=4959657463019796329" rel="nofollow,noindex">filter</a> 中所做的一样，如果返回 true，那么 Rx 就会神奇的再次调用 <code>Observable</code> 重新执行 Retrofit 的网络请求。</p> <p>如果最多抛出了3次 <code>SocketTimeoutExceptions</code> 异常，程序会继续执行后续的<code>onError</code> 来处理异常。</p> <pre> <code class="language-java">@Override public Observable<List<Comic>> getCharacterComics(int characterId) { final String comicsFormat = "comic"; final String comicsType = "comic"; return mMarvelApi.getCharacterComics( characterId, comicsFormat, comicsType) .retry((attemps, error) -> error instanceof SocketTimeoutException && attemps < MAX_ATTEMPS); }</code></pre> <p>一些参考资料</p> <ul> <li><a href="/misc/goto?guid=4958979542149358570" rel="nofollow,noindex">ReactiveX</a></li> <li><a href="/misc/goto?guid=4959630664342551849" rel="nofollow,noindex">Reactive Programming in the Netflix API with RxJava</a></li> <li><a href="/misc/goto?guid=4959671484699066028" rel="nofollow,noindex">Use Lambdas on Java 7 and older</a> – Esko Luontola</li> <li><a href="/misc/goto?guid=4959631833554996799" rel="nofollow,noindex">Grokking RxJava</a> , Part1: The basics – Dan Lew</li> </ul> <p>来源:<a href="http://www.devtf.cn/?p=770&utm_source=tuicool&utm_medium=referral">http://www.devtf.cn/?p=770</a> </p>