Может модернизировать с OKHttp использовать данные кэша, когда в автономном режиме

148

Я пытаюсь использовать Retrofit & OKHttp для кэширования HTTP-ответов. Я следовал этой сути и, в конечном итоге, с этим кодом:

File httpCacheDirectory = new File(context.getCacheDir(), "responses");

HttpResponseCache httpResponseCache = null;
try {
     httpResponseCache = new HttpResponseCache(httpCacheDirectory, 10 * 1024 * 1024);
} catch (IOException e) {
     Log.e("Retrofit", "Could not create http cache", e);
}

OkHttpClient okHttpClient = new OkHttpClient();
okHttpClient.setResponseCache(httpResponseCache);

api = new RestAdapter.Builder()
          .setEndpoint(API_URL)
          .setLogLevel(RestAdapter.LogLevel.FULL)
          .setClient(new OkClient(okHttpClient))
          .build()
          .create(MyApi.class);

И это MyApi с заголовками Cache-Control

public interface MyApi {
   @Headers("Cache-Control: public, max-age=640000, s-maxage=640000 , max-stale=2419200")
   @GET("/api/v1/person/1/")
   void requestPerson(
           Callback<Person> callback
   );

Сначала я запрашиваю онлайн и проверяю файлы кеша. Правильный ответ JSON и заголовки там. Но когда я пытаюсь запросить в автономном режиме, я всегда получаю RetrofitError UnknownHostException. Что еще я должен сделать, чтобы Retrofit прочитал ответ из кеша?

РЕДАКТИРОВАТЬ: Так как OKHttp 2.0.x HttpResponseCacheесть Cache, setResponseCacheестьsetCache

OSRL
источник
1
Отвечает ли вызываемый вами сервер с соответствующим заголовком Cache-Control?
Хасан Ибрагим
это возвращает это, Cache-Control: s-maxage=1209600, max-age=1209600я не знаю, достаточно ли этого.
Osrl
Похоже, что publicключевое слово нужно было в заголовке ответа, чтобы оно работало в автономном режиме. Но эти заголовки не позволяют OkClient использовать сеть, когда она доступна. Есть ли способ установить политику / стратегию кэширования для использования сети, когда она доступна?
Osrl
Я не уверен, что вы можете сделать это в том же запросе. Вы можете проверить соответствующий класс CacheControl и заголовки Cache-Control . Если такого поведения нет, я бы, вероятно, выбрал два запроса: только кэшированный (только если кэшированный), а затем сетевой (max-age = 0).
Хасан Ибрагим,
это было первое, что пришло мне в голову. Я провел дни в этих классах CacheControl и CacheStrategy . Но идея двух запросов не имела особого смысла. Если max-stale + max-ageпропущен, он делает запрос из сети. Но я хочу установить max-stale неделю. Это делает чтение ответа из кэша, даже если сеть доступна.
Osrl

Ответы:

189

Изменить для Retrofit 2.x:

OkHttp Interceptor - это правильный способ доступа к кешу в автономном режиме:

1) Создать перехватчик:

private static final Interceptor REWRITE_CACHE_CONTROL_INTERCEPTOR = new Interceptor() {
    @Override public Response intercept(Chain chain) throws IOException {
        Response originalResponse = chain.proceed(chain.request());
        if (Utils.isNetworkAvailable(context)) {
            int maxAge = 60; // read from cache for 1 minute
            return originalResponse.newBuilder()
                    .header("Cache-Control", "public, max-age=" + maxAge)
                    .build();
        } else {
            int maxStale = 60 * 60 * 24 * 28; // tolerate 4-weeks stale
            return originalResponse.newBuilder()
                    .header("Cache-Control", "public, only-if-cached, max-stale=" + maxStale)
                    .build();
        }
    }

2) Настройка клиента:

OkHttpClient client = new OkHttpClient();
client.networkInterceptors().add(REWRITE_CACHE_CONTROL_INTERCEPTOR);

//setup cache
File httpCacheDirectory = new File(context.getCacheDir(), "responses");
int cacheSize = 10 * 1024 * 1024; // 10 MiB
Cache cache = new Cache(httpCacheDirectory, cacheSize);

//add cache to the client
client.setCache(cache);

3) Добавить клиента для модернизации

Retrofit retrofit = new Retrofit.Builder()
        .baseUrl(BASE_URL)
        .client(client)
        .addConverterFactory(GsonConverterFactory.create())
        .build();

