該Bus實(shí)際上是參考了網(wǎng)上資料和相關(guān)視頻而實(shí)現(xiàn)的，【如有雷同，絕對(duì)不是巧合】，同時(shí)也感謝晚上各種提供資料的廣大程序猿們，有興趣的可以自己也寫(xiě)一個(gè)，簡(jiǎn)單好用：
jetpact包中提供的LiveData實(shí)際上就已經(jīng)包含了觀察者模式以及對(duì)應(yīng)的LifeOwner對(duì)于觀察者的管理，官方維護(hù)絕對(duì)精品，質(zhì)量有保障，所以我們要做的實(shí)際上就是簡(jiǎn)答的封裝而已（站在巨人的肩膀上可以摔得更有范兒）：
日常我們正常使用LiveData的姿勢(shì)是這樣的：
final TextView txv_msg = findViewById(R.id.txv_msg);
final MediatorLiveData<String> test = new MediatorLiveData<>();
/*--------------------重點(diǎn)在這里--------------------*/
test.observe(this, new Observer<String>() {
@Override
public void onChanged(@Nullable String s) {
Log.d("LiveData","msg:"+s);
txv_msg.setText(s);
}
});
/*-----------------------------------------------*/
//模擬正常調(diào)用
test.setValue("test");
//模擬調(diào)用
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重點(diǎn)部分都統(tǒng)一起來(lái)寫(xiě)個(gè)BUS管理，豈不是就完成了一個(gè)自己需要的EvntBUS工具了么，而且這個(gè)bus還是跟著頁(yè)面生命周期走的，如果頁(yè)面銷毀，觀察者自動(dòng)就被回收了，我們什么都不用擔(dān)心，因?yàn)間oogle已經(jīng)給我們做好了，我們只不過(guò)是上來(lái)蹭一波封裝的功能而已：
public class LiveDataBus_Ver1 {
private final Map<String, MutableLiveData<Object>> bus;
private LiveDataBus_Ver1(){
bus = new HashMap<>();
}
private static class SingletonHolder {
/***單例對(duì)象實(shí)例*/
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){
//如果不存在，則直接新建一個(gè)LiveData
if(!bus.containsKey(key)){
MutableLiveData<Object> liveData = new MutableLiveData<>();
bus.put(key,liveData);
}
//返回給用戶調(diào)用
return (MutableLiveData<T>) bus.get(key);
}
}
好，上面這個(gè)版本1的LiveDataBus就算完工了，這個(gè)時(shí)候已經(jīng)可以正常使用，實(shí)際上這個(gè)已經(jīng)算是一個(gè)非常完整的LiveDataBus的版本了，是不是很簡(jiǎn)單，使用方法也很簡(jiǎn)單：
pubic class ActivityA{
public void dosomething(){
//調(diào)用Bus對(duì)目標(biāo)“bus1”發(fā)送一條消息
LiveDataBus_Ver1.get()
.with("bus1")
.setValue("send msg 1");
}
}
pubic class ActivityB{
public void dosomething(){
//同樣根據(jù)標(biāo)簽“bus1”獲取發(fā)送過(guò)來(lái)的消息，這個(gè)消息是可以跨頁(yè)面發(fā)送的，所以基本上已經(jīng)跟我們平日里使用的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);
}
});
}
}
現(xiàn)在你可以使用我們自己寫(xiě)好的這個(gè)LiveDataBus正常的在各個(gè)頁(yè)面之間傳送消息了，毫無(wú)鴨梨，而且還真的很好用，效率也不用擔(dān)心，畢竟更下面的實(shí)現(xiàn)都是google幫我們完成的，但是我們?cè)谑褂眠^(guò)程中發(fā)現(xiàn)這么一個(gè)問(wèn)題：
如果我們從ActivityA 跳轉(zhuǎn)到ActivityB之前，我們發(fā)送一條消息，這個(gè)時(shí)候還沒(méi)有打開(kāi)B頁(yè)面，實(shí)際上B頁(yè)面還沒(méi)有建立，但是當(dāng)我們進(jìn)入B頁(yè)面的時(shí)候會(huì)發(fā)覺(jué)，B竟然收到這條消息了，嘿，有人說(shuō)這多好，不久直接實(shí)現(xiàn)了黏性廣播功能了么！驚不驚喜意不意外！hmm，話是這么講沒(méi)錯(cuò)，但是絕大部分時(shí)候我們并不需要這個(gè)功能，這個(gè)時(shí)候怎么辦？
預(yù)知后事如何請(qǐng)聽(tīng)下回分解：
