(点击上方公众号，可快速关注)
泉源：伯乐在线专栏作者-SOLID
https://android.jobbole.com/83416/
如有好文章投稿，请点击→这里相识详情
RxJava
从开始最开始学习RxJava到如今也有一段时间了，还记得客岁第一次看RxJava的文章就是扔物线的的这篇文章给Android开辟者的RxJava详解，那一次我看了整整一个下战书，由于在那之前我完全没打仗过RxJava，也不知道那是个什么，看完很多地方都还不是很明白，整个人都是晕晕的，固然劳绩也还是有的，至少对RxJava有了一个开端的概念。那次之后我就没再去碰过RxJava了，当时内心想的是，假如背面必要这方面的东西我再来学习也不迟。
时间差不多过了半年，RxJava也越来越火了，利用RxJava的开辟者也是越来越多，github上关于的开源库中利用RxJava的也越来越多。当我再去看一些开源库的时间，由于很多地方都用到了RxJava，就发现很多代码都看不懂了，这也就激起了再次去学习RxJava的动力，随后就在网上各种的查找RxJava相干的学习资料，重新学习，我又去看了一遍给Android开辟者的RxJava详解，劳绩还是很多的，本文也是对这段时间我学习RxJava的一个小结，以下知识点重要针对于Android开辟者。
本文的学习目次
1.RxJava是什么
2.在Android中怎么去利用RxJava
3.RxJava操纵符的先容
4.RxJava在生产环境中的利用
5.RxJava学习的参考资料
1.RxJava是什么
要知道RxJava是什么，那么你应该先去相识一下Rx。Rx的全称是ReactiveExtensions，直译过来就是相应式扩展。Rx基于观察者模式，他是一种编程模子，目标是提供同等的编程接口，资助开辟者更方便的处理惩罚异步数据流。ReactiveX.io给的界说是，Rx是一个利用可观察数据流举行异步编程的编程接口，ReactiveX连合了观察者模式、迭代器模式和函数式编程的英华。Rx已经渗出到了各个语言中，有了Rx以是才有了RxJava，Rx.NET、RxJS、RxSwift、Rx.rb、RxPHP等等，更具体的可以去这里看看languages
那么RxJava到底是什么，我对于他的明白就针对于Java语言的一个异步的相应式编程库。
2.怎么去利用RxJava
在gradle文件的dependencies中参加以下代码即可（以下版本大概不是最新的，必要最新的可到RxAndroid查察）
compile'io.reactivex:rxandroid:1.2.0'
compile'io.reactivex:rxjava:1.1.5'
3.RxJava操纵符的先容
有了以上的设置，我们就可以在Android中利用RxJava了。对于RxJava的利用，最紧张的还是对于操纵符的学习，认识了操纵符才华更好的利用RxJava。RxJava中的操纵符黑白常丰富的，关于RxJava操纵符先容的文章已经是属于一搜就是一大堆的那种了，以是本文就不多做先容了，在这里给各人保举一个学习操纵符比力好的地方Operaters
4.RxJava在生产环境中的利用
想必学习RxJava的同砚，在学习完操纵符之后，最想知道的是怎么将其用在我们平常的开辟当中去，本节就带各人去相识一下怎么去应用RxJava。
RxBinding
节流(防止按钮的重复点击)
轮询，定时操纵
RxPermissions
RxBus
RxJava与Retrofit
等待你们的增补~~~
(1)RxBinding
RxBinding是JakeWharton大牛用RxJava为Android控件编写的一个控件绑定库，而且为各个包下的控件都编写相应的库，如下所示
Platformbindings:
compile'com.jakewharton.rxbinding:rxbinding:0.4.0'
'support-v4'librarybindings:
compile'com.jakewharton.rxbinding:rxbinding-support-v4:0.4.0'
'appcompat-v7'librarybindings:
compile'com.jakewharton.rxbinding:rxbinding-appcompat-v7:0.4.0'
'design'librarybindings:
compile'com.jakewharton.rxbinding:rxbinding-design:0.4.0'
'recyclerview-v7'librarybindings:
compile'com.jakewharton.rxbinding:rxbinding-recyclerview-v7:0.4.0'
'leanback-v17'librarybindings:
compile'com.jakewharton.rxbinding:rxbinding-leanback-v17:0.4.0'
我们只需引入对应地库就可以利用了。
比如我们对Button添加一个单击变乱就可以如许做了
Buttonbutton=(Button)findViewById(R.id.button);
RxView.clicks(button).subscribe(newAction1Void(){
@Override
publicvoidcall(VoidaVoid){
Log.i("test","clicked");
}
});
到这里，你肯定会说，这并没有没什么卵用，还不如直接设置一个setOnClickListener来的方便，直接。继承往下看
通常环境下，假如我们要防止一个按钮重复点击会怎么做？设置一个第一次按下的时间，然后在第二次点击的时间去判定？NONONO，如许做都太low了，我们来看看用RxBing怎样去实现
RxView.clicks(button).debounce(300,TimeUnit.MILLISECONDS).subscribe(newAction1Void(){
@Override
publicvoidcall(VoidaVoid){
Log.i("test","clicked");
}
});
很爽吧，这里过滤掉了在300ms内的重复点击，只需加一个操纵符就可以了，而不消我们去编写一大堆而且还轻易堕落的逻辑代码了。
这里利用最多的一个地方就是在我们做搜刮的时间，再连合filter操纵，去过滤掉那些没须要的查询操纵，来减小服务器的压力和客户端的流量输出。
(2)轮询，定时操纵
在做App的时间，有些地方我们大概会时不时的去哀求服务器，以至于客户端的数据是最新的，在RxJava中可以如许做
//每隔两秒实行一次
Observable.interval(2,2,TimeUnit.SECONDS).subscribe(newAction1Long(){
@Override
publicvoidcall(LongaLong){
//TODOWHATYOUWANT
}
});
在两秒后去实行一些操纵（比如启动页跳转到主页面）
Observable.timer(2,TimeUnit.SECONDS).subscribe(newAction1Long(){
@Override
publicvoidcall(LongaLong){
//TODOWHATYOUWANT
}
});
(3)RxPermissions
RxPermissions也是国外的大牛开辟的基于RxJava的Android权限管理库，他让6.0以上的权限管理更加的简单，假如有适配6.0以上的手机的需求，这个库是个不错的选择。下面我们来看看根本的用法。
//哀求相机权限
RxPermissions.getInstance(this)
.request(Manifest.permission.CAMERA)
.subscribe(granted-{
if(granted){//用户同意了（在6.0之前的手机始终都为true）
//可以照相了
}else{
//可以在这里提示用户，大概再次哀求
}
});
固然，假如我想一次哀求多个权限呢，每次都去写上面的代码肯定是个不好的做法，RxPermissions的作者也思量到了这一点，在Api里提供了一个多参数的重载
//取得相机权限和读取手机状态
RxPermissions.getInstance(this)
.request(Manifest.permission.CAMERA,
Manifest.permission.READ_PHONE_STATE)
.subscribe(granted-{
if(granted){
}else{
}
});
更多的资料还请去github上去查察。
(4)RxBus
有了RxJava，EventBus、Otto什么的都可以靠边了，由于RxJava本身就自带了这个功能，我们只需做一下简单的封装就可以利用了，也趁便镌汰了我们项目标体积。
publicclassRxBus{
privatefinalSubjectObject,Object_bus;
privatestaticclassRxBusHolder{
privatestaticfinalRxBusinstance=newRxBus();
}
privateRxBus(){
_bus=newSerializedSubject(PublishSubject.create());
}
publicstaticsynchronizedRxBusgetInstance(){
returnRxBusHolder.instance;
}
publicvoidpost(Objecto){
_bus.onNext(o);
}
publicTObservableTtoObserverable(ClassTeventType){
return_bus.ofType(eventType);
}
怎么去利用？
在必要发送消息的地方
RxBus.getInstance().post("SomeChange");
在必要吸取消息的地方
SubionmSubion=RxBus.getInstance().toObserverable(String.class).subscribe(newAction1String(){
@Override
publicvoidcall(Strings){
handleRxMsg(s);
}
});
不要忘了在得当的地方去取消这个订阅（以免发生内存走漏）
mSubion.unsubscribe();
到这里大概你有个疑问，Subject是个什么鬼！
着实Subject同时充当了Observer和Observable的脚色，他可以发射数据也可以吸取数据，有AsyncSubject、BehaviorSubject、PublishSubject、ReplaySubject四种，具体的先容请看Subject
(5)RxJava与Retrofit
Retrofit大概各人都不太陌生了，假如你还不知道的话，那么赶紧去学习吧，这么强大的框架怎么能不知道呢！
背面的讲授是基于相识过Retrofit的同砚
关于Retrofit的根本利用大概我们都不是太陌生，对于哀求后的结果都是在一个回调接口里吸取，对于结果的处理惩罚并不是太机动，一大堆的回调会让你以后回过来看代码的时间看的灯红酒绿。
RxJava很好的办理了这个题目，我们来看看Retrofit的怎么去适配RxJava吧。
gradle文件的引用
compile'com.squareup.retrofit2:retrofit:2.0.2'
compile'com.squareup.retrofit2:converter-gson:2.0.2'
compile'com.squareup.retrofit2:adapter-rxjava:2.0.2'//RxJava与Retrofit的适配器
这里我以哀求https://gank.io/api/data/Android/10/1为例。
返回的结果大抵是如许的
于是我界说了一个GankResultBean去吸取这个结果。
此中ResultsBean就是results中的每一个条目。
好了，下面我们来看看适配了RxJava的Retrofit怎么去利用吧
起首我们界说一个接口
publicinterfaceRxGankService{
@GET("all/20/{page}")
ObservableGankResultBeangetAndroidData(@Path("page")intpage);
}
值得留意的是这里返回的是ObservableGankResultBean而不是通例的CallGankResultBean
接着就可以做哀求了
Retrofitretrofit=newRetrofit.Builder()
.baseUrl("https://gank.io/api/data/")
.addConverterFactory(GsonConverterFactory.create())
.addCallAdapterFactory(RxJavaCallAdapterFactory.create())//这个就是用来适配RxJava的
.build();
RxGankServicerxGankService=retrofit.create(RxGankService.class);
finalObservableGankResultBeanobservable=rxGankService.getAndroidData(1);
observable
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.map(newFunc1GankResultBean,ListGankResultBean.ResultsBean(){
@Override
publicListGankResultBean.ResultsBeancall(GankResultBeangankResultBean){
returngankResultBean.getResults();
}
})
.flatMap(newFunc1ListGankResultBean.ResultsBean,ObservableGankResultBean.ResultsBean(){
@Override
publicObservableGankResultBean.ResultsBeancall(ListGankResultBean.ResultsBeanresultsBeen){
returnObservable.from(resultsBeen);
}
})
.filter(newFunc1GankResultBean.ResultsBean,Boolean(){
@Override
publicBooleancall(GankResultBean.ResultsBeanresultsBean){
return"Android".equals(resultsBean.getType());
}
})
.subscribe(newSubscriberGankResultBean.ResultsBean(){
@Override
publicvoidonCompleted(){
Log.i("test","onCompleted");
}
@Override
publicvoid(Throwablee){
e.printStackTrace();
}
@Override
publicvoidonNext(GankResultBean.ResultsBeanresultsBean){
textView.append(resultsBean+"n");
}
});
这里是为了演示才利用了这么多的操纵符，在实际利用的时间根据具体环境而定。
下面简单表明下上面这段代码
observeOn(AndroidSchedulers.mainThread())：订阅者的回调在主线程
subscribeOn(Schedulers.io())：订阅发生在io线程
map:一样平常我们不会关心error字段，我们关心的只是results，以是在这里做了一个映射让用户吸取的是ListGankResultBean.ResultsBean而不是包罗有error的GankResultBean
flatMap:让结果一条一条的发射出去，而不是一个聚集
filter：只吸取Type为Android的数据
以上的例子用流的方式是不是很好的办理了对哀求结果的处理惩罚，对结果的处理惩罚可以做到为所欲为，而且逻辑还很清楚。
以上几个点就是我相识的关于RxJava的应用。假如你尚有其他方面的应用，还望增补。
5.RxJava学习的参考资料
这里我将我学习RxJava以来网络的关于RxJava分享出来，以方便各人的查阅。
学习RxJava的第一手资料,官方的wiki:wiki
我学习RxJava看的第一篇文章：给Android开辟者的RxJava详解(这个各人肯定都知道)
大头鬼总结的RxJava学习资料：Awesome-RxJava
RxJava文档中文翻译：Rx和RxJava文档中文翻译项目
其他：
RxJava处理惩罚网络毗连失败和timer()、interval()、delay()之间的区别
ArchitectingAndroidwithRxJava
利用RxJava提拔用户体验
用RxJava实现变乱总线(EventBus)
IntrotoRx
ImplementinganEventBusWithRxJava–RxBus
大概是东半球最全的RxJava利用场景小结
RxJava操纵符图解（需科学上网）
末了：为了跟上期间的步调，是时间学习RxJava了
看完本文有劳绩？请分享给更多人
关注「安卓开辟精选」，提拔安卓开辟技能
CopyrightYourWebSite.SomeRightsReserved.
京ICP备2023016396号-1PoweredByESCLINK.
我要评论