使用 OkHttp 拦截器的 Http 请求不起作用

Question

我正在使用带有 OkHttp 拦截器的 Retrofit 来处理 API。 拦截器向每个请求添加 cookie 标头。 拦截器代码：

class AddCookiesInterceptor: Interceptor {

    @Inject
    lateinit var cookiesDao: CookiesDao

    init {
        App.getAppComponent().inject(this)
    }

    @SuppressLint("CheckResult")
    override fun intercept(chain: Interceptor.Chain): Response {
        val builder = chain.request().newBuilder()
        cookiesDao.getAll()
            .subscribeOn(Schedulers.io())
            .subscribe { cookies ->
            builder.addHeader("Cookie", "JWT=" + cookies.jwt)
        }
        return chain.proceed(builder.build())
    }
}

在调试时我看到，拦截器更新请求并添加带有值的 cookie 标头，但是当服务器到达请求时它返回错误（再次 400 http 代码身份验证）。 如果我像这样手动将标头添加到请求中

    @GET("/api.tree/get_element/")
    @Headers("Content-type: application/json", "X-requested-with: XMLHttpRequest", "Cookie: jwt_value")
    fun getElementId(): Maybe<ResponseBody>

Api 返回 200 个 http 代码，它可以工作。

Answer 1

您的代码无法正常工作，因为您正在异步添加标头，这是您的流程中发生的事情的“时间线”：

init builder -> 请求 cookie -> 继续链 -> 接收 cookies dao 回调 -> 将 header 添加到已经使用的 builder

您需要做的是同步检索 cookie，为此您可以使用 BlockingObseervable 并获得类似的东西。 使用同步函数不会造成任何问题，因为拦截器已经在后台线程上运行。

@SuppressLint("CheckResult")
override fun intercept(chain: Interceptor.Chain): Response {
    val builder = chain.request().newBuilder()
    val cookies = cookiesDao.getAll().toBlocking().first()
    builder.addHeader("Cookie", "JWT=" + cookies.jwt)
   
    return chain.proceed(builder.build())
}