Также проверьте @kosiara - Бартош Kosarzycki «s ответ . Возможно, вам придется удалить заголовок из ответа.


OKHttp 2.0.x (проверьте оригинальный ответ):

Так как OKHttp 2.0.x HttpResponseCacheесть Cache, setResponseCacheесть setCache. Так что вам должно setCacheпонравиться это:

        File httpCacheDirectory = new File(context.getCacheDir(), "responses");

        Cache cache = null;
        try {
            cache = new Cache(httpCacheDirectory, 10 * 1024 * 1024);
        } catch (IOException e) {
            Log.e("OKHttp", "Could not create http cache", e);
        }

        OkHttpClient okHttpClient = new OkHttpClient();
        if (cache != null) {
            okHttpClient.setCache(cache);
        }
        String hostURL = context.getString(R.string.host_url);

        api = new RestAdapter.Builder()
                .setEndpoint(hostURL)
                .setClient(new OkClient(okHttpClient))
                .setRequestInterceptor(/*rest of the answer here */)
                .build()
                .create(MyApi.class);

Оригинальный ответ:

Оказывается, ответ сервера должен быть Cache-Control: publicсделан OkClientдля чтения из кеша.

Кроме того, если вы хотите запросить из сети, когда доступно, вы должны добавить Cache-Control: max-age=0заголовок запроса. Этот ответ показывает, как это сделать параметризованным. Вот как я это использовал:

RestAdapter.Builder builder= new RestAdapter.Builder()
   .setRequestInterceptor(new RequestInterceptor() {
        @Override
        public void intercept(RequestFacade request) {
            request.addHeader("Accept", "application/json;versions=1");
            if (MyApplicationUtils.isNetworkAvailable(context)) {
                int maxAge = 60; // read from cache for 1 minute
                request.addHeader("Cache-Control", "public, max-age=" + maxAge);
            } else {
                int maxStale = 60 * 60 * 24 * 28; // tolerate 4-weeks stale
                request.addHeader("Cache-Control", 
                    "public, only-if-cached, max-stale=" + maxStale);
            }
        }
});
OSRL
источник
(Мне было интересно, почему это не сработало; оказалось, что я забыл установить фактический кеш для использования OkHttpClient. См. Код в вопросе или в этом ответе .)
Jonik
2
Просто слово совета HttpResponseCache has been renamed to Cache.** Install it with OkHttpClient.setCache(...) instead of OkHttpClient.setResponseCache(...).
Энрике де Соуза
2
Я не получаю вызов перехватчика, когда сеть недоступна. Я не уверен, как может ударить условие, когда сеть недоступна. Я что-то здесь упускаю?
Androidme
2
это if (Utils.isNetworkAvailable(context))правильно или это должно быть наоборот то есть if (!Utils.isNetworkAvailable(context))?
Эрик
2
Я использую Retrofit 2.1.0, и когда телефон находится в автономном режиме, public okhttp3.Response intercept(Chain chain) throws IOExceptionникогда не вызывается, он вызывается только тогда, когда я в сети
ericn
28

Все вышеописанные у меня не сработали. Я пытался реализовать автономный кеш в модификации 2.0.0-бета2 . Я добавил перехватчик, используя okHttpClient.networkInterceptors()метод, но получил, java.net.UnknownHostExceptionкогда я пытался использовать кэш в автономном режиме. Оказалось, что я должен был добавить okHttpClient.interceptors()также.

Проблема заключалась в том, что кэш не был записан во флэш-память, потому что сервер вернулся, Pragma:no-cacheчто не позволяет OkHttp хранить ответ. Автономный кеш не работал даже после изменения значений заголовка запроса. После некоторых проб и ошибок я заставил кеш работать без изменения серверной части, удалив прагму из ответа вместо запроса -response.newBuilder().removeHeader("Pragma");

Дооснащение: 2.0.0-бета2 ; OkHttp: 2.5.0

OkHttpClient okHttpClient = createCachedClient(context);
Retrofit retrofit = new Retrofit.Builder()
        .client(okHttpClient)
        .baseUrl(API_URL)
        .addConverterFactory(GsonConverterFactory.create())
        .build();
service = retrofit.create(RestDataResource.class);

...

