带你学开源项目:RxLifecycle - 当Activity被destory时自动暂停网络请求

此文需要读者对RxJava有一定了解

一、 介绍

本文分析思路不是从源码里抽代码出来一步步跟踪,而是提出问题,一步步思考解决方法,从而学习到开源项目的思维精华,而不仅仅是了解该项目的具体实现。笔者认为这种方式更有利于读者提高自身思维方式和技术能力

二、 开源项目

RxLifecycle 地址:https://github.com/trello/RxLifecycle 。该项目是为了防止RxJavasubscription导致内存泄漏而诞生的,核心思想是通过监听ActivityFragment的生命周期,来自动断开subscription以防止内存泄漏。

基本用法如下:

此处myObservable可以看成一个耗时的网络请求,通过绑定到ActivityEvent.DESTROY,一旦Activity发生了DESTORY生命周期,数据就不会再流向subscriber,即不会对这些数据进行任何处理和UI绘制,从而提高安全性。

三、 问题

Android开发中常会有这样一个场景:

  1. 发送网络请求 -> 2. 服务器处理请求并返回数据 -> 3. client端接收数据,绘制UI。

在前两步一般都是不会出现问题的,但是在第三步,当数据返回给client端时,如果页面已经不在了,那么就无法去绘制UI,很有可能会导致意向不到的问题。因此,为了解决这个问题,一个好的思路就是当页面离开时,自动断开网络请求数据的处理过程,即数据返回后不再进行任何处理

四、 思考

要达到上面这样一个功能,我们可以思考,至少需要两部分:

  1. 随时监听Activity(Fragment)的生命周期并对外发射出去;
  2. 在我们的网络请求中,接收生命周期并进行判断,如果该生命周期是自己绑定的,如Destory,那么就断开数据向下传递的过程。

五、 分析

可以看到,首先有一个核心功能要实现:就是既能够监听Activity生命周期事件并对外发射,又能够接收每一个生命周期事件并作出判断。为了实现这个功能,可以联想到RxJava中的Subject,既能够发射数据,又能够接收数据。

六、 Subject介绍

了解Subject的读者可以跳过这部分。

如何理解Subject呢?

很容易,在RxJava里面,Observable是数据的发射者,它会对外发射数据,然后经过mapflatmap等等数据处理后,最终传递给Observer,这个数据接收者。因此,抛开中间数据处理不管,可以看出,Observable对外发射数据,是数据流的开端;Observer接收数据,是数据流的末端。

那么Subject呢?看一眼源码:

首先,它extends Observable<R>,说明Subject具备了对外发射数据的能力,即拥有了from()just()等等;另外,它又implements Observer<T>,说明又能够处理数据,具备onNext()onCompleted等等。

然后,Subject毕竟只是一个抽象类,那么我们要如何使用它呢?

这里介绍一种最简单的:PublishSubject:

这里做的事情很简单,先创建一个PublishSubject -> 绑定一个myObserver,此时subject扮演了Observable的角色,把数据发射给myObserver -> 然后subject处理接收了两个数据onetwo -> 最终这些数据都传递给了myObserver。所以,subject扮演的角色是:

数据onetwo => (Observer) subject (Observable) => myObserver

简单来说,我们把数据onetwo塞给subject,然后subject又发射给了myObserver

七、 BaseActivity监听生命周期

那么我们先来实现生命周期监听功能,基本思路是:在BaseActivity里创建一

PublishSubject对象,在每个生命周期发生时,把该生命周期事件传递给PublishSubject。具体实现如下(只写部分生命周期,其他类似):

这样的话,我们把所有生命周期事件都传给了lifecycleSubject了,或者说,lifecycleSubject已经接收到了并能够对外发射各种生命周期事件的能力了。

八、 改良每一个Observable,接收生命周期并自动断开自身

通常我们的一次网络请求长这样:

其中,networkObservable表示一个通用的网络请求,会接收网络数据并传递给Observer去绘制UI。

现在,我们希望这个networkObservable监听ActivityDESTORY事件,一旦发生了DESTORY就自动断开Observer,即使网络数据回来了也不再传递给Observer去绘制UI。即:

因此,我们需要实现

这个方法,那如何实现呢?

我们知道lifecycleSubject能够发射生命周期事件了,那么我们可以让networkObservable去检查lifecycleSubject发出的生命周期,如果和自己绑定的生命周期事件一样,那就自动停掉即可。

九、 改装networkObservable

对于networkObservable自动停掉,我们可以利用操作符

它的作用是监听otherObservable,一旦otherObservable对外发射了数据,就自动把networkObservable停掉;

otherObservable何时对外发射数据呢?当然是lifecycleSubject发射出的生命周期事件等于绑定的生命周期事件时,开始发射。

其中的关键是判断activityLifeCycleEvent.equals(bindEvent);,一旦条件满足,otherObservable就对外发射数据,然后networkObservable就立即自动停掉。

十、 合并 生命周期监听 与 networkObservable改良

  1. 在BaseActivity里添加lifecycleSubject,并把每一个生命周期事件按时传递给lifecycleSubject
  2. 在BaseActivity里添加一个bindUntilEvent方法:
  3. 在任意一个网络请求 networkObservable 处改良

注意:

  1. 文中提到的networkObservable是网络请求,但实际上这不限于网
    1. 络请求,任何耗时操作如文件io操作等都可以利用这个方法,来监听生命周期并自动暂停。
    2. 对于Fragment中的处理方法也是类似。

    谢谢!

如果你想要第一时间获取我的文章,欢迎关注公众号 CoolCoder,跟随我一起学习技术、感悟艺术、体会生活吧。如果你对开源项目分析感兴趣,欢迎加入我们的android-open-source-project-cracking

打赏支持我写出更多好文章,谢谢!

打赏作者

打赏支持我写出更多好文章,谢谢!

任选一种支付方式

1 2 收藏 评论

关于作者:wingjay

用艺术的眼光发现技术的美。专注于Android、服务器开发,热爱开源、写作、阅读。我在这写文章:http://wingjay.com我在这分享技术:http://weibo.com/u/1625892654我在这开源代码:https://github.com/wingjay我在这等待来信:yinji... 个人主页 · 我的文章 · 2 ·     

相关文章

可能感兴趣的话题



直接登录
跳到底部
返回顶部