LiveDataBus

Posted 2023-02-16

参考技术A

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

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

下面详细介绍核心类LiveData

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

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

使用livedata注册观察者监听

使用livedata发送消息给观察者

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

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

用第一代LiveDataBus订阅

发送消息

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

通过查看LiveData的源码发现setValue（）开始，依次调用了
dispatchValue() -> considerNotify() -> observer.onChanged()

postValue()会调用setValue（）所以同理；
这就解释了为什么我们可以在observer中收到post来的value，为什么act2不运行也可以收到value；
我们注意到当observer.mLastVersion >= mVersion的时候会直接return，不调用onChanged从而解决上面的问题。

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

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