private OkHttpClient createCachedClient(final Context context) {
    File httpCacheDirectory = new File(context.getCacheDir(), "cache_file");

    Cache cache = new Cache(httpCacheDirectory, 20 * 1024 * 1024);
    OkHttpClient okHttpClient = new OkHttpClient();
    okHttpClient.setCache(cache);
    okHttpClient.interceptors().add(
            new Interceptor() {
                @Override
                public Response intercept(Chain chain) throws IOException {
                    Request originalRequest = chain.request();
                    String cacheHeaderValue = isOnline(context) 
                        ? "public, max-age=2419200" 
                        : "public, only-if-cached, max-stale=2419200" ;
                    Request request = originalRequest.newBuilder().build();
                    Response response = chain.proceed(request);
                    return response.newBuilder()
                        .removeHeader("Pragma")
                        .removeHeader("Cache-Control")
                        .header("Cache-Control", cacheHeaderValue)
                        .build();
                }
            }
    );
    okHttpClient.networkInterceptors().add(
            new Interceptor() {
                @Override
                public Response intercept(Chain chain) throws IOException {
                    Request originalRequest = chain.request();
                    String cacheHeaderValue = isOnline(context) 
                        ? "public, max-age=2419200" 
                        : "public, only-if-cached, max-stale=2419200" ;
                    Request request = originalRequest.newBuilder().build();
                    Response response = chain.proceed(request);
                    return response.newBuilder()
                        .removeHeader("Pragma")
                        .removeHeader("Cache-Control")
                        .header("Cache-Control", cacheHeaderValue)
                        .build();
                }
            }
    );
    return okHttpClient;
}

...

public interface RestDataResource {

    @GET("rest-data") 
    Call<List<RestItem>> getRestData();

}
Косиара - Бартош Косаржицкий
источник
6
Похоже, ваши interceptors ()и networkInterceptors ()идентичны. Почему ты продублировал это?
toobsco42
различные типы перехватчиков читайте здесь. github.com/square/okhttp/wiki/Interceptors
Рохит Бандил
да, но они оба делают одно и то же, поэтому я уверен, что одного перехватчика должно быть достаточно, верно?
Овидиу Латку
Есть ли конкретная причина не использовать один и тот же экземпляр перехватчика для обоих .networkInterceptors().add()и interceptors().add()?
ccpizza
22

Мое решение:

private BackendService() {

    httpCacheDirectory = new File(context.getCacheDir(),  "responses");
    int cacheSize = 10 * 1024 * 1024; // 10 MiB
    Cache cache = new Cache(httpCacheDirectory, cacheSize);

    httpClient = new OkHttpClient.Builder()
            .addNetworkInterceptor(REWRITE_RESPONSE_INTERCEPTOR)
            .addInterceptor(OFFLINE_INTERCEPTOR)
            .cache(cache)
            .build();

    Retrofit retrofit = new Retrofit.Builder()
            .baseUrl("https://api.backend.com")
            .client(httpClient)
            .addConverterFactory(GsonConverterFactory.create())
            .build();

    backendApi = retrofit.create(BackendApi.class);
}

private static final Interceptor REWRITE_RESPONSE_INTERCEPTOR = chain -> {
    Response originalResponse = chain.proceed(chain.request());
    String cacheControl = originalResponse.header("Cache-Control");

    if (cacheControl == null || cacheControl.contains("no-store") || cacheControl.contains("no-cache") ||
            cacheControl.contains("must-revalidate") || cacheControl.contains("max-age=0")) {
        return originalResponse.newBuilder()
                .header("Cache-Control", "public, max-age=" + 10)
                .build();
    } else {
        return originalResponse;
    }
};

private static final Interceptor OFFLINE_INTERCEPTOR = chain -> {
    Request request = chain.request();

    if (!isOnline()) {
        Log.d(TAG, "rewriting request");

        int maxStale = 60 * 60 * 24 * 28; // tolerate 4-weeks stale
        request = request.newBuilder()
                .header("Cache-Control", "public, only-if-cached, max-stale=" + maxStale)
                .build();
    }

    return chain.proceed(request);
};

