Cocos Creator之消息分發(fā)
本篇開(kāi)始介紹游戲業(yè)務(wù)架構(gòu)相關(guān)的內(nèi)容。在游戲業(yè)務(wù)層，所有需要隔離的系統(tǒng)和模塊間通信都可以通過(guò)消息分發(fā)解耦。例如網(wǎng)絡(luò)返回通知、數(shù)據(jù)更新同步到界面等。
消息分發(fā)基于觀(guān)察者模式設(shè)計(jì)。需要處理消息的地方向消息中心注冊(cè)監(jiān)聽(tīng)回調(diào)，派發(fā)消息時(shí)，調(diào)用消息中心的派發(fā)接口遍歷該消息的監(jiān)聽(tīng)隊(duì)列，調(diào)用對(duì)應(yīng)的回調(diào)方法。
先定義監(jiān)聽(tīng)回調(diào)類(lèi)型
/**
* 消息監(jiān)聽(tīng)回調(diào)方法
*/
export type NotifyListener = (src: any, data: any) => void;
通過(guò)key-value方式保存監(jiān)聽(tīng)隊(duì)列
1private static msg2listDict: Dictionary< string, Array > = new Dictionary< string, Array<NotifyListenerInfo> >();
接口定義
/**
* 添加多次監(jiān)聽(tīng)者，需要手動(dòng)移除
* @param msg
* @param listener
* @param target
*/
public static addListener(msg: string, listener: NotifyListener, target?: any): void {}
/**
* 添加單次監(jiān)聽(tīng)者，事件觸發(fā)后即移除
* @param msg
* @param listener
* @param target
*/
public static addOnceListener(msg: string, listener: NotifyListener, target?: any): void {}
/**
* 移除指定消息指定的監(jiān)聽(tīng)者
* @param msg
* @param listener
*/
public static removeMsgListener(msg: string, listener: NotifyListener): void {}
/**
* 移除指定消息所有監(jiān)聽(tīng)者
* @param msg
*/
public static removeMsgAllListeners(msg: string): void {}
/**
* 移除指定目標(biāo)對(duì)指定消息的監(jiān)聽(tīng)
* @param msg
* @param target
*/
public static removeTargetMsgListen(msg: string, target: any): void {}
/**
* 移除指定目標(biāo)所有消息監(jiān)聽(tīng)
* @param target
*/
public static removeTargetAllMsgListen(target: any): void {}
/**
* 派發(fā)消息
* @param msg
* @param src
* @param data
*/
public static notify(msg: string, src: any, data: any): void {}
在添加移除實(shí)現(xiàn)中，需要注意某消息可能正在派發(fā)。
對(duì)于一個(gè)消息新添加的監(jiān)聽(tīng)者，應(yīng)該在當(dāng)前隊(duì)列消息派發(fā)完后再派發(fā)，因此，添加一個(gè)待添加隊(duì)列
1private static listener2add: Array<NotifyListenerInfo> = [];
在添加監(jiān)聽(tīng)者時(shí)做以下判斷
// 該消息正在派發(fā)，放入待添加隊(duì)列
if (NotifyCenter.notifyMsgs.indexOf(msg) >= 0) {
NotifyCenter.listener2add.push(info);
return;
}
同樣在移除監(jiān)聽(tīng)者時(shí)，可能正在派發(fā)消息，避免對(duì)隊(duì)列的修改導(dǎo)致for循環(huán)異常，添加一個(gè)待移除隊(duì)列，派發(fā)消息時(shí)，如果該監(jiān)聽(tīng)者在移除隊(duì)列則不派發(fā)。在消息派發(fā)完后再將其移出隊(duì)列
1private static listener2remove: Array<NotifyListenerInfo> = [];
在移除監(jiān)聽(tīng)者時(shí)做以下判斷
// 該消息正在派發(fā)，放入待移除隊(duì)列
if (NotifyCenter.notifyMsgs.indexOf(msg) >= 0) {
NotifyCenter.listener2remove.push(list[i]);
} else {
list.splice(i, 1);
}
派發(fā)消息時(shí)遍歷指定消息下的隊(duì)列
// 隊(duì)列不存在，不需要處理
let list = NotifyCenter.msg2listDict.get(msg);
if (!list) {
return;
}
// 標(biāo)記消息正在派發(fā)，多個(gè)消息可能同時(shí)在派發(fā)，同一消息可能標(biāo)記多次
NotifyCenter.notifyMsgs.push(msg);
// 處理消息派發(fā)
for (let i = 0, n = list.length; i < n; i++) {
NotifyCenter._dispatch(list[i], src, data, false);
}
派發(fā)消息時(shí)先判斷是否在移除隊(duì)列
// 在移除隊(duì)列，不派發(fā)
if (NotifyCenter.listener2remove.indexOf(info) >= 0) {
return;
}
當(dāng)前隊(duì)列派發(fā)完后檢查待添加隊(duì)列
// 處理待添加隊(duì)列派發(fā)
for (let i = 0, n = msg2add.length; i < n; i++) {
if (listener2add[i].msg == msg) {
NotifyCenter._dispatch(listener2add[i], src, data, true);
}
}
引入消息分發(fā)中心，隔離的系統(tǒng)、模塊間通過(guò)消息監(jiān)聽(tīng)和派發(fā)通信，避免互相引用耦合。
更多資源請(qǐng)點(diǎn)擊：https://bycwedu.vipwan.cn/promotion_channels/630597732
