這是我在這段時間的開發(fā)中，一些場景對 Rxjava、retrofit的應用
1下梢、 數(shù)據(jù)三級獲取 (內存 -> 本地存儲 -> 網(wǎng)絡)
2堂氯、 延遲執(zhí)行 祈秕， 延遲 2秒 執(zhí)行 xx操作
3、 輪循任務
4、 多組不同的數(shù)據(jù)源 之間的操作:(場景： 1、注冊需要三個參數(shù)都滿足條件饵史；2、輸出兩組數(shù)組 相同的數(shù))
5胜榔、 過濾 且返回第一個符合條件的數(shù)據(jù)
6胳喷、 Rxjava Retrofit組合使用
數(shù)據(jù)三級獲取 (內存 -> 本地存儲 -> 網(wǎng)絡)
正常來講是這樣的：
新開線程 先判斷對象有沒有數(shù)據(jù)，沒有數(shù)據(jù)就從本地賦值給對象夭织，如果還是為空吭露，那么從網(wǎng)絡獲取，最后切換主線程執(zhí)行UI操作;
ObservableSource<String> memory = observer1 -> {
if (str != null) {
observer1.onNext(str);
} else {
observer1.onComplete();
}
};
ObservableSource<String> disk = observer1 -> {
String localData = "localData";
if (localData != null) {
observer1.onNext(localData);
} else {
observer1.onComplete();
}
};
ObservableSource<String> netWork = observer1 -> {
String netData = null;
if (netData != null) {
observer1.onNext(netData);
observer1.onComplete();
} else {
observer1.onComplete();
observer1.onError(new Throwable("數(shù)據(jù)為空"));
}
};
Observer observer = new Observer<String>() {
@Override
public void onNext(String s) { //UI操作 }
@Override
public void onError(Throwable e) { // 吐司 }
};
Observable.concat(memory, disk, netWork)
.subscribeOn(Schedulers.io())//指定Observable 在哪個線程上創(chuàng)建執(zhí)行操作尊惰，如果多次調用讲竿，只有第一次有效
.observeOn(AndroidSchedulers.mainThread())//在指定下一事件發(fā)生的線程
.subscribe(observer);
別看好像代碼挺多的泥兰， 但是流程絕對清晰，最主要的是 不用手動切換線程题禀；
延遲執(zhí)行 鞋诗， 延遲 2秒 執(zhí)行 xx操作
有個弊端,不能發(fā)射數(shù)據(jù)， 且Observer數(shù)據(jù)類型是Long 返回數(shù)為：0投剥；
Observer<Long> longObserver = new Observer<Long>() {
//...
@Override
public void onNext(Long lon) {
out("onNext：" + lon);
}
//...
};
Observable.timer(2, TimeUnit.MILLISECONDS)
.subscribe(longObserver);
輪循任務
Observable.interval(2, TimeUnit.SECONDS)
.subscribe(longObserver);
停止輪循 unSubscribe()
多組不同的數(shù)據(jù)源 之間的操作:(場景： 1、注冊需要三個參數(shù)都滿足條件担孔；2江锨、輸出兩組數(shù)組 相同的數(shù))
1 注冊：
Observable.combineLatest( Observable.just("111"), Observable.just("222"), Observable.just("333"),
(s, charSequence, charSequence2) -> {
//判斷三個數(shù)是否都滿足條件 返回 true或者 false
return false;
})
.subscribe(new Observer<Boolean>() {
//...
@Override
public void onNext(Boolean b) {
out("onNext：" + (b ? "成功" : "失敗"));
}
});
2 兩數(shù)組輸出相同數(shù)
Observable.combineLatest( Observable.just(list1), Observable.just(list2), Observable.just("333"),
(list1, list2) -> {
List inputList=new ArrayList<>();
for(int a:list1){
for(int b:list2){
inputList.add(a);
}
}
return inputList;
})
.subscribe(new Observer<List<int>>() {
//...
@Override
public void onNext(List<int> list) {
out("onNext：" + list);
}
//...
});
過濾 且返回第一個符合條件的數(shù)據(jù)
Observable.just(1, 2, 3, 4, 5, 6, 7, 8, 9)
.filter(integer -> {
if (integer <3) {
return false;
} else {
return true;
}
})
.firstElement()
.subscribe(integer -> out("accept：" + integer))
Rxjava Retrofit 組合使用
封裝一下更好用哦，套路如下：
初始化 支持 rxjava的 retrofit
通過retrofit 得到 Observable
Observable 執(zhí)行 網(wǎng)絡請求
public interface HttpHealthAPI {
@GET("index.php")
Observable<BaseDataModel> get(@Query("controller") String controller, @Query("method") String method, @Query("app_id") String app_id);
}
// 初始化 Retrofit
private Retrofit retrofit;
retrofit = new Retrofit.Builder()
.baseUrl(NET_RETROFIT_URL)
.client(client)
.addConverterFactory(FastJsonConverterFactory.create()) //數(shù)據(jù)轉換 我這邊用的是fastjson
.addCallAdapterFactory(RxJava2CallAdapterFactory.create()) //轉換成 rxjava
.build();
// 獲取 Observable
Observable observable = retrofit .create(HttpHealthAPI.class)
// 執(zhí)行 網(wǎng)絡請求
observable.subscribeOn(Schedulers.newThread())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(baseSubscriber);
希望我的文章不會誤導在觀看的你糕篇，如果有異議的地方歡迎討論和指正啄育。
如果能給觀看的你帶來收獲，那就是最好不過了拌消。
