这里有新鲜出炉的精品教程,程序狗速度看过来!
Android是一种基于Linux的自由及开放源代码的操作系统,主要使用于移动设备,如智能手机和平板电脑,由Google公司和开放手机联盟领导及开发。尚未有统一中文名称,中国大陆地区较多人使用“安卓”或“安致”。
本篇文章主要介绍了Android仿淘宝搜索联想功能的示例代码,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
现在不少应用都提供了搜索功能,有些还提供了搜索联想。对于一个搜索联想功能,最基本的实现流程为:客户端通过监听输入框内容的变化,当输入框发生变化之后就会回调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
来源: http://www.phperz.com/article/17/0914/345675.html