Retrofit 2＆OKHttp 3のキャッシュレスポンスが私の場合では機能しません

Question

この質問の答えはCan Retrofit with OKHttp use cache data when offlineでしたが、このコードはキャッシュできないようです。私は何が間違っていますか？

は

long SIZE_OF_CACHE = 10 * 1024 * 1024; // 10 MB 
    Cache cache = new Cache(getDirectory(), SIZE_OF_CACHE); 
    if (cache == null) { 
     Toast.makeText(AppController.getInstance().getApplicationContext(), "could n0t set cache", Toast.LENGTH_SHORT).show(); 
    } 

    client = new OkHttpClient 
      .Builder() 
      .addNetworkInterceptor(REWRITE_CACHE_CONTROL_INTERCEPTOR) 
      .cache(cache) 
      .build(); 

は私のネットワークインターセプタを追加します。この私のokhttpクライアントは以下の通りです：

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 (isConnected()) { 
       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; // tolerate 1-day stale 
       return originalResponse.newBuilder() 
         .header("Cache-Control", "public, only-if-cached, max-stale=" + maxStale) 
         .build(); 
      } 
     } 
    }; 

アムは、このように改造する追加：

public static Retrofit getClient() { 
     createCacheForOkHTTP(); 
     if (retrofit == null) { 
      retrofit = new Retrofit.Builder() 
        .client(client) 
        .baseUrl(BASE_URL) 
        .addConverterFactory(GsonConverterFactory.create()) 
        .build(); 
     } 
     return retrofit; 
    } 

//私の活動に追加します：

ApiInterface apiService = 
       ApiClient.getClient().create(ApiInterface.class); 

     Call<MovieResponse> call = apiService.getPopularMoviesDetails(ApiKey, page); 
     call.enqueue(new Callback<MovieResponse>() { 
      @Override 
      public void onResponse(Call<MovieResponse> call, Response<MovieResponse> response) { 
       progressBar.setVisibility(View.GONE); 
       mErrorView.setVisibility(View.GONE); 
       if (response.isSuccessful()) { 
        movies = response.body().getResults(); 
        movieAdapter.setMovieList(movies); 
        mRecyclerView.setAdapter(movieAdapter); 
       } else { 
        Toast.makeText(getActivity(), "header" + response.headers() + "code" + response.code() + "errorbody" + response.errorBody() + "errorbody" + response.message(), Toast.LENGTH_SHORT).show(); 
       } 

      } 

      @Override 
      public void onFailure(Call<MovieResponse> call, Throwable t) { 
       progressBar.setVisibility(View.GONE); 
       // Log error here since request failed 
       Log.e(TAG, t.toString()); 
       mErrorView.setVisibility(View.VISIBLE); 

      } 
     }); 

//インターフェース

@GET("movie/popular") 
    Call<MovieResponse> getPopularMoviesDetails(@Query("api_key") String apiKey, @Query("page") int page); 

Answer 1

あなたはすでにこれを修正するかどうかわかりません。私は偉大な/短い解決策が助けてくれることを願った。

私はCacheControlInterceptorを作成します。これには24時間のキャッシュがあります。オフラインになっていて、応答時間が24時間未満であれば、キャッシュレスポンスが得られます。この方法では

public class CacheControlInterceptor implements Interceptor { 

    private static final String CACHE_CONTROL_HEADER = "Cache-Control"; 
    private static final String MAX_AGE_HEADER_VALUE = "public, max-age="; 
    private static final String MAX_STALE_HEADER_VALUE = "public, only-if-cached, max-stale="; 

    // Specifies the maximum amount of time a resource will be considered fresh. 
    private static final int MAX_AGE = 60; 

    // Indicates that the client is willing to accept a response that has exceeded its expiration time. 
    private static final int MAX_STALE = 60 * 60 * 24; // 24 hours cache. 

    @Override 
    public Response intercept(Chain chain) throws IOException { 

     Request request = chain.request(); 

     if (WatchItApplication.hasNetwork()) { 
      request = request.newBuilder() 
        .header(CACHE_CONTROL_HEADER, MAX_AGE_HEADER_VALUE + MAX_AGE).build(); 
     } else { 
      request = request.newBuilder() 
        .header(CACHE_CONTROL_HEADER, MAX_STALE_HEADER_VALUE + MAX_STALE).build(); 
     } 

     return chain.proceed(request); 
    } 
} 

