rx android vs mosby 模式加载数据 recyclerview

Question

我正在开发 Android 应用程序。我附加的代码正在创建一个回收视图。我们做的第一件事是创建一个异步任务，它将在 SQLite 数据库上获取数据并将其加载到适配器->recylcerview 中。当后台任务运行时，会向用户显示一个进度对话框。

public class HomeActivity extends AppCompatActivity
{
    private RecyclerView recycler;
    private RecyclerViewAdapter adapter;
    private SwipeRefreshLayout swipeRefresh;
    private progressDialog progressDialog;

     // ... some code here

 @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);

        // ... some code here


    createRecyclerView();
    loadRecyclerView();


    // ... some code here

    }


    private void loadRecyclerView()
    {
        new LoadingBackgroundTask().execute();
    }



    private void createRecyclerView()
{

    Context context = getApplicationContext();

    recycler = (RecyclerView) findViewById(R.id.recycle_view_home);
    recycler.setHasFixedSize(true);

    RecyclerView.LayoutManager lManager = new LinearLayoutManager(context);
    recycler.setLayoutManager(lManager);

    adapter = new RecyclerViewAdapter();

    recycler.setAdapter(adapter);
    recycler.setItemAnimator(new DefaultItemAnimator());

}

private class LoadingBackgroundTask extends AsyncTask<Void, Void, List<items>> {

    @Override
    protected void onPreExecute() {
        super.onPreExecute();
        progressDialog = ProgressDialog.show(HomeActivity.this, getString(R.string.dialog_load_list),getString(R.string.dialog_please_wait), false, false);

    }

    @Override
    protected List doInBackground(Void... params) {

        List<items> lists;
        //Data Source Class ( SQLite)
        ListDS listDS = new ListDS(getApplicationContext());
        list = listDS.getList();

        return list;
    }

    @Override
    protected void onPostExecute(List result) {
        super.onPostExecute(result);

        //it inserts de list on recyclerview performing animation
        adapter.animate(result);

        progressDialog.dissmiss();
        swipeRefresh.setRefreshing(false);
        recycler.scrollToPosition(0);
    }

}

}

到目前为止，还不错。但是，您可能知道这段代码有一些众所周知的问题；例如，如果我在 asynctask 发挥它的魔力时旋转屏幕，它会使应用程序崩溃。

我尝试了另一种我在谷歌上看到的替代方法，rxandroid。

（对不起，如果我打错了，我是靠记忆）

public class HomeActivity extends AppCompatActivity
{
 private Subscriber suscriptor;
private progressDialog progressDialog;

 //some code ....

  @Override
protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);

    suscriptor = new Subscriber() {
        @Override
        public void onCompleted() {
            progressDialog.dismiss();
            Log.d("SUSCRIPTOR","ON COMPLETE");
        }

        @Override
        public void onError(Throwable e) {
            Log.d("SUSCRIPTOR","ON ERROR");
        }

        @Override
        public void onNext(Object o) {
            adapter.animate((List<items>)o);

        }
    };


    Observable.create(
            new Observable.OnSubscribe<List<items>>() {
                @Override
                public void call(Subscriber<? super List<items>> sub) {
                progressDialog = ProgressDialog.show(HomeActivity.this,  getString(R.string.dialog_load_list),getString(R.string.dialog_please_wait), false, false);
                    List<items> lists;
                    //Data Source Class ( SQLite)
                    ListDS listDS = new ListDS(getApplicationContext());
                    list = listDS.getList();

                    sub.onNext(list);
                    sub.onCompleted();

                }

                @Override
                protected void finalize() throws Throwable {
                    super.finalize();
                    Log.d("OBSERAVBLE","FINALIZED");
                }
            })
    .observeOn(AndroidSchedulers.mainThread())
    .subscribeOn(Schedulers.newThread())
           .cache()
    .subscribe(suscriptor);

    }


@Override
public void onDestroy()
{
    if(suscriptor!=null)
    {
        if(!suscriptor.isUnsubscribed())
        {
            suscriptor.unsubscribe();
        }
    }

    super.onDestroy();
}

}

现在当我旋转屏幕时应用程序不再崩溃了。然而，observable 一直在后台工作，直到它完成，但是当我取消订阅以避免崩溃时，我没有正确收到结果。此外，即使 observable 像我提到的那样继续工作，进度条也会消失。

寻找解决方案，我发现有一个名为 "Ted Mosby" 的模式似乎可以解决我的问题。虽然它看起来很有希望，但我认为对于一些我觉得不值得的东西来说编码太多了，rxandroid 可能有一个解决方法。

所以，我的问题是，我怎样才能得到我想要的东西，而不会陷入对我的目的来说太大的体系结构编码混乱中？如果你们解决了这个问题，你能举个例子吗？你认为我错了，我应该实施 TedMosby 模式吗？

Answer 1

您的 Observable 应该自己处理取消订阅的事实。有两种机制：

检查 subscriber.isUnsubscribed。您可以在 "heavy" 步
增加退订回调。您可以使用它来停止长时间的运行操作、释放资源等

看看这段代码：

Observable.create(
        new Observable.OnSubscribe<List<items>>() {
            @Override
            public void call(Subscriber<? super List<items>> sub) {
                sub.add(Subscriptions.create(new Action0() {
                    @Override
                    public void call() {
                        cancelLongRunningOperationIfItStillRunning();
                    }
                }));
                if (!sub.isUnsubscribed()) {
                    //start long running operation here
               }
            }
        })
        .doOnSubscribe(new Action0() {
            @Override
            public void call() {
            }
        })

您不应该在 Observable 中引用您的 activity/context/progress 对话框等。如果您想产生一些副作用，请改用 doOnSubscribe。

Answer 2

Mosby 是一个 Model-View-Presenter (MVP) 库.所以你命名为 "ted mosby pattern" 的模式实际上是 MVP。

但你还没有理解什么是 MVP。这与保留异步运行任务无关，甚至认为这可以通过 Mosby 实现。 MVP 是关于关注点分离的。 View只是显示UI个元素，Presenter控制着View，即presenter告诉view：现在显示进度对话框，现在隐藏进度对话框等。换句话说，presenter控制视图的状态. Model 可以是异步任务或 RxJava Observable。然后 Presenter 取回结果并告诉视图显示它。您的代码被解耦为 3 层模型（也称为业务逻辑）以及 Presenter 和 View。优点是您可以更改视图（即用进度条小部件替换进度对话框）而无需触及任何加载数据的代码（Presenter 和业务逻辑）。此外，通过 MVP，您的代码变得可测试。

所以你应该比较的是：我应该使用 AsyncTask 还是 RxJava 来加载数据。使用 Mosby，您可以在演示器中执行您的 http 请求。完成方向更改后，演示者不会被破坏（因此后台任务不会被取消）。

但是，MVP 并不是万能的解决方案。如果您必须确保正确执行单个 http 调用（即注册社区），您应该考虑使用 android 服务。

Answer 3

你可以做的就是在 activity 中所做的任何事情，比如你的 AsycTask 和 RecyclerView，把它放在一个片段中，然后 setRetainInstance(true) 在 onCreateView() 片段的方法并将该片段加载到您的 activity.

setRetainInstance(true) 不会让您的片段实例在屏幕旋转时销毁。

rx android vs mosby 模式加载数据 recyclerview

rx android vs mosby pattern load data recyclerview

android

design-patterns

android-asynctask

rx-android

android-recyclerview