掘金连接 (https://badge.juejin.im/entry/5b6ebc17518825195f49c4ad/likes.svg?style=flat-square)
Android开发,个人使用框架基于LiveData+ViewModel<-Respontory构建项目架构，没引入RxJava（小项目没必要引入）
个人GitHub地址 本人喜欢新都技术，但是博客文章组织写的很懒，还请谅解。欢迎留言
我的开发库整合AndriodDevelopLibrary，欢迎Start、Fork,帮你快速开发一个项目
LiveDataEventBus 源码实现，功能简洁易懂，自己可以随意定制
</br>
基于LiveData的事件总线LiveDataEventBus优点总结
- LiveData 的支持2中注册监听，非常适合Android刷新机制。无序手动解除注册，无内存泄漏问题
- observe模式，拥有声明周期，在界面可见的时候才会触发回调，保证UI更新的是最新数据。
- observeForever该模式就是一直监听,只要数据源变化都会回调，无生命周期。跟EventBus和RxBus一样
LiveDataEventBus代码实现
/**
* Created by sdl on 2018/8/8.
*/
public class LiveDataEventBus {
private final Map<String, BusLiveData<Object>> mCacheBus;
private LiveDataEventBus() {
mCacheBus = new ArrayMap<>();
}
private static class SingletonHolder {
private static final LiveDataEventBus DEFAULT_BUS = new LiveDataEventBus();
}
private static LiveDataEventBus get() {
return SingletonHolder.DEFAULT_BUS;
}
public static MutableLiveData<Object> with(@Nullable String key) {
return get().withInfo(key, Object.class, false);
}
public static <T> MutableLiveData<T> with(@Nullable String key, Class<T> type) {
return get().withInfo(key, type, false);
}
public static <T> MutableLiveData<T> with(@Nullable String key, Class<T> type, boolean needCurrentDataWhenNewObserve) {
return get().withInfo(key, type, needCurrentDataWhenNewObserve);
}
private <T> MutableLiveData<T> withInfo(String key, Class<T> type, boolean needData) {
if (!mCacheBus.containsKey(key)) {
mCacheBus.put(key, new BusLiveData<>(key));
}
BusLiveData<Object> data = mCacheBus.get(key);
data.mNeedCurrentDataWhenFirstObserve = needData;
return (MutableLiveData<T>) mCacheBus.get(key);
}
private static class BusLiveData<T> extends MutableLiveData<T> {
// 比如BusLiveData 在添加 observe的时候，同一个界面对应的一个事件只能注册一次
// 自己添加逻辑定制
private String mEventType;
//首次注册的时候，是否需要当前LiveData 最新数据
private boolean mNeedCurrentDataWhenFirstObserve;
private BusLiveData(String eventType) {
this.mEventType = eventType;
}
//主动触发数据更新事件才通知所有Observer
private boolean mIsStartChangeData = false;
@Override
public void setValue(T value) {
mIsStartChangeData = true;
super.setValue(value);
}
@Override
public void postValue(T value) {
mIsStartChangeData = true;
super.postValue(value);
}
//添加注册对应事件type的监听
@Override
public void observe(@NonNull LifecycleOwner owner, @NonNull Observer<T> observer) {
super.observe(owner, new ObserverWrapper<>(observer, this));
}
//数据更新一直通知刷新
@Override
public void observeForever(@NonNull Observer<T> observer) {
super.observeForever(observer);
}
@Override
public void removeObserver(@NonNull Observer<T> observer) {
super.removeObserver(observer);
}
}
private static class ObserverWrapper<T> implements Observer<T> {
private Observer<T> observer;
private BusLiveData<T> liveData;
private ObserverWrapper(Observer<T> observer, BusLiveData<T> liveData) {
this.observer = observer;
this.liveData = liveData;
//mIsStartChangeData 可过滤掉liveData首次创建监听，之前的遗留的值
liveData.mIsStartChangeData = liveData.mNeedCurrentDataWhenFirstObserve;
}
@Override
public void onChanged(@Nullable T t) {
if (liveData.mIsStartChangeData) {
if (observer != null) {
observer.onChanged(t);
}
}
}
}
}
observe模式使用 （基于Kotlin写的Demo）
- 第一步，在Activity中注册观察者
//注册2个，2个会按顺序触发（自己控制下，也可以修改内部实现来控制，自己定制）
LiveDataEventBus.with("change", String::class.java)
.observe(this, Observer {
Logger.e("observe change 1->$it")
})
LiveDataEventBus.with("change", String::class.java)
.observe(this, Observer {
Logger.e("observe change 2->$it")
})
- 第二步，在当前或者其他界面发送事件 change 用法跟RxBus类似。
LiveDataEventBus.with("change").value = ("change->$index")
- 总结：“change” 字符串，任意定义，表示某一个操作，所有注册的Observer都会在界面可见的时候接受到最新的value对象,
observeForever模式使用 （基于Kotlin写的Demo）
- 第一步，在任意地方中添加某个常驻操作
LiveDataEventBus.with("change_forever", String::class.java)
.observeForever {
Logger.e("change_forever change->$it")
ToastUtils.showShort("change_forever->$it")
}
- 第二步，在任意地方发送事件 change_forever ，注册的observeForever对象都会立即收到最新value对象
LiveDataEventBus.with("change_forever").value = ("change_forever->$index")
LiveDataEventBus 使用总结
- 根据场景使用上述2中模式，绝大多数都是Observe模式，某些场景用observeForever
- 注意触发value变化时候调用的方法。主线程用setValue(T)效率最快，子线程用postValue(T)
- LiveData默认情况下，给同一个LiveData注册Observe时候，都会收到一次最新值，LiveDataEventBus通过标志位来过滤第一次注册时候的回调。
- 在用的过程中，推荐客户端在维护一个共有的事件类来管理。主动避免多次添加相同操作的Observe，相同操作无意义或者自己定制注册部分代码=.=
</br>
最后感谢美团的技术团队提出的技术点，原技术文章通过反射来控制首次注册的值派发。上述对技术进行优化，重新定制基础功能 </br>
美团原文技术链接
