RxJava - 如何在取消订阅 observable 后继续后台任务

Question

我是 RxJava 新手。我有一个 bitmapObservable 用于下载图像 url 列表并将其转换为位图的简单网络操作。

mSubscription = Observable.create(new Observable.OnSubscribe<Bitmap[]>() {
        @Override
        public void call(final Subscriber<? super Bitmap[]> subscriber) {
            String[] urls = new String[]{
                    "http://www.convertimage.net/frontframe/images/cute_ball_info.png",
                    "http://customerserviceai.com/wp-content/uploads/2016/08/waiting.png",
                    "https://images.google.com/images/branding/googleg/1x/googleg_standard_color_128dp.png"};
            Bitmap[] bitmaps = new Bitmap[urls.length];
            int i = 0;
            for (String url : urls) {
                final Bitmap bitmap = Downloader.getBitmapFromURL(url);
                if (bitmap == null) {
                    subscriber.onError(new IOException());
                } else {
                    bitmaps[i++] = bitmap;
                    Log.d(TAG, "Bitmap " + url + " downloaded" + bitmap);
                }
            }
            subscriber.onNext(bitmaps);
            subscriber.onCompleted();
        }
    }).subscribeOn(Schedulers.newThread())
            .observeOn(AndroidSchedulers.mainThread()).subscribe(new Subscriber<Bitmap[]>() {
                @Override
                public void onCompleted() {
                    Log.d(TAG, "Everything completed");
                }

                @Override
                public void onError(Throwable e) {
                    Log.d(TAG, "Some error has been occured");
                }

                @Override
                public void onNext(Bitmap[] bitmaps) {
                    Log.d(TAG, "Downloaded bitmaps " + bitmaps);
                }
            });

在活动的onDestroy 上，我取消订阅 observable 以避免内存泄漏。

  @Override
protected void onDestroy() {
    mSubscription.unsubscribe();
    super.onDestroy();
}

我可以看到，如果我在图像下载过程中退出活动，后台任务也会被杀死。我只想继续背景任务，即使我已经取消了观察者的订阅。是否可以？

Answer 1

这不是一个真正的 RxJava 问题。在 Android 中，如果您希望后台任务即使在 Activity 死亡后仍然存在，您可以使用 Service。有两种服务，后台服务和前台服务。

但后台服务还不够，Android 不保证您的应用在后台运行时不会被杀死。 Ian Lake 在his blog post 中很好地解释了它。

因此，为了确保您的应用继续下载，您可以使用前台服务。这种模式通常用于音乐播放器应用，即使在用户锁定屏幕后，您仍然可以在后台听到音乐，因为应用仍在后台运行。

但是，如果您仍然想使用 RxJava 来解决您的问题，您可以使用 Subject。将您的下载进度保存在 Subject 上，当您想继续下载时，只需再次发出您的 Observable。