RxCache使用场景记录

场景

一个需求,构建UI数据时，需要组装数据，我们将数据分为两类，一类为配置数据、一类为UI框架数据。框架数据依赖配置数据进行数据组装，配置数据特性为长期保持不变。针对这个特性，我们可以将配置数据json保存到本地，设置超期时间，不用频繁的进行网络访问。

对此，我们进行RxCache库的使用，该库通过注解的设置可以网络数据保存到制定文件目录下。具体的使用方法可以参考《Android RxCache使用详解》。

踩坑

在配置过程中，我没有直接按照上面的方式进行访问，得到了类型转换错误，查看原因是保存的json数据在解析过程中因为存文的文本文件没有转义字符保存，在读取的时候报错。

//网络json直接存储格式
data{
 code:1
 data:[
   {name:"martin"}
  ]
}

具体的解决方案是讲网络数据返回的String优先保存，文件格式展示：

\"data\"{
  \"code\":1
 \"data\":[
   {\"name\":\"martin\"}
  ]
}

经过上面的处理后，然后通过读取流的方式通过gson工具进行转换。
部分代码如下：

//网络访问
interface ApiService{
	//返回值顶为String
	@POST(AppConstant.UrlString.URL_GET_ALL_CONTACT_SOURCE)
    fun getAllContactSources(): Observable<String>
} 

//缓存访问
@EncryptKey("tagDisplayCache")
interface ApiCacheService{
	
	//设置超时时间为5分钟
    @ProviderKey("cacheCustomerSource")
    @LifeCache(duration = 5, timeUnit = TimeUnit.MINUTES)
    fun cacheCustomerSources(
    	//网络访问请求
        observable: Observable<String>,
        number: DynamicKey,
        evictDynamicKey: EvictDynamicKey
    ): Observable<String>
}
//ComposeString2Obj，核心代码
public class ComposeString2Obj<T> implements ObservableTransformer<String,DataResponse<T>> {

     public TypeToken<DataResponse<T>> typeToken;

     public static ComposeString2Obj newCompose(TypeToken typeToken) {
        return new ComposeString2Obj(typeToken);
    }

    public ComposeString2Obj(TypeToken<DataResponse<T>> typeToken) {
        this.typeToken = typeToken;
    }

    @Override
    public ObservableSource<DataResponse<T>> apply(Observable<String> responseObservable) {
        return responseObservable
                .flatMap(new ReadListFunc<>(typeToken))
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread());
    }

    // 读取列表数据
     private static class ReadListFunc<E> implements Function<String, Observable<DataResponse<E>>> {

         private TypeToken<DataResponse<E>> typeToken;

         public ReadListFunc(TypeToken<DataResponse<E>> typeToken) {
             this.typeToken = typeToken;
         }


        @Override
        public Observable<DataResponse<E>> apply(String s) {
            DataResponse<E> response = new Gson().fromJson(s, typeToken.getType());
            if (response != null && response.getCode() == DataResponse.CODE_SUCCESS) {
                return Observable.just(response);
            } else {
                return Observable.error(new Throwable());
            }
        }
    }

 }
//类型转换
fun main(){
	 ApiServiceManager.getInstance().getApiCache(ApiCacheService::class.java)
            .cacheCustomerSources(
                ApiServiceManager.getInstance()
                    .getApiService(ApiService::class.java).getAllContactSources(),
                    //访问
                DynamicKey(AppConstant.UrlString.URL_GET_ALL_CONTACT_SOURCE),
                EvictDynamicKey(isRefresh)
            ).compose(ComposeString2Obj(object:TypeToken<DataResponse<MutableList<MapBean>>>(){}))
}

---------------后期持续更新