1.LiveDataBus

synchronized源码分析

LiveDataBus

synchronized源码分析        LiveDataBus是基于LiveData实现的类似EventBus的消息通信框架，它是基于LiveData实现的，完全可以代替EventBus，RxBus；

synchronized源码分析

        LiveDataBus的主要是基于发布订阅设计模式，发布订阅模式定义了一种 “一对多” 的关系，和观察者模式是完全不同的两个设计模式；

synchronized源码分析

        下面详细介绍核心类LiveData

synchronized源码分析

        LiveData是一个可以被观察的数据holder，并且可以自动感知控件的生命周期，不会发生内存泄漏；

synchronized源码分析

        LiveData需要一个观察者对象，当LiveData的值发生改变时，观察者会察觉到这个改变；

synchronized源码分析

        使用livedata注册观察者监听

synchronized源码分析

        使用livedata发送消息给观察者

synchronized源码分析

        LiveData其实就是一个存放数据的holder，类似ViewHolder的holder，存放在LiveData里的数据会拥有LiveData的特性；

synchronized源码分析

        LiveData是Android Architecture Components的一个类；这个类是谷歌在Google I/O 发布一套帮助开发者解决Android架构设计的方案。这个类有四个核心，后续会一一介绍；

synchronized源码分析

        用第一代LiveDataBus订阅

synchronized源码分析

        发送消息

synchronized源码分析

        至于说他是第一代bus，说明肯定有问题，问题就是在post或者set一个value后，只要在一个frag/act里observe了，无论组件是否启动，都会收到value，即当在act1中post了，在act2中observe，但是post的时候act2没有运行，当启动act2，收到了value。收到了订阅前的消息

synchronized源码分析

        通过查看LiveData的源码发现setValue（）开始，依次调用了

synchronized源码分析

dispatchValue()-> considerNotify()-> observer.onChanged()

synchronized源码分析

        postValue()会调用setValue（）所以同理；

synchronized源码分析

        这就解释了为什么我们可以在observer中收到post来的value，为什么act2不运行也可以收到value；

synchronized源码分析

        我们注意到当observer.mLastVersion >= mVersion的时候会直接return，不调用onChanged从而解决上面的问题。

synchronized源码分析

        我们需要拿到mLastVersion，就需要拿到observer对象，顺着源码发现observer对象存在mObservers的map中；我们自定义一个mutableLiveData，改写他的observe（），在observe（）中，通过反射拿到mObservers对象，从而拿到observer.mLastVersion，将mVersion赋值给他；

synchronized源码分析

        hook的作用相当于 在observe（）调用后执行observer.mLastVersion = mVersion; 让considerNotify（）直接return，可是我们如何收到订阅后的post呢？因为只有订阅的时候才会hook，在hook后，我们调用post（），会mVersion++，所以在判断 if (observer.mLastVersion >= mVersion) 的时候就又会是false了；

synchronized源码分析

synchronized源码分析