RxLifecycle 源码解析:当 Activity 被 destory 时自动停掉网络请求

私以为,阅读开源项目是与世界级技术大牛直接对话的最好方式。
此次来分享下 RxLifecycle 源码的分析。

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

一、 介绍

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

二、 开源项目

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

基本用法如下:

myObservable
    .compose(RxLifecycle.bindUntilEvent(lifecycle, ActivityEvent.DESTROY))
    .subscribe();

此处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呢?看一眼源码:

/**
 * Represents an object that is both an Observable and an Observer.
 */
public abstract class Subject<T, R> extends Observable<R> implements Observer<T> {}

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

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

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

  PublishSubject<Object> subject = PublishSubject.create();
  // myObserver will receive "one" & "two" and onCompleted events
  subject.subscribe(myObserver);
  subject.onNext("one");
  subject.onNext("two");
  subject.onCompleted();

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

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

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

七、 BaseActivity监听生命周期

那么我们先来实现生命周期监听功能,基本思路是:在BaseActivity里创建一个PublishSubject对象,在每个生命周期发生时,把该生命周期事件传递给PublishSubject。具体实现如下(只写部分生命周期,其他类似):
```java
class BaseActivity {

protected final PublishSubject<ActivityLifeCycleEvent> lifecycleSubject = PublishSubject.create();

@Override
  protected void onCreate(Bundle savedInstanceState) {
      lifecycleSubject.onNext(ActivityLifeCycleEvent.CREATE);
      ...
  }

  @Override
  protected void onPause() {
      lifecycleSubject.onNext(ActivityLifeCycleEvent.PAUSE);
      ...
top Created with Sketch.