RxJava(七) 使用 debounce 操作符优化 App 搜索功能[通俗易懂]
大家好,又见面了,我是你们的朋友全栈君。
RxJava 系列文章目录导读:
一、RxJava create 操作符的用法和源码分析 二、RxJava map 操作符用法详解 三、RxJava flatMap 操作符用法详解 四、RxJava concatMap 操作符用法详解 五、RxJava onErrorResumeNext 操作符实现 app 与服务器间 token 机制 六、RxJava retryWhen 操作符实现错误重试机制 七、RxJava 使用 debounce 操作符优化 app 搜索功能 八、RxJava concat 操作处理多数据源 九、RxJava zip 操作符在 Android 中的实际使用场景 十、RxJava switchIfEmpty 操作符实现 Android 检查本地缓存逻辑判断 十一、RxJava defer 操作符实现代码支持链式调用 十二、combineLatest 操作符的高级使用 十三、RxJava 导致 Fragment Activity 内存泄漏问题 十四、interval、takeWhile 操作符实现获取验证码功能 十五、RxJava 线程的自由切换
一、抛出问题
现在几乎所有的 App 都有搜索功能 , 一般情况我们监听 EditText 控件,当值发生改变去请求搜索接口. 如:
etKey.addTextChangedListener(new TextWatcher() {
@Override
public void beforeTextChanged(CharSequence s, int start, int count, int after) {
}
@Override
public void onTextChanged(CharSequence s, int start, int before, int count) {
}
@Override
public void afterTextChanged(Editable s) {
String key = etKey.getText().toString().trim();
if (key.length() > 0){
search(key); // 请求搜索接口,成功后把结果显示到界面上.
}
}
});
这样做有两个问题:
- 可能导致很多没有意义的请求,耗费用户流量(因为控件的值每更改一次立即就会去请求网络,而且只是最后输入的关键字是有用的)
- 可能导致最终搜索的结果不是用户想要的. 例如,用户一开始输入关键字
AB
这个时候出现两个请求, 一个请求是 A 关键字, 一个请求是 AB 关键字. 表面上是 A 请求先发出去, AB 请求后发出去. 如果后发出去的 AB 请求先返回, A 请求后返回,那么 A 请求后的结果将会覆盖 AB 请求的结果. 从而导致搜索结果不正确.
二、如何解决问题
使用强大的 RxJava 的 debounce
操作符可以解决这个问题。
subscription = RxTextView.textChanges(etKey)
.debounce(400, TimeUnit.MILLISECONDS, AndroidSchedulers.mainThread())
.subscribeOn(AndroidSchedulers.mainThread())// 对etKey[EditText]的监听操作 需要在主线程操作
//对用户输入的关键字进行过滤
.filter(new Func1<CharSequence, Boolean>() {
@Override
public Boolean call(CharSequence charSequence) {
Log.d("RxJava", "filter is main thread : " + (Looper.getMainLooper() == Looper.myLooper()));
return charSequence.toString().trim().length() > 0;
}
})
.flatMap(new Func1<CharSequence, Observable<List<String>>>() {
@Override
public Observable<List<String>> call(CharSequence charSequence) {
Log.d("RxJava", getMainText("flatMap"));
return searchApi.search(charSequence.toString());
}
})
//.subscribeOn(Schedulers.io()不起作用
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Action1<List<String>>() {
@Override
public void call(List<String> strings) {
tvContent.setText("search result:\n\n");
tvContent.append(strings.toString());
}
}, new Action1<Throwable>() {
@Override
public void call(Throwable throwable) {
throwable.printStackTrace();
tvContent.append("Error:" + throwable.getMessage());
}
});
上面代码的主要逻辑:
- 使用 debounce 操作符设置: 只有当用户输入关键字后 400 毫秒才发射数据(说的直白点就是 400 毫秒后才会走后面的逻辑)
- 使用 filter 操作符 对用户输入的关键字进行过滤:只有输入的关键字不为空,才会走后面的逻辑;
- 使用 flatMap 操作符:使用最终的关键字去请求搜索接口
至此,避免 EditText 每改变一次就请求一次的情况。 但是,还有一个问题,上面说的导致搜索结果的错乱,上面的代码还是没有解决,比如停止输入 400 毫秒后, 那么肯定会开始请求 Search 接口, 但是用户又会输入新的关键字,这个时候上个请求还没有返回, 新的请求又去请求 Search 接口.这个时候有可能最后的一个请求返回, 第一个请求最后返回,导致最终显示的结果是第一次搜索的结果.
怎么去解决这个问题:可以使用
switchMap
操作符解决。
看看官网对 switchMap
操作符如何解释的:
Returns a new Observable by applying a function that you supply to each item emitted by the source Observable that returns an Observable,
and then emitting the items emitted by the most recently emitted of these Observables.
switchMap
操作符和 flatMap
操作符差不多,区别是 switchMap
操作符只会发射(emit)最近的 Observables。
也就是说,当 400 毫秒后,发出第一个搜索请求,当这个请求的过程中,用户又去搜索了,发出第二个请求,不管怎样,switchMap 操作符只会发射第二次请求的 Observable。所以,在上面的代码基础上把 flatMap 改成 switchMap 就可以了。
如果你觉得本文帮助到你,给我个关注和赞呗!
另外,我为 Android 程序员编写了一份:超详细的 Android 程序员所需要的技术栈思维导图。
如果有需要可以移步我的 GitHub -> AndroidAll,里面包含了最全的目录和对应知识点链接,帮你扫除 Android 知识点盲区。 由于篇幅原因只展示了 Android 思维导图:
发布者:全栈程序员栈长,转载请注明出处:https://javaforall.cn/151576.html原文链接:https://javaforall.cn
相关文章
- 从零开发一款相机APP 第二篇: 前景
- 某车联网App 通讯协议加密分析
- uni-app APP地图移动时获取地图中心点经纬度坐标
- uni-app引入sortable列表拖拽,兼容App和H5
- app store connect
- 如何把小程序游戏运行到自有App中?(IOS篇)
- uni-app 安卓APP开发记录
- 软件测试|一键搞定centos7的docker+selenium+appium+jenkins+android_app源码打包成apk的环境搭建
- 一步步了解iOS APP上架流程,让你的APP顺利进入App Store的大门
- HBuilder包装iOS APP上App Store的详细过程
- 使用jqMobi开发app基础详解手机开发
- 各种App都告诉我:你没钱,你得借钱,跟我借!
- 鸿蒙 HarmonyOS 2 音频播控中心可一键切换至外放、切换 App
- 最佳Linux学习之路:一款轻松促进学习的App(学linux的app)
- 拓展业务用App组合MySQL实现跨平台数据共享(app组合mysql)
- App联手Oracle实现多样化应用(app与oracle)
- MYSQL数据库下载指南,轻松安装游戏APP(MYSQL下载游戏app)
- App与Oracle融合,拥抱数据驱动未来(app与oracle)
- 麻省理工学院创业团队做快递无人车,用手机APP随叫随到
- 天风证券与AI公司达成合作,NLP、KG技术革新高材生App
- 对话兆日科技白建雄:为什么一个银行对公App要有考勤功能?
- Web.config和App.config的区别分析