现在不少应用都提供了搜索功能,有些还提供了搜索联想。对于一个搜索联想功能,最基本的实现流程为:客户端通过监听输入框内容的变化,当输入框发生变化之后就会回调aftertextchanged方法,客户端利用当前输入框内的文字向服务器发起请求,服务器返回与该搜索文字关联的结果给客户端进行展示。服务器那边,一般要做内存缓存池,就是把有可能的结果都放在内存中。
效果图
app这边也有几个重要的问题需要我们思考
我的方案是采用retrofit2+rxjava2来实现的,针对这几个问题的大致思路如下,关于这几个操作符的解释,在demo中有较完整的解释
下面贴出关键代码
private void initedt() { edittext = (edittext) findviewbyid(r.id.edt); edittext.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) { if (s.tostring().trim().isempty()) { mpop.dismiss(); } else { //输入内容非空的时候才开始搜索 startsearch(s.tostring()); } } }); mpublishsubject = publishsubject.create(); mpublishsubject.debounce(200, timeunit.milliseconds) //这里我们限制只有在输入字符200毫秒后没有字符没有改变时才去请求网络,节省了资源 .filter(new predicate<string>() { //对源observable产生的结果按照指定条件进行过滤,只有满足条件的结果才会提交给订阅者 @override public boolean test(string s) throws exception { //当搜索词为空时,不发起请求 return s.length() > 0; } }) /** * flatmap:把observable产生的结果转换成多个observable,然后把这多个observable “扁平化”成一个observable,并依次提交产生的结果给订阅者 *concatmap:操作符flatmap操作符不同的是,concatmap操作符在处理产生的observable时, 采用的是“连接(concat)”的方式,而不是“合并(merge)”的方式, 这就能保证产生结果的顺序性,也就是说提交给订阅者的结果是按照顺序提交的,不会存在交叉的情况 *switchmap:与flatmap操作符不同的是,switchmap操作符会保存最新的observable产生的 结果而舍弃旧的结果 **/ .switchmap(new function<string, observablesource<string>>() { @override public observablesource<string> apply(string query) throws exception { return getsearchobservable(query); } }) .observeon(androidschedulers.mainthread()) .subscribe(new disposableobserver<string>() { @override public void onnext(string s) { //显示搜索联想的结果 showsearchresult(s); } @override public void onerror(throwable throwable) { } @override public void oncomplete() { } }); mcompositedisposable = new compositedisposable(); mcompositedisposable.add(mcompositedisposable); } //开始搜索 private void startsearch(string query) { mpublishsubject.onnext(query); } private observable<string> getsearchobservable(final string query) { return observable.create(new observableonsubscribe<string>() { @override public void subscribe(observableemitter<string> observableemitter) throws exception { log.d(tag, "开始请求,关键词为:" + query); try { thread.sleep(100); //模拟网络请求,耗时100毫秒 } catch (interruptedexception e) { if (!observableemitter.isdisposed()) { observableemitter.onerror(e); } } if (!(query.contains("科") || query.contains("耐") || query.contains("七"))) { //没有联想结果,则关闭pop mpop.dismiss(); return; } log.d("searchactivity", "结束请求,关键词为:" + query); observableemitter.onnext(query); observableemitter.oncomplete(); } }).subscribeon(schedulers.io()); }
下面是针对几个操作符,从官网download下来的东西,供大家一起学习
debounce
debounce原理类似于我们在收到请求之后,发送一个延时消息给下游,如果在这段延时时间内没有收到新的请求,那么下游就会收到该消息;而如果在这段延时时间内收到来新的请求,那么就会取消之前的消息,并重新发送一个新的延时消息,以此类推。
而如果在这段时间内,上游发送了oncomplete消息,那么即使没有到达需要等待的时间,下游也会立刻收到该消息。
filter
filter的原理很简单,就是传入一个predicate函数,其参数为上游发送的事件,只有该函数返回true时,才会将事件发送给下游,否则就丢弃该事件。
switchmap
switchmap的原理是将上游的事件转换成一个或多个新的observable,但是有一点很重要,就是如果在该节点收到一个新的事件之后,那么如果之前收到的时间所产生的observable还没有发送事件给下游,那么下游就再也不会收到它发送的事件了。
如上图所示,该节点先后收到了红、绿、蓝三个事件,并将它们映射成为红一、红二、绿一、绿二、蓝一、蓝二,但是当蓝一发送完事件时,绿二依旧没有发送事件,而最初绿色事件在蓝色事件之前,那么绿二就不会发送给下游。
github地址(完整demo,欢迎下载)
https://github.com/zhouxu88/searchdemo
rxjava2学习地址
https://github.com/reactivex/rxjava
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持移动技术网。
如对本文有疑问, 点击进行留言回复!!
荐 面试官:kafka日志段如何读写都不知道,好意思说精通Kafka吗?
荐 如何写出一份“有理有据使人信服”的Android项目设计文档
荐 灵魂一问,Android中有代替HashMap的方法吗?
intent.setFlag的参数 FLAG_ACTIVITY_CLEAR_TASK 说明
网友评论