Android/RxJava 如何链接网络请求并在失败时重试答案

【问题标题】：Android/RxJava How to chain network requests and retry when it failsAndroid/RxJava 如何链接网络请求并在失败时重试
【发布时间】：2016-05-25 20:36:09
【问题描述】：

我正在尝试在 Android 中使用 RxJava 链接网络请求，然后在失败时重试。我一直在研究 StackOverflow 如何做到这一点，而不会陷入单独使用 vanilla Android 和 Retrofit 带来的回调地狱。我可以在一个过程中完成这一切，在这样的异步任务中（以下是我需要执行的步骤）登录。

使用用户名/密码登录用户
如果响应成功则请求 SSO 令牌
使用该 sso 令牌调用启动服务

我一直在 AsyncTask 中执行此操作，它仅在登录时有效。但是，SSO 令牌在应用程序正在使用时会过期，所以我每次看到它过期时都需要发出请求。

AsyncTask 的代码如下所示：

private class LoginUserTask extends AsyncTask<Void, Void, Void> {
    private final String LOG_TAG = LoginUserTask.class.getSimpleName();

    @Override
    protected Void doInBackground(Void... params) {
        OkHttpClient httpClient = ((TribeSocial) getApplication()).getHttpClient();

        // Login User
        GroupDockService groupDockLoginService =
                GroupDockServiceGenerator
                        .createService(GroupDockService.class,
                                httpClient, GroupDockUser.class, new GroupDockUserDeserializer());
        GroupDockUser groupDockUser = groupDockLoginService.loginUser("Tribe", username, password);
        Utility.saveAccountSubdomain(mContext, groupDockUser.getGroupDockSubdomain().getSubdomain());

        // Get Sso Token
        GroupDockService groupDockService = GroupDockServiceGenerator
                .createService(GroupDockService.class, httpClient);
        GroupDockSsoResponse ssoResponse =
                groupDockService.getSsoToken(Utility.getAccountSubdomain(mContext), true);
        Utility.saveSsoToken(mContext, ssoResponse.getSsoToken());

        // Sign in user into Tribe service
        TribeSocialService tribeSocialLaunchService =
                TribeServiceGenerator.createService(TribeSocialService.class,
                        httpClient, new LenientGsonConverter(new Gson()));
        tribeSocialLaunchService.launch(Utility.getSsoToken(mContext));

        // Get User id and save it to SharedPreferences
        TribeSocialService tribeSocialWhoAmIService =
                TribeServiceGenerator.createService(TribeSocialService.class, httpClient,
                        User.class, new WhoAmIDeserializer());
        User tribeUser = tribeSocialWhoAmIService.whoami();
        Utility.saveUserId(mContext, tribeUser.getId());

        return null;
    }

    @Override
    protected void onPostExecute(Void v) {
        Utility.launchMainActivity(mContext);
    }
}

我尝试使用 RxJava 进行这项工作的尝试类似于

GroupDockService groupDockLoginService =
        GroupDockServiceGenerator
                .createService(GroupDockService.class,
                        mHttpClient, GroupDockUser.class, new GroupDockUserDeserializer());

groupDockLoginService
        .loginUserRx("Tribe", username, password)
        .subscribeOn(Schedulers.newThread())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(new Subscriber<GroupDockUser>() {
            @Override
            public void onCompleted() {

            }

            @Override
            public void onError(Throwable e) {
                Log.e(LOG_TAG, "I have errored out: " + e.getMessage());
                Toast.makeText(mContext,
                        getString(R.string.username_and_or_password_is_incorrect),
                        Toast.LENGTH_SHORT).show();
            }

            @Override
            public void onNext(GroupDockUser groupDockUser) {
                Utility.saveUsernamePassword(mContext, username, password);
                new LoginUserTask().execute();
            }
        });

在该代码中，我需要执行以下操作

loginUserRx 成功后，我需要将用户名和密码保存到 SavedPreferences 中
然后我需要发出网络请求以获取 sso 令牌
之后，我需要发出第三个也是最后一个网络请求才能启动。

现在的代码只需调用登录用户，一旦成功，就会启动异步任务。理想情况下，我想在一个请求中将所有请求链接在一起。我一直在尝试flatmap、map 等，但当我走出上面时，我不知道如何链接这些调用。

任何人都可以对此有所了解吗？谢谢。

【问题讨论】：

retry 怎么样？我看不到 map 或 flatmap 如何帮助你做你想做的事

标签： java android retrofit rx-android

【解决方案1】：

看看这个例子。希望，它会激励你。

service
        //do login
        .loginUser()
        //side effect: save into Shared Preference
        .doOnNext( )
        //get SSO
        .flatMap()
        //do any other side effects
        .doOnNext()
        //do final network request
        .flatMap()
        //in case of error retry after 5 seconds
        .retryWhen(observable -> Observable.timer(5, TimeUnit.SECONDS))
        .subscribeOn(Schedulers.computation())
        .observeOn(AndroidSchedulers.mainThread())
        //update you UI
        .subscribe();