Android中使用反应式编程RxJava

时间:2023-02-05 00:53:23

GitHut 地址: https://github.com/ReactiveX/RxAndroid

(1)RxJava简介:

RxJava 是一个在Java虚拟机上实现的响应式扩展库:提供了基于observable序列实现的异步调用及基于事件编程。

RxJava最核心的两个东西是Observables(被观察者,事件源)和Subscribers(观察者)。Observables发出一系列事件,Subscribers处理这些事件。

它扩展了观察者模式,支持数据、事件序列并允许你合并序列,无需关心底层的线程处理、同步、线程安全、并发数据结构和非阻塞I/O处理。

一个Observable可以发出零个或者多个事件,知道结束或者出错。每发出一个事件,就会调用它的Subscriber的onNext方法,最后调用Subscriber.onNext()或者Subscriber.onError()结束。

RxJava是由Netflix开发的反应式扩展(Reactive Extensions)的Java实现。Reactive Extensions是这样一个第三方库:它结合了可观察集合和LINQ式查询以达到异步和基于事件的编程效果

Netflix将这个库托管到了Github上,支持Java6以上的版本并且使它可以用于Android App开发。

它支持Java5及更高版本,并支持其他一些基于JVM的语言,如Groovy、Clojure和Scala。

我们假设你已经对RxJava有一些了解。如果没有的话,强烈建议先看看这两篇 文章和Netflix在Github Wiki上的前几页。

(2)观察者模式

  1. Observable和Subscriber可以做任何事情
Observable可以是一个数据库查询,Subscriber用来显示查询结果;Observable可以是屏幕上的点击事件,Subscriber用来响应点击事件;Observable可以是一个网络请求,Subscriber用来显示请求结果。

  2. Observable和Subscriber是独立于中间的变换过程的。
在Observable和Subscriber中间可以增减任何数量的map。整个系统是高度可组合的,操作数据是一个很简单的过程。

(3)实现内容

e.g.

Model类中name内容变化时,View(Activity)中Subscribers这个name的变化,同步更新Ui上的Name。
我想到的方式是
在Model中创建Obervable,在setName方法中,写入nameObservable.onNext(newName)这一行。

(ios开发有ReactiveCocoa这个框架,类似rxjava,可以监听成员变量值变化)

ReactiveCocoa是比RxJava更方便一些,RxJava一个比较好的解决这个问题的方法就是为view model创建一个compose subscription,可以参考这个项目 https://github.com/tehmou/rx-android-architecture

逐步学习:(著名全栈 @hi大头鬼hi 的blog)

深入浅出RxJava(一:基础篇)

深入浅出RxJava(二:操作符)

深入浅出RxJava三--响应式的好处

深入浅出RxJava四-在Android中使用响应式编程  (注意对持有的context导致的内存泄露

如何升级到RxAndroid 1.0

提到 RxJava ,就不能不提中国 RxJava 教父级人物,著名全栈 @hi大头鬼hi ,尤其是 Android 工程师,他翻译的教程帮助了太多太多人,他翻译的教程最大的特点就是精准,即使你字字斟酌,也很难找到缺点。国内很多人翻译或者写的 RxJava 都会先拿去给大头鬼帮忙审校才会发出去,你们说屌不屌?

说完大头鬼,接下来登场的就是 Flipoard 的扔物线了,著名的开源库 MaterialEditText 作者,还是著名的 codeKK 上 Dagger 源码解析作者。

听说他以后的教程都会发在代码家的匠心写作上,所以博客就不贴了,有兴趣的自己去搜一下就能找到。

接下来再推荐一位对岸的小伙伴 yongjhih ,同样是 RxJava 的*爱好者,虽然不如大头鬼和扔物线著名,不过教程和代码都是相当漂亮,他的 GitHub 上有很多关于 RxJava 的 Examples 。

接下来再推荐几个:

我平常看的内容大致就这么多了,其实上面那么多东西,要全都看过来基本不可能,而且只是看应该也只是然并卵,最最重要的还是要不断练习,得自己去写 Demo ,把自己能用 Handler ,AsyncTask ,BroadcastReceiver 等组件都用 RxJava 去实现一遍,这样会比单纯地看教程要有效的多。当然,还有更加重要的一点,要相信自己一定能学好。