该Bus实际上是参考了网上资料和相关视频而实现的，【如有雷同，绝对不是巧合】，同时也感谢晚上各种提供资料的广大程序猿们，有兴趣的可以自己也写一个，简单好用：
jetpact包中提供的LiveData实际上就已经包含了观察者模式以及对应的LifeOwner对于观察者的管理，官方维护绝对精品，质量有保障，所以我们要做的实际上就是简答的封装而已（站在巨人的肩膀上可以摔得更有范儿）：
日常我们正常使用LiveData的姿势是这样的：
final TextView txv_msg = findViewById(R.id.txv_msg);
final MediatorLiveData<String> test = new MediatorLiveData<>();
/*--------------------重点在这里--------------------*/
test.observe(this, new Observer<String>() {
@Override
public void onChanged(@Nullable String s) {
Log.d("LiveData","msg:"+s);
txv_msg.setText(s);
}
});
/*-----------------------------------------------*/
//模拟正常调用
test.setValue("test");
//模拟调用
txv_msg.setOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View v) {
txv_msg.post(new Runnable() {
@Override
public void run() {
test.postValue("go go go ");
}
});
}
});
如果我们把observe重点部分都统一起来写个BUS管理，岂不是就完成了一个自己需要的EvntBUS工具了么，而且这个bus还是跟着页面生命周期走的，如果页面销毁，观察者自动就被回收了，我们什么都不用担心，因为google已经给我们做好了，我们只不过是上来蹭一波封装的功能而已：
public class LiveDataBus_Ver1 {
private final Map<String, MutableLiveData<Object>> bus;
private LiveDataBus_Ver1(){
bus = new HashMap<>();
}
private static class SingletonHolder {
/***单例对象实例*/
static final LiveDataBus_Ver1 INSTANCE = new LiveDataBus_Ver1();
}
public static LiveDataBus_Ver1 get() {
return LiveDataBus_Ver1.SingletonHolder.INSTANCE;
}
public MutableLiveData<Object> with(String key){
return with(key, Object.class);
}
public <T> MutableLiveData<T> with(String key, Class<T> clz){
//如果不存在，则直接新建一个LiveData
if(!bus.containsKey(key)){
MutableLiveData<Object> liveData = new MutableLiveData<>();
bus.put(key,liveData);
}
//返回给用户调用
return (MutableLiveData<T>) bus.get(key);
}
}
好，上面这个版本1的LiveDataBus就算完工了，这个时候已经可以正常使用，实际上这个已经算是一个非常完整的LiveDataBus的版本了，是不是很简单，使用方法也很简单：
pubic class ActivityA{
public void dosomething(){
//调用Bus对目标“bus1”发送一条消息
LiveDataBus_Ver1.get()
.with("bus1")
.setValue("send msg 1");
}
}
pubic class ActivityB{
public void dosomething(){
//同样根据标签“bus1”获取发送过来的消息，这个消息是可以跨页面发送的，所以基本上已经跟我们平日里使用的eventbus相同了
LiveDataBus_Ver1.get()
.with("bus1",String.class)
.observe(this, new Observer<String>() {
@Override
public void onChanged(@Nullable String msg) {
LogW.d("LiveDataBus_Ver1"," msg received:"+msg);
}
});
}
}
现在你可以使用我们自己写好的这个LiveDataBus正常的在各个页面之间传送消息了，毫无鸭梨，而且还真的很好用，效率也不用担心，毕竟更下面的实现都是google帮我们完成的，但是我们在使用过程中发现这么一个问题：
如果我们从ActivityA 跳转到ActivityB之前，我们发送一条消息，这个时候还没有打开B页面，实际上B页面还没有建立，但是当我们进入B页面的时候会发觉，B竟然收到这条消息了，嘿，有人说这多好，不久直接实现了黏性广播功能了么！惊不惊喜意不意外！hmm，话是这么讲没错，但是绝大部分时候我们并不需要这个功能，这个时候怎么办？
预知后事如何请听下回分解：
