摘要:按照计划这一期是要介绍框架结构和设计思想的,但是考虑到将在十月底发布正式版因此决定将框架结构和设计思想分析放到正式版发布后再做。后续我也会有一系列的文章来介绍和的区别。首选我们需要调用系统来获取所有已安装的,所以在的方法中调用。
转载请注明出处:[https://zhuanlan.zhihu.com/p/...
RxJava系列1(简介)
RxJava系列2(基本概念及使用介绍)
RxJava系列3(转换操作符)
RxJava系列4(过滤操作符)
RxJava系列5(组合操作符)
RxJava系列6(从微观角度解读RxJava源码)
RxJava系列7(最佳实践)
前言有点标题党了,其实谈不上什么最佳实践。前段时间公司实行996,所以也没什么时间和精力来更新博客(好吧~我承认是我懒~)。因此这篇文章只是简单的通过两个例子介绍了RxJava在生产环境中的使用。不过本篇中的每个例子我都配上了完整的代码。
示例一、获取手机上已安装的App按照计划这一期是要介绍RxJava框架结构和设计思想的,但是考虑到Netflix将在十月底发布RxJava2.0正式版;因此决定将RxJava框架结构和设计思想分析放到2.0正式版发布后再做。后续我也会有一系列的文章来介绍RxJava1.x和2.x的区别。
第一个例子我们需要在Android设备上展示已安装的第三方app列表,关于环境搭建、依赖配置、RecyclerView的使用等这些基础内容我就不做陈述了。需要了解的同学可以去GitHub上把项目clone下来看看。这里我主要讲讲如何通过RxJava实现核心功能。
首选我们需要调用系统api来获取所有已安装的app,所以在OnSubscribe的call方法中调用getApplicationInfoList()。但是getApplicationInfoList()获取的数据并不能完全满足我们的业务需求:
由于我们只需要展示手机上已安装的第三方App,因此需要通过filter操作符来过滤掉系统app;
ApplicationInfo并不是我们所需要的类型,因此需要通过map操作符将其转换为AppInfo;
由于获取ApplicationInfo、过滤数据、转换数据相对比较耗时,因此需要通过subscribeOn操作符将这一系列操作放到子线程中来处理;
而要将信息展示在页面上涉及到UI操作,因此需要通过observeOn操作符将onNext、onCompleted、onError调度到主线程,接着我们在这些方法中更新UI。
下面是核心代码:
final PackageManager pm = MainActivity.this.getPackageManager(); Observable.create(new Observable.OnSubscribe() { @Override public void call(Subscriber super ApplicationInfo> subscriber) { List infoList = getApplicationInfoList(pm); for (ApplicationInfo info : infoList) { subscriber.onNext(info); } subscriber.onCompleted(); } }).filter(new Func1 () { @Override public Boolean call(ApplicationInfo applicationInfo) { return (applicationInfo.flags & ApplicationInfo.FLAG_SYSTEM) <= 0; } }).map(new Func1 () { @Override public AppInfo call(ApplicationInfo applicationInfo) { AppInfo info = new AppInfo(); info.setAppIcon(applicationInfo.loadIcon(pm)); info.setAppName(applicationInfo.loadLabel(pm).toString()); return info; } }).subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(new Subscriber () { @Override public void onCompleted() { mAppListAdapter.notifyDataSetChanged(); mPullDownSRL.setRefreshing(false); } @Override public void onError(Throwable e) { mPullDownSRL.setRefreshing(false); } @Override public void onNext(AppInfo appInfo) { mAppInfoList.add(appInfo); } });
程序执行效果图:
完整的代码我放到了GitHub上,有兴趣大家可以去clone下来自己运行看看。
源码地址:https://github.com/BaronZ88/HelloRxAndroid
示例二、RxJava+Retrofit2实现获取天气数据RxJava + Retrofit2几乎是Android应用开发的标配了,这个例子中我们就来聊聊这二者是如何配合起来帮助我们快速开发的。
Retrofit2中一个标准的接口定义是这样的:
@GET("weather") ObservablegetWeather(@Query("cityId") String cityId);
现在有了RxJava,一个基本的网络请求我们便可以这样实现:
ApiClient.weatherService.getWeather(cityId) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(new Action1() { @Override public void call(Weather weather) { weatherView.displayWeatherInformation(weather); } });
但有时候可能一开始我们并不知道cityId,我们只知道cityName。所以就需要我们先访问服务器,拿到对应城市名的cityId,然后通过这个cityId再去获取天气数据。
同样的,我们需要定义一个获取cityId的接口:
@GET("city") ObservablegetCityIdByName(@Query("cityName") String cityName);
紧接着我们便可以使用无所不能的RxJava来实现需求了。
ApiClient.weatherService.getCityIdByName("上海") .flatMap(new Func1>() { @Override public Observable call(String cityId) { return ApiClient.weatherService.getWeather(cityId); } }).subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(new Action1 () { @Override public void call(Weather weather) { weatherView.displayWeatherInformation(weather); } });
哇哦!~ so easy!!!妈妈再也不用担心....
源码地址:https://github.com/BaronZ88/WeatherStyle
WeatherStyle)这个项目还在开发中,这个项目不只包含了RxJava和Retrofit的使用,同时还包含MVP、ORMLite、RetroLambda、ButterKnife等等开源库的使用
RxJava1.X的系列文章就到此结束了,由于本人对RxJava的理解有限,这一系列文章中如有错误还请大家指正。在使用RxJava过程中有任何疑问也欢迎大家和我交流。共同学习!共同进步!
好啦,我们RxJava2见!~
如果大家喜欢这一系列的文章,欢迎关注我的知乎专栏和GitHub。
知乎专栏:https://zhuanlan.zhihu.com/baron
GitHub:https://github.com/BaronZ88
文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。
转载请注明本文地址:https://www.ucloud.cn/yun/66532.html
摘要:之前写过一系列的文章,也承诺过会尽快有的介绍。所以这次还是给大家分享一个使用解决问题的案例,希望对大家在使用的时候有一点点启发。上述这一套复杂的业务逻辑如果使用传统编码方式将是极其复杂的。 之前写过一系列RxJava1的文章,也承诺过会尽快有RxJava2的介绍。无奈实际项目中还未真正的使用RxJava2,不敢妄动笔墨。所以这次还是给大家分享一个使用RxJava1解决问题的案例,希望对...
摘要:而这个就是线程调度的关键前面的例子中我们通过指定了发射处理事件以及通知观察者的一系列操作的执行线程,正是通过这个创建了我们前面提到的。总结这一章以执行流程操作符实现以及线程调度三个方面为切入点剖析了源码。 转载请注明出处:https://zhuanlan.zhihu.com/p/22338235 RxJava系列1(简介) RxJava系列2(基本概念及使用介绍) RxJava系列3...
阅读 2799·2021-11-15 11:39
阅读 1786·2021-09-24 09:48
阅读 1027·2021-09-22 15:36
阅读 3518·2021-09-10 11:22
阅读 2954·2021-09-07 09:59
阅读 906·2021-09-03 10:28
阅读 624·2021-09-02 15:15
阅读 2716·2021-08-27 16:24