上海网站建设褐公洲司,套模版做网站,网站群建设进度,百度快照怎么做写这篇博客的目的
网上关于Retrofit2和RxJava2的博客特别多#xff0c;但是内容特别复杂#xff0c;一上来就讲解很高级的用法
其实我们没必要像高考做题家一样#xff0c;把每个API都背的滚瓜烂熟
熟悉基本用法#xff0c;高阶用法需要的时候再逐个了解就行了
因为博客…写这篇博客的目的
网上关于Retrofit2和RxJava2的博客特别多但是内容特别复杂一上来就讲解很高级的用法
其实我们没必要像高考做题家一样把每个API都背的滚瓜烂熟
熟悉基本用法高阶用法需要的时候再逐个了解就行了
因为博客本身是脱离具体应用环境的很难通过文字把每个点讲得透彻大可不必太过追求面面俱到
所以这篇博客的主要目的只是为了讲解一下核心用法对于不求甚解的新手来说看完基本已经够用了
Retrofit示例
OkHttpClient client null;Retrofit.Builder builder new Retrofit.Builder().addCallAdapterFactory(RxJava2CallAdapterFactory.create()).addConverterFactory(GsonConverterFactory.create()).client(client).baseUrl(baseUrl);Retrofit retrofit builder.build();ApiService service retrofit.create(ApiService.class);
Retrofit讲解
addCallAdapterFactory 指定Call适配器用于将Call转换为Flowable
addConverterFactory 只懂Body适配器用于将Body转换为Bean
client 指定OkHttpClient
baseUrl 指定后台接口根路径
ApiService 指定请求格式和内容
RxJava示例
ObservableBookListVo bookListVoObservable apiService.getBookList();ObservableBannerListVo bannerListVoFlowable apiService.getBannerData();Observable concatFlowable Observable.concat(bookListVoObservable, bannerListVoFlowable);concatFlowable.subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());concatFlowable.subscribe(new Observer() {Overridepublic void onSubscribe(Disposable disposable) {//开始执行网络请求}Overridepublic void onNext(Object concatVo) {//网络请求执行成功}Overridepublic void onError(Throwable throwable) {//网络请求执行失败}Overridepublic void onComplete() {//所有请求全部执行完毕}});
RxJava讲解
Observable 封装一个事件这里是网络请求
Observable.concat 将多个事件串联起来执行
subscribeOn 指定订阅事件的线程这里是执行网络请求的线程
observeOn 指定接收事件的线程这里是网络请求执行成功处理回复数据的线程
subscribe 指定事件订阅者和接收者
onSubscribe 事件被订阅这里是即将开始执行网络请求
onNext 接收到新事件这里是网络请求返回数据
onError 接收或处理事件时发生异常这里是处理网络回复数据异常
onComplete 所有事件全部发送完毕这个方法要手动调用才会触发
onSubscribe的线程由subscribeOn方法指定
onNext的线程由observeOn方法指定
