RxJava：同时发送多个请求时如何刷新令牌？

Question

我有一个使用 OAuth2 进行身份验证并使用 Retrofit 从 RESTful 服务获取数据的应用程序。现在，我有令牌检索和刷新运行。令牌像这样刷新（省略调度程序）：

// Each Retrofit call observable is "wrapper" using this method
protected <T> Observable<T> wrap(@NonNull final Observable<T> page) {
    return authenticate()
        .concatMap(token -> page)
        .onErrorResumeNext(throwable -> {
            Log.w(TAG, "wrap: ErrorResumeNext", throwable);
            return refreshAccessToken()
                .flatMap(accessToken -> page);
        }));
}

// Retrieves the access token if necessary
Observable<AccessToken> authenticate() {
    // Already have token
    if(accessToken != null) return Observable.just(accessToken);
    // No token yet, fetch it
    return api.getAccessToken(...);
}

// Refreshes the token
Observable<AccessToken> refreshAccessToken() {
    return api.refreshToken(...);
}

这可行，但在某些情况下，一次发送多个请求并且它们都调用刷新过程 - 基本上我的应用最终刷新令牌的次数与当前请求的次数一样多。

那么，问题来了：如何保证在需要刷新token的时候，无论有多少正在进行的请求都需要刷新token，只刷新一次？我能否以某种方式发出其他请求 "wait" 直到第一个请求成功调用并检索到新令牌？

Answer 1

我们使用热可观察对象刷新令牌并为所有未通过身份验证的请求提供对其实例的访问来完成此行为。

使用 share 运算符将用于刷新令牌的基本冷可观察对象转变为热可观察对象，以便所有其他订阅者共享其结果。一旦请求返回，所有等待的观察者都会收到通知，并且在那一刻（在操作员链中，它恰好在 share() 之前进入 doOnUnsubscribe 的回调）销毁刷新的可观察实例，以便下一个订阅者将创建新的一个。所有这一切都可以通过单例模式轻松实现，您可以将刷新的可观察对象包装到单例包装器 class 中，然后通过 getInstance() 请求它。如果没有正在进行的请求——实例为空——getInstance 应该创建一个新的。

您还需要注意一些其他事项，例如刷新过程中的错误和使令牌全部无效，但这些是基础知识。

我现在没有太多时间对此进行详细说明，但如果您在自己实施时遇到一些问题，请发表评论，明天我将 post 一些代码示例。如果没有上下文，它们就没有多大意义。

RxJava：同时发送多个请求时如何刷新令牌？

RxJava: How to refresh a token when multiple requests are sent at the same time?

android

oauth-2.0

rx-java

retrofit2

refresh-token