在 Android 中的拦截器中执行另一个 API 调用是否有问题？

Question

我在尝试刷新拦截器内的访问令牌时遇到问题。我已经读过对于这个问题最好使用身份验证器，但是我的 API 的工作方式是我收到一个未经授权的访问令牌的 403 错误（不是我的设计，但必须使用它）。

所以我试图调用 API 端点以在我的拦截器中获取一个新的访问令牌，但似乎第二个 API 调用在没有关闭它的情况下创建了一个 OKHTTP 响应。

override fun intercept(chain: Interceptor.Chain?): Response {

        var currentRequest = chain!!.request()
        val currentRequestResponse = chain.proceed( currentRequest )

        if ( currentRequestResponse.code() >= HTTP_ERROR_CODE && isNotLoginRequest( chain ) ) {

            try {

                // we check the response code, if there is 403 code we need to relog the user
                // before executing the request
                // try to reconnect the user with synchronous request


                val userManager = UserManager.getInstance()

                val clientId = getQueryParameter(UserService.CLIENT_ID_QUERY_KEY, currentRequest)
                val redirectUri = getQueryParameter(UserService.REDIRECT_URI_QUERY_KEY, currentRequest)
                val clientSecret = getQueryParameter(UserService.CLIENT_SECRET_QUERY_KEY, currentRequest)

                // we get a new access token with a synchronous request
                val accessToken = userManager.refreshToken(clientId, clientSecret, redirectUri)

                currentRequest = rebuildRequestWithNewToken( accessToken, currentRequest )

                return chain.proceed( currentRequest )

            } catch (e: Throwable) {

                e.printStackTrace()
            }
        }

        return currentRequestResponse
    }

我相信问题来自 userManager.refreshToken，它是获取新访问令牌的 API 调用。

这是我收到的错误：

java.lang.IllegalStateException：无法发出新请求，因为之前的响应仍然打开：请调用 response.close()

Answer 1

您可以像这样在网络拦截器内进行刷新令牌调用

if (response.code() == 403) {
            try {
                val body = RequestBody.create(contentType, "")

                val authRequest = request.newBuilder()
                        .setDefaultHeaders()
                        .addHeader("Authorization", "Your token")
                        .url(refreshtokenurl)
                        .post(body)
                        .build()
                val tokenRefreshResponse = chain.proceed(authRequest)
                if (tokenRefreshResponse.code() == 401 || tokenRefreshResponse.code() == 403) {
                   //error in refreshing token
                } else if (tokenRefreshResponse.code() == 200) {
                   //save the new token and refresh token in preference and continue with the earlier request
                    currentRequestResponse = chain.proceed(currentRequest.newBuilder()
                                .setDefaultHeaders()
                                .addHeader(your header)
                                .build())
                }
            } catch (e: Exception) {

            }

        }