私はOKHttpClienteを作成します。 CacheControlInterceptorとキャッシュを追加しています。

private OkHttpClient createDefaultOkHttpClient() { 
     HttpLoggingInterceptor interceptor = new HttpLoggingInterceptor(); 
     interceptor.setLevel(HttpLoggingInterceptor.Level.BASIC); 

     return new OkHttpClient.Builder() 
       .retryOnConnectionFailure(true) 
       .connectTimeout(TIMEOUT_MILLIS, TIMEOUT_UNIT) 
       .readTimeout(TIMEOUT_MILLIS, TIMEOUT_UNIT) 
       .writeTimeout(TIMEOUT_MILLIS, TIMEOUT_UNIT) 
       .addNetworkInterceptor(new HeaderInterceptor()) 
       .cache(new Cache(WatchItApplication.getInstance().getCacheDir(), 10 * 1024 * 1024)) 
       .addInterceptor(new CacheControlInterceptor()) 
       .addInterceptor(interceptor) 
       .build(); 
    } 

最後に改造：

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

それが動作するかどうか私に教えてください。

Answer 2

キャッシングを容易にするために、サーバーからの応答を書き換えないでください。サーバーの管理者に応答を提供するときにキャッシュヘッダーを含めるように依頼する方がよいでしょう。そうすれば、キャッシュはOkHttpだけでなく、すべてのクライアントで機能します。

あなたは大人で、サーバーチームとの会話を避けるために技術的なショートカットを取る権利があります。

まず、network interceptorとアプリケーションインターセプタの両方を使用するようにコードを変更する必要があります。なぜ2つ？さて、あなたがキャッシュにリクエストをしているとき、ネットワークインターセプタはまだ動いていません。また、キャッシュに応答を書き込むときには、アプリケーションインターセプタはまだ実行されていません。

アプリケーションインターセプタを使用すると、キャッシュを好むとき、これを含めるようにリクエストヘッダを書き換えるし、古くなったレスポンスを提供するためにキャッシュを許可する：

Cache-Control: only-if-cached, max-stale=86400 

あなたのネットワークインターセプタがこれを含めるように、サーバーのレスポンスヘッダを書き換えますすべての応答が24時間キャッシュされます。

Cache-Control: max-age=86400 

Answer 3

私は問題を解決できました。これはどのように行ったのですか。

private static OkHttpClient getCacheClient(final Context context) { 
    Interceptor REWRITE_CACHE_CONTROL_INTERCEPTOR = new Interceptor() { 
     @Override 
     public okhttp3.Response intercept(Chain chain) throws IOException { 
      okhttp3.Response originalResponse = chain.proceed(chain.request()); 
      if (isConnected()) { 
       // Internet available; read from cache for 0 day 
       // Why? Reduce server load, better UX 
       int maxAge = 0; 
       return originalResponse.newBuilder() 
         .header("Cache-Control", "public, max-age=" + maxAge) 
         .build(); 
      } else { 
       // No internet; tolerate cached data for 1 week 
       int maxStale = 60 * 60 * 24 * 7; 
       return originalResponse.newBuilder() 
         .header("Cache-Control", "public, only-if-cached, max-stale=" + maxStale) 
         .build(); 
      } 
     } 
    }; 

    File httpCacheDirectory = new File(context.getCacheDir(), "cachedir"); 
    int size = 5 * 1024 * 1024; 
    Cache cache = new Cache(httpCacheDirectory, size); 

    return new OkHttpClient.Builder() 
      .addNetworkInterceptor(REWRITE_CACHE_CONTROL_INTERCEPTOR) 
      .cache(cache) 
      .build(); 
} 

と使用方法：

public static Retrofit getClient(final Context context) { 

    if (retrofit == null) { 
     retrofit = new Retrofit.Builder() 
       .client(getCacheClient(context)) 
       .baseUrl(BASE_URL) 
       .addConverterFactory(GsonConverterFactory.create()) 
       .build(); 
    } 
    return retrofit; 
}