Android RXJava2 内存性能

Question

我创建了一个 Observable(RxJava2 + Volley)，每 5 秒重复一次，
它可以工作，但是当我 Dump Java Heap(memory) 时，我的 Model JAVA 类的实例有很多，并且每次 Observable 重复时它都会增加。 为什么 RX 创建我的模型的多个实例？我怎样才能只使用它的一个实例？

型号

public RequestFuture<String> getLiveRefreshFuture() {
        RequestFuture<String> future = RequestFuture.newFuture();
        VolleyStringRequest request = new VolleyStringRequest(Request.Method.POST
                , REFRESH_URL
                , future
                , future) {
            @Override
            protected Map<String, String> getParams() throws AuthFailureError {
                return getRefreshParams();
            }
        };

        VolleySingleton.getInstance().addToRequestQueue(request);
        return future;
    }    

---

活动

    private final CompositeDisposable disposables = new CompositeDisposable();

final LiveRemoteModel model = DaggerLiveComponent.builder().build().getModel();

        Observable<LiveResponse> observable = Observable
                .interval(Constants.TOOLBAR_BADGES_REFRESH_DELAY, TimeUnit.SECONDS)
                .subscribeOn(Schedulers.io())
                .map(dummy -> model.getLiveRefreshFuture())
                .map(RequestFuture::get)
                .map(LiveResponse::new)
                .observeOn(AndroidSchedulers.mainThread());

        DisposableObserver<LiveResponse> disposableObserver =
                new DisposableObserver<LiveResponse>() {
                    @Override
                    public void onNext(@NonNull LiveResponse liveResponse) {
                        setToolbarBadges(liveResponse.getToolbarBadges());
                    }

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

                    @Override
                    public void onComplete() {
                        Log.d("RX", "onComplete: ");
                    }
                };

        disposables.add(observable.subscribeWith(disposableObserver));    

Answer 1

为什么 RX 会为我的模型创建多个实例？我怎样才能只使用它的一个实例？

如果你仔细看堆转储中的对象是LiveRemoteModel$2，这表明它是LiveRemoteModel中的一个匿名类。

查看您的代码，这可能是每次调用 model.getLiveRefreshFuture() 时创建的 VolleyStringRequest 对象。在 RX 管道中没有保留该对象，因此 Volley 中必须有某些东西保留它。