码迷,mamicode.com
首页 > 移动开发 > 详细

RxAndroid/java小记

时间:2016-12-16 14:31:44      阅读:284      评论:0      收藏:0      [点我收藏+]

标签:error:   editable   解决   view   任务   scheduler   看到了   处理   put   

 

Rxandroid

作为一个在设计模式中能把MVP发挥的淋漓尽致的框架不去学习感觉真的对不起自己,然后也学点新东西吧,响应式编程,MVP观察者模式,然后使用RxAndroid使我们自己的代码更加简洁

然后昨天看了一个文章说,接口调用频繁使用的话会使你的整个代码看起来非常难以理解,其实想想也是,一个读者看到了你的代码,然后却发现你的代码里充斥着接口回调,哎,这时候

他就需要寻找你这个接口到底回调到了哪里(想想也是这个道理啊);

所以Rx(Android、java)系列很好解决了这个问题,我也是昨天才意识到,因为你可以把所需要执行的任务和任务产生的回调放在同一个地方,然后这个时候,就不需要找来找去了吧

一目了然,任务(耗时任务或者不耗时任务)执行地,任务返回值以及后续的处理都以链式的形式调用;

MVP是啥

即Model view Presenter,技术分享

mvp模式可以分离显示层和逻辑层,他们之间通过接口进行通信(好像我之前很多都是用接口通信的诶!冥冥中也有用到mvp模式),降低耦合;

从图中可以看出Presenter分别和Model和view交互,而view和Model之间并没有直接联系

这样随着我们的业务在拓展然后UI改变的话,或者业务逻辑改变UI也有修改的话,如果不分开,那将是一件非常头疼的事,因为你都要两者兼顾,但是现在你只需要

专心专注于UI界面或者业务逻辑的修改了!嗯 ,差不多MVP就是这个好处吧

然后是RxAndroid

rxandroid是rxjava的扩展,然后使用起来的话有提供很多方法给我们进行任务的操作

如just,map,fromCallable等。然后是两个重要的类Observable(事件发布者,被观察者),Observer(观察者,事件订阅者,Subscription(事件订阅者)。

just方法使用

just方法适用于不耗时的任务,同步方法

//事件发布者
    Observable<String> listObservable;
/**just测试,这里的getString是一个简单的返回String的函数(不贴出来)*/
     listObservable = Observable.just(getString());

listObservable.subscribe(new Observer<String>() {
            @Override
            public void onCompleted() {
                Log.v("test","OnCompleted");
            }

            @Override
            public void onError(Throwable e) {
                Log.v("test","OnError"+e);
            }

            @Override
            public void onNext(String s) {
                textView.setText(s);
                Log.v("test","OnNext:------"+s);
            }
        });

如上代码just()方法参数内可以传入一个值,值的类型由事件发布者在定义时规定,应与其保持一致。值获取成功后将通知onNext函数“发布”。

然后我们就可以在onNext函数进行相关操作了。这是简单的使用,然而rxandroid精髓之处在于对线程的操作(虽然我会说,但是感觉还是没有完全理解)

fromCallable()方法

just方法只是一个基础的方法,然而在实际情况中我们会有很多耗时的操作比如,网络请求,比如数据库存储等等,这个时候我们就需要用到异步的方法

fromcallbale用法和just类似,但是多了些控制线程的东西

/**长时间耗时任务测试*/
        listObservable = Observable.fromCallable(new Callable<String>() {
            @Override
            public String call() throws Exception {
                return getStringLongTime();
            }
        });

Subscription mtvSubscription = listObservable
                .subscribeOn(Schedulers.io())  //指定Observable中的方法运行的线程
                .observeOn(AndroidSchedulers.mainThread())//指定onNext运行线程
                .subscribe(new Observer<String>() {
                    @Override
                    public void onCompleted() {
                        Log.v("test_CallAble","OnCompled:------");
                    }

                    @Override
                    public void onError(Throwable e) {
                        Log.v("test_CallAble","OnError:------"+e);
                    }

                    @Override
                    public void onNext(String s) {
                        textView.setText(s);
                        Log.v("test_CallAble","OnNext:------"+s);
                    }
                });

被观察者new了一个Callable的实例,里面运行长时间耗时任务,完成后将异步通知观察者的OnNext方法

subscribOn是指定Observable运行的线程

observeOn是指定观察者OnNext方法所执行的线程

map方法

这里copy一下大神的代码过来,表述了map的使用方法,自行领会 debounce设置延迟时间

mTextWatchSubscription = mSearchResultsSubject
    .debounce(400, TimeUnit.MILLISECONDS)//设置400毫秒等待时间
    .observeOn(Schedulers.io())
    .map(new Func1<String, List<String>>() {

        @Override 
        public List<String> call(String s) { 
            return mRestClient.searchForCity(s); 
        } 
    })
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(new Observer<List<String>>() { 

        @Override 
        public void onCompleted() { }

        @Override 
        public void onError(Throwable e) { } 

        @Override
        public void onNext(List<String> cities) {
            handleSearchResults(cities); 
        }
    });

mSearchInput.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) {
        //有text改变时,调用onNext方法
        mSearchResultsSubject.onNext(s.toString()); 
    }

    @Override 
    public void afterTextChanged(Editable s) { } 
});

图片引用自:Android 源码 设计模式 解析与实战 【何红辉,关爱民著】

部分代码copy自博客园作者:还没好好感受年轻

 

RxAndroid/java小记

标签:error:   editable   解决   view   任务   scheduler   看到了   处理   put   

原文地址:http://www.cnblogs.com/fengfenghuifei/p/6186396.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!