HTTP 504 Unsatisfiable Request (only-if-cached)

Question

Retrofit2.2.0 和 okhttp3.9.1 离线缓存不起作用，当我请求离线数据时会抛出异常，即 HTTP 504 Unsatisfiable Request (only-if-cached)。数据正在从互联网加载到设备中，但离线模式无法检索它。

示范：

以下代码描述了 API 接口。

public class TestApi {


    private static TestService testService;

    private static final String TEST_URL = "https://httpbin.org/";


    public static TestService getTestService() {

        if(testService == null) {
            synchronized (TestApi.class) {
                if(testService == null) {
                    testService = XApi.getInstance().getRetrofit(TEST_URL, true).create(TestService.class);
                }
            }
        }
        return testService;
    }

}

以下代码描述了 API 服务。

public interface TestService {

    @GET("/cache/60")
    Flowable<TestBean> getTestDate();

}

下面的代码描述了缓存控制拦截器。

public class CachingControlInterceptor {

    private static final int TIMEOUT_CONNECT = 60; //60 second
    private static final int TIMEOUT_DISCONNECT = 60 * 60 * 24 * 7; //7?

    public static final Interceptor REWRITE_RESPONSE_INTERCEPTOR = new Interceptor() {
        @Override
        public okhttp3.Response intercept(Chain chain) throws IOException {
            String cache = chain.request().header("cache");
            okhttp3.Response originalResponse = chain.proceed(chain.request());
            String cacheControl = originalResponse.header("Cache-Control");
            if (cacheControl == null) {
                if (cache == null || "".equals(cache)) {
                    cache = TIMEOUT_CONNECT + "";
                }
                originalResponse = originalResponse.newBuilder()
                    .removeHeader("Pragma")
                    .header("Cache-Control", "public, max-age=" + cache)
                    .build();
                return originalResponse;
            } else {
                return originalResponse;
            }
        }
    };

    public static final Interceptor REWRITE_RESPONSE_INTERCEPTOR_OFFLINE = new Interceptor() {
        @Override
        public okhttp3.Response intercept(Chain chain) throws IOException {
            Request request = chain.request();
            if (!NetworkUtils.isConnected()) {
                request = request.newBuilder()
                    .removeHeader("Pragma")
                    .header("Cache-Control", "public, only-if-cached, max-stale="+TIMEOUT_DISCONNECT)
                    .build();
            }
            return chain.proceed(request);
        }
    };

}

最后，给 OkHttpClient.Builder 添加一个拦截器

Retrofit.Builder builder = new Retrofit.Builder()
    .baseUrl(baseUrl)
    .client(getClient(baseUrl, provider))
    .addConverterFactory(GsonConverterFactory.create());

builder.addNetworkInterceptor(CachingControlInterceptor.REWRITE_RESPONSE_INTERCEPTOR);
builder.addInterceptor(CachingControlInterceptor.REWRITE_RESPONSE_INTERCEPTOR_OFFLINE);

我不知道如何解决它。

希望任何人都可以帮助我！

Answer 1

我仍然不太明白你到底想做什么，但是从一个更简单的可执行示例开始，以下有什么问题吗？

package com.baulsupp.oksocial;

import okhttp3.*;
import retrofit2.Call;
import retrofit2.Retrofit;
import retrofit2.converter.scalars.ScalarsConverterFactory;
import retrofit2.http.GET;

import java.io.File;
import java.io.IOException;

public class TestRequest {
    private static boolean connected = true;

    public interface TestService {
        @GET("/cache/60")
        Call<String> getTestDate();
    }

    public static final Interceptor REWRITE_RESPONSE_INTERCEPTOR_OFFLINE = new Interceptor() {
        @Override
        public okhttp3.Response intercept(Chain chain) throws IOException {
            Request request = chain.request();
            if (isConnected()) {
                request = request.newBuilder().cacheControl(CacheControl.FORCE_NETWORK).build();
            } else {
                request = request.newBuilder().cacheControl(CacheControl.FORCE_CACHE).build();
            }
            Response response = chain.proceed(request);

            System.out.println("network: " + response.networkResponse());
            System.out.println("cache: " + response.cacheResponse());

            return response;
        }
    };

    private static boolean isConnected() {
        return connected;
    }

    public static void main(String[] args) throws IOException {

        OkHttpClient.Builder clientBuilder =
                new OkHttpClient.Builder().cache(new Cache(new File("/tmp/http"), 10 * 1024 * 1024));

        clientBuilder.addInterceptor(REWRITE_RESPONSE_INTERCEPTOR_OFFLINE);

        Retrofit builder = new Retrofit.Builder()
                .addConverterFactory(ScalarsConverterFactory.create())
                .baseUrl("https://httpbin.org/")
                .client(clientBuilder.build())
                .build();

        TestService service = builder.create(TestService.class);

        connected = true;

        String online = service.getTestDate().execute().body();
        System.out.println(online);

        connected = false;

        String offline = service.getTestDate().execute().body();
        System.out.println(offline);
    }
}

输出

network: Response{protocol=http/1.1, code=200, message=OK, url=https://httpbin.org/cache/60}
cache: null
{
  "args": {}, 
  "headers": {
    "Accept-Encoding": "gzip", 
    "Cache-Control": "no-cache", 
    "Connection": "close", 
    "Host": "httpbin.org", 
    "User-Agent": "okhttp/3.9.1"
  }, 
  "origin": "82.5.95.16", 
  "url": "https://httpbin.org/cache/60"
}

network: null
cache: Response{protocol=http/1.1, code=200, message=OK, url=https://httpbin.org/cache/60}
{
  "args": {}, 
  "headers": {
    "Accept-Encoding": "gzip", 
    "Cache-Control": "no-cache", 
    "Connection": "close", 
    "Host": "httpbin.org", 
    "User-Agent": "okhttp/3.9.1"
  }, 
  "origin": "82.5.95.16", 
  "url": "https://httpbin.org/cache/60"
}