| 注册
请输入搜索内容

热门搜索

Java Linux MySQL PHP JavaScript Hibernate jQuery Nginx
mynk3578
7年前发布

RxAndroid深入理解

   <p>注:本文的分析基于RxAndroid 1.2.1</p>    <p>现在项目里面大多都已经使用了rxjava, 因此对于很多rxjava的扩展库,也都可以使用在项目里了。</p>    <p>RxAndroid 已经成为标配了,基本只要使用了Rxjava, 你肯定能看见RxAndroid的身影。</p>    <h3><strong>使用场景:</strong></h3>    <pre>  <code class="language-java">Observable.just("one", "two", "three", "four", "five")          .subscribeOn(Schedulers.newThread())          .observeOn(AndroidSchedulers.mainThread())          .subscribe(/* an Observer */);</code></pre>    <p>很简单,就是指定到主线程上,即UI线程上,所以subscribe里的内容就会执行在主线程上。</p>    <h3><strong>或者其他线程的Looper</strong></h3>    <pre>  <code class="language-java">Looper backgroundLooper = // ...  Observable.just("one", "two", "three", "four", "five")          .observeOn(AndroidSchedulers.from(backgroundLooper))          .subscribe(/* an Observer */)</code></pre>    <p>这种使用方式,就是把后台线程所绑定的Looper作为AndroidSchedulers的参数, 那么这时实际上等同于 :</p>    <pre>  <code class="language-java">...  observeOn(Scheduler.io());</code></pre>    <p>因此这种方式下,subscribe 里的代码是执行在backgroundLooper所绑定的线程。</p>    <h3><strong>代码结构:</strong></h3>    <p style="text-align:center"><img src="https://simg.open-open.com/show/f56b2de9efde81689061bcd037669aa6.png"></p>    <p style="text-align:center">Paste_Image.png</p>    <h3><strong>实现分析:</strong></h3>    <p>既然使用的入口是AndroidScheduler 那就重这里开始分析。</p>    <p>首先看看AndroidScheduler的创建:</p>    <p style="text-align:center"><img src="https://simg.open-open.com/show/18579f6750ada6374565547a192d8807.png"></p>    <p style="text-align:center">Paste_Image.png</p>    <p>搭眼一看,饿汉式的单例, 并且这个单例是使用AtomicReference的,原子操作,保证多线程情况下,线程获取的值都是最新的,正确的。实例化用到了RxAndroidPlugins, 看下:</p>    <p style="text-align:center"><img src="https://simg.open-open.com/show/8f910ec0c98b50abe90571927f2b879f.png"></p>    <p style="text-align:center">Paste_Image.png</p>    <p>同样是AtomicReference ,同样是单例。</p>    <p style="text-align:center"><img src="https://simg.open-open.com/show/9c1cb191a72efb3dec0cac504cca8b48.png"></p>    <p style="text-align:center">Paste_Image.png</p>    <p>又引用到RxAndroidSechedulersHook</p>    <p style="text-align:center"><img src="https://simg.open-open.com/show/c331081d2ebf78fff20c0a4722caf306.png"></p>    <p style="text-align:center">Paste_Image.png</p>    <p>这是个什么鬼,搞了半天最后getMainThreadScheduler() 返回null. 再回头看看前面AndroidScheduler实例化的地方。</p>    <p style="text-align:center"><img src="https://simg.open-open.com/show/fa91efccfcaea9d5a21edf237031df7b.png"></p>    <p style="text-align:center">Paste_Image.png</p>    <p>soga, 空的话直接返回一个LooperScheduler, 否则直接使用。</p>    <p>这就是问题了,为什么要绕这么大一圈?</p>    <p>我觉得秘密在RxAndroidSchedulersHook里的一个方法,如下:</p>    <p style="text-align:center"><img src="https://simg.open-open.com/show/30d51de689e787eb4ed2594a5991b6b5.png"></p>    <p style="text-align:center">Paste_Image.png</p>    <p>那么这个方法在哪里被调用了呢? 这个问题先放着,后面会讲到。</p>    <p>先来看看注释,大概的意思是,该方法在把action 交给Scheduler处理之前被执行, 可以用于</p>    <p>包装/装饰/日志记录(翻译过来好别扭!), 默认值只是传递作用,直接返回。</p>    <p>如果你仔细看看Rxjava RxJavaSchedulersHook 类,你会发现如出一辙, 一模一样!!!</p>    <p>连注释都长一样!</p>    <p>这里是把UI线程的Looper作为参数创建了一个LoopScheduler.</p>    <p>再进去看看LooperScheduler:</p>    <p style="text-align:center"><img src="https://simg.open-open.com/show/09f70cb4416d79644be849195aadfc9d.png"></p>    <p style="text-align:center">Paste_Image.png</p>    <p>LooperScheduler 继承自Scheduler, 因此必须实现createWorker方法。</p>    <p>Worker是个什么东东?</p>    <p style="text-align:center"><img src="https://simg.open-open.com/show/974f964bb9f3b034e69d2f776fe8a557.png"></p>    <p style="text-align:center">Paste_Image.png</p>    <p>实际上是Scheduler里 的一个静态抽象类,实现了Subscription接口,因此也就有unSubscriber方法。</p>    <p>可以取消订阅,但是Worker并没有实现取消订阅方法,而是交给子类去实现,比如这里的HandlerWorker就实现了Worker抽象类,下面是截取的核心部分:</p>    <p style="text-align:center"><img src="https://simg.open-open.com/show/b6f6e3767cbc503c6625780c2db10166.png"></p>    <p style="text-align:center">Paste_Image.png</p>    <p>HandlerWorker实现了schedule方法,一个是有延时的,一个是无延时的。 从代码看首先判断了是否被取消订阅了, 取消了则直接返回,不做任何处理,否者接着走。</p>    <p>哎呦喂! 哎呦喂! 这不是RxAndroidSchedulersHook 里的那个我们之前放着的方法吗?</p>    <p>在这里被调用了。</p>    <p>接着走这里又跳出来个ScheduledAction, 贴出代码!</p>    <p style="text-align:center"><img src="https://simg.open-open.com/show/d42b7cb137a7ce68eac9e6dbe7b0e16a.png"></p>    <p style="text-align:center">Paste_Image.png</p>    <p style="text-align:center"><img src="https://simg.open-open.com/show/2477872ff130fc185577ef73f1f0ad03.png"></p>    <p style="text-align:center">Paste_Image.png</p>    <p>从代码中不难看出, 在LooperScheduler 中创建的handler, 交给HandlerWorker后又交给了ScheduledAction。 该类实现了Runnable 接口,run方法里面调用了action.call() ;看来这里才是真正调用的地方,然后如果发生异常就调用RxjavaPlugin 触发错误处理。</p>    <p>ScheduledAction同样实现了Subscription接口, 取消也很简单,handler removeCallbacks(this).。</p>    <p>看完了ScheduledAction是不是感觉一目了然了,接着上面HandlerWorker的schedule方法讲,</p>    <p>后面从Message池中获取了一个Message并且把message的Callback参数设置为ScheduledAction的实例, 然后后面handler.sendMessageDelayed(message, unit.toMillis(delayTime)); 延时发送这条消息。 看到这你应该明白了,就是利用handler把消息发送到了looper所在的线程! 因此你传递进去的Looper绑定在什么线程, 我们的action(订阅者)就在哪个线程执行!</p>    <p>而我们平时都是使用AndroidScheduler.mainThread(); 默认传递的就是UI线程的Looper!</p>    <p>有的小伙伴说,不对吧,我没看到接收处理消息的地方啊! 楼主你个坑!</p>    <p>实际上这就是handler你了解的不够细:</p>    <pre>  <code class="language-java">(Handler.java)</code></pre>    <p style="text-align:center"><img src="https://simg.open-open.com/show/6031b6f098814074f5fe690d38cb85c1.png"></p>    <p style="text-align:center">Paste_Image.png</p>    <p>看到了吗? 这里是handler接收到Looper分配的消息的处理, 先是判断了msg有没有callback, 有的话就不会调用handleMessage(msg)了,而是调用了handlerCallback(msg); 从而调用了runnable的run方法,也就是ScheduledAction的run()方法.</p>    <p style="text-align:center"><img src="https://simg.open-open.com/show/ee1e34f29e61cc055fbbc9c779905c47.png"></p>    <p style="text-align:center">Paste_Image.png</p>    <p>RxAndroid中还有一个类没讲 MainThreadSubscription, 下篇文章会讲下RxBinding,里面会讲到,这里就不多说了。</p>    <h3> </h3>    <p> </p>    <p>来自:http://www.jianshu.com/p/8292ea39c38e</p>    <p> </p>    
 本文由用户 mynk3578 自行上传分享,仅供网友学习交流。所有权归原作者,若您的权利被侵害,请联系管理员。
 转载本站原创文章,请注明出处,并保留原始链接、图片水印。
 本站是一个以用户分享为主的开源技术平台,欢迎各类分享!
 本文地址:https://www.open-open.com/lib/view/open1480474237462.html
RxAndroid RxJava Android开发 移动开发