public static boolean isOnline() {
    ConnectivityManager cm = (ConnectivityManager) MyApplication.getApplication().getSystemService(Context.CONNECTIVITY_SERVICE);
    NetworkInfo netInfo = cm.getActiveNetworkInfo();
    return netInfo != null && netInfo.isConnectedOrConnecting();
}
Аркадиуш Конор
источник
3
не работает для меня ... Получение 504 неудовлетворительного запроса (только если кешируется)
zacharia
Только ваше решение помогает мне, большое спасибо. Потратьте 2 дня, чтобы прокрутить вниз
Ярослав Мовчан
1
да, единственное рабочее решение в моем случае. (Дооснащение 1.9.x + okHttp3)
Хоанг Нгуен Хуу
1
Работает с Retrofit RETROFIT_VERSION = 2.2.0 OKHTTP_VERSION = 3.6.0
Тадас Валайтис
Как добавить builder.addheader () в этот метод для доступа к API с авторизацией?
Абхилаш,
6

Ответ ДА. На основании приведенных выше ответов я начал писать модульные тесты для проверки всех возможных вариантов использования:

  • Использовать кеш в автономном режиме
  • Сначала используйте кэшированный ответ до истечения срока действия, затем сеть
  • Сначала используйте сеть, затем кеш для некоторых запросов
  • Не хранить в кеше некоторые ответы

Я создал небольшую вспомогательную библиотеку для легкой настройки кэша OKHttp. Вы можете увидеть соответствующий юнит-тест здесь на Github: https://github.com/ncornette/OkCacheControl/blob/master/okcache-control/src/test/java/com/ ncornette / кэш / OkCacheControlTest.java

Unittest, который демонстрирует использование кэша в автономном режиме:

@Test
public void test_USE_CACHE_WHEN_OFFLINE() throws Exception {
    //given
    givenResponseInCache("Expired Response in cache", -5, MINUTES);
    given(networkMonitor.isOnline()).willReturn(false);

    //when
    //This response is only used to not block when test fails
    mockWebServer.enqueue(new MockResponse().setResponseCode(404));
    Response response = getResponse();

    //then
    then(response.body().string()).isEqualTo("Expired Response in cache");
    then(cache.hitCount()).isEqualTo(1);
}

Как видите, кеш можно использовать, даже если срок его действия истек. Надеюсь, это поможет.

Николас Корнетт
источник
2
Ваша библиотека великолепна! Спасибо за вашу усердную работу. The lib: github.com/ncornette/OkCacheControl
Хоанг Нгуен Хуу
5

опираясь на @ kosiara-Бартош-kasarzycki в ответ , я создал образец проекта , который должным образом грузы из Memory-> диск-> сеть с использованием модифицированной, okhttp, rxjava и гуавы. https://github.com/digitalbuddha/StoreDemo

FriendlyMikhail
источник
2

Кэш с Retrofit2 и OkHTTP3:

OkHttpClient client = new OkHttpClient
  .Builder()
  .cache(new Cache(App.sApp.getCacheDir(), 10 * 1024 * 1024)) // 10 MB
  .addInterceptor(new Interceptor() {
    @Override public Response intercept(Chain chain) throws IOException {
      Request request = chain.request();
      if (NetworkUtils.isNetworkAvailable()) {
        request = request.newBuilder().header("Cache-Control", "public, max-age=" + 60).build();
      } else {
        request = request.newBuilder().header("Cache-Control", "public, only-if-cached, max-stale=" + 60 * 60 * 24 * 7).build();
      }
      return chain.proceed(request);
    }
  })
  .build();

Статический метод NetworkUtils.isNetworkAvailable ():

public static boolean isNetworkAvailable(Context context) {
        ConnectivityManager cm =
                (ConnectivityManager) context.getSystemService(Context.CONNECTIVITY_SERVICE);
        NetworkInfo activeNetwork = cm.getActiveNetworkInfo();
        return activeNetwork != null &&
                activeNetwork.isConnectedOrConnecting();
    }

Затем просто добавьте клиента в модификатор сборки:

Retrofit retrofit = new Retrofit.Builder()
                    .baseUrl(BASE_URL)
                    .client(client)
                    .addConverterFactory(GsonConverterFactory.create())
                    .build();

Первоисточник: https://newfivefour.com/android-retrofit2-okhttp3-cache-network-request-offline.html

Владимир Широков
источник
1
при первой загрузке в автономном режиме происходит сбой! иначе это работает должным образом
Зафер Челалоглу
это не работает для меня. Я скопировал его и попробовал после того, как попытался интегрировать его принцип, но не заставляю его работать.
Мальчик
App.sApp.getCacheDir () что это делает?
Хузаифа Асиф