如何使用 RxJava/RxAndroid 从 Android 服务更新 UI

Question

我有一个绑定服务负责下载文件，因此它知道下载状态/进度。并且 UI（Fragment 或 Activity）必须显示/更新服务的下载进度。

其实我认为常用的方法是使用BroadcastReciever 或来自Activity 的CallBack。但我在某处听说过使用 RxJava（ReactiveX 编程）和 mediator 类（以及 Dagger 将其注入到服务和活动中），如下所述。

所以我的问题是如何用这些东西来处理 RxJava？任何代码示例？除了使用意图之外，还有其他有效的方法吗？

资源： More efficient way of updating UI from Service than intents?【看第一个答案更新】

Answer 1

RxJava/RxAndroid 需要

1) 可观察的 2) 观察者 3) 订阅

计划您需要放置 1、2、3、

的位置

OBSERVABLES去哪里创建数据，所以在你的情况下SERVICE

OBSERVERS去哪里需要使用（或显示）数据，这就是你的活动

SUBSCRIBE 去任何你可以访问 OBSERVABLE 和 OBSERVER 的地方，所以让我们使用 ACVITITY

程序和代码：

首先， 像这样准备您的 OBSERVABLE 服务

class MyService extends Service {
    static PublishSubject<String> data = PublishSubject.create();

   @Override
   public void onStarCommand(Intent intent,int i, int j){
        # DO THIS ANYWHER WHERE YOU GENERATE DATA 
        data.onNext("Hello");
   }

   public static Observable<String> getObservable(){
      return data;
   }
}

其次， 在 Activity 的 onCreate 中准备您的 OBSERVER（和 OBSERVABLE）

Observable<String> observable = MyService.getObservable();
Observer<String> observer = new Observer<String>() {
        @Override
        public void onCompleted() {
            Log.d(TAG, "onCompleted: ");
        }

        @Override
        public void onError(Throwable e) {
            Log.e(TAG, "onError: ",e);
        }

        @Override
        public void onNext(String text) {
            Log.d(TAG, "DATA reveived here: "+text);
        }
    };

最后 在Activity中同时链接OBSERVER和OBSERVABLE，否则Observable不会响应， 在 onCreate 中再次使用它

observable.subscribe(observer);

DONE，现在即使使用 onNext() 从 Service 触发数据，数据也会到达 Activity

Answer 2

当某些东西绑定到您的Service 时，您使用的Binder 子类可以公开一个方法，该方法返回一个发出进度数据的Observable。

使用这种方法需要注意的是，当Activity 实例不再有效时，您需要释放两个资源：服务连接和可观察订阅。