RxAndroid/java小记 Android

行是知之始,知是行之成。这篇文章主要讲述RxAndroid/java小记相关的知识，希望能为你提供帮助。

Rxandroid
作为一个在设计模式中能把MVP发挥的淋漓尽致的框架不去学习感觉真的对不起自己，然后也学点新东西吧，响应式编程，MVP观察者模式，然后使用Rxandroid使我们自己的代码更加简洁
然后昨天看了一个文章说，接口调用频繁使用的话会使你的整个代码看起来非常难以理解，其实想想也是，一个读者看到了你的代码，然后却发现你的代码里充斥着接口回调，哎，这时候
他就需要寻找你这个接口到底回调到了哪里（想想也是这个道理啊）；
所以Rx（Android、java）系列很好解决了这个问题，我也是昨天才意识到，因为你可以把所需要执行的任务和任务产生的回调放在同一个地方，然后这个时候，就不需要找来找去了吧
【RxAndroid/java小记】一目了然，任务（耗时任务或者不耗时任务）执行地，任务返回值以及后续的处理都以链式的形式调用；
MVP是啥即Model view Presenter，

文章图片

mvp模式可以分离显示层和逻辑层，他们之间通过接口进行通信（好像我之前很多都是用接口通信的诶！冥冥中也有用到mvp模式），降低耦合；
从图中可以看出Presenter分别和Model和view交互，而view和Model之间并没有直接联系
这样随着我们的业务在拓展然后UI改变的话，或者业务逻辑改变UI也有修改的话，如果不分开，那将是一件非常头疼的事，因为你都要两者兼顾，但是现在你只需要
专心专注于UI界面或者业务逻辑的修改了！嗯，差不多MVP就是这个好处吧
然后是RxAndroidrxandroid是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自博客园作者：还没好好感受年轻