/*** 缓存API接口** @LifeCache设置缓存过期时间. 如果没有设置@LifeCache , 数据将被永久缓存理除非你使用了 EvictProvider, EvictDynamicKey or EvictDynamicKeyGroup .* EvictProvider可以明确地清理清理所有缓存数据.* EvictDynamicKey可以明确地清理指定的数据 DynamicKey.* EvictDynamicKeyGroup 允许明确地清理一组特定的数据. DynamicKeyGroup.* DynamicKey驱逐与一个特定的键使用EvictDynamicKey相关的数据。比如分页，排序或筛选要求* DynamicKeyGroup。驱逐一组与key关联的数据，使用EvictDynamicKeyGroup。比如分页，排序或筛选要求*/
public interface CacheProviders {//缓存时间 1天@LifeCache(duration = 7, timeUnit = TimeUnit.DAYS)Observable<Reply<List<DataResults>>> getHomeTypes(Observable observable, DynamicKey userName, EvictDynamicKey evictDynamicKey);}

public abstract class RetrofitUtils {private static Retrofit mRetrofit;private static OkHttpClient mOkHttpClient;/*** 获取Retrofit对象** @return*/protected static Retrofit getRetrofit() {if (null == mRetrofit) {if (null == mOkHttpClient) {mOkHttpClient = OkHttp3Utils.getOkHttpClient();}//Retrofit2后使用build设计模式mRetrofit = new Retrofit.Builder()//设置服务器路径.baseUrl(Constant.API_SERVER + "/")//添加转化库，默认是Gson.addConverterFactory(GsonConverterFactory.create())//添加回调库，采用RxJava.addCallAdapterFactory(RxJavaCallAdapterFactory.create())//设置使用okhttp网络请求.client(mOkHttpClient).build();}return mRetrofit;}}

/** 所有的请求数据的方法集中地* 根据MovieService的定义编写合适的方法* 其中observable是获取API数据* observableCahce获取缓存数据* new EvictDynamicKey(false) false使用缓存  true 加载数据不使用缓存*/
public class HttpData extends RetrofitUtils {private static File cacheDirectory = FileUtil.getcacheDirectory();private static final CacheProviders providers = new RxCache.Builder().persistence(cacheDirectory).using(CacheProviders.class);protected static final GanHuoService service = getRetrofit().create(GanHuoService.class);private static class SingletonHolder {private static final HttpData INSTANCE = new HttpData();}public static HttpData getInstance() {return SingletonHolder.INSTANCE;}public void getHomeInfo(Observer<DataResults> observer,  boolean isUseCache,String type, int number, int page) {Observable observable= service.getDataResults(type,number,page);Observable observableCahce=providers.getHomeTypes(observable,new DynamicKey("首页"),new EvictDynamicKey(!isUseCache)).map(new HttpResultFuncCcche<List<DataResults>>());setSubscribe(observableCahce,observer);}/*** 插入观察者** @param observable* @param observer* @param <T>*/public static <T> void setSubscribe(Observable<T> observable, Observer<T> observer) {observable.subscribeOn(Schedulers.io()).subscribeOn(Schedulers.newThread())//子线程访问网络.observeOn(AndroidSchedulers.mainThread())//回调到主线程.subscribe(observer);}/*** 用来统一处理RxCacha的结果*/private class HttpResultFuncCcche<T> implements Func1<Reply<T>, T> {@Overridepublic T call(Reply<T> httpResult) {return httpResult.getData();}}}