我想实现这样一个功能，用户点击获取数据库数据，若数据库有这个数据，则直接显示本地的，若数据库没有这个数据，就从服务器请求再显示出来。请问一下用rxjava要怎么写呢？
1.先把功能函数写出来.
private static Object loadFromCache(String key) { //....本地缓存加载，如果加载失败返回 null } private static Object loadFromServer(String key) { //....通过网络加载，返回数据 Object obj = .... saveToCache(key, obj);//保存到本地缓存 return obj; }
2.将阻塞方法转为RxJava的写法
private static Observable rxLoadFromCache(String key) { return Observable.fromCallable(() -> loadFromCache(key)); } private static Observable rxLoadFromServer(String key) { return Observable.fromCallable(() -> loadFromServer(key)); }
3.合并到一起
public static Observable rxLoad(String key) { return Observable.concat( rxLoadFromCache(key), rxLoadFromServer(key) ).filter(obj -> obj != null) .take(1); }
4.调用最后的方法
rxLoad(key) .subscribeOn(Schedulers.io()) .subscribe(obj->{ System.out.println(obj); });
![[Web front-end] Permulaan pantas Node.js](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
1.先把功能函数写出来.
private static Object loadFromCache(String key) { //....本地缓存加载，如果加载失败返回 null } private static Object loadFromServer(String key) { //....通过网络加载，返回数据 Object obj = .... saveToCache(key, obj);//保存到本地缓存 return obj; }2.将阻塞方法转为RxJava的写法
3.合并到一起
4.调用最后的方法
rxLoad(key) .subscribeOn(Schedulers.io()) .subscribe(obj->{ System.out.println(obj); });