在APP中,我們經常會需要一個廣播機制,用以跨頁面事件通知,比如一個需要登錄的APP中,頁面會關注用戶登錄或注銷事件,來進行一些狀態更新。這時候,一個事件總線便會非常有用,事件總線通常實現了訂閱者模式,訂閱者模式包含發布者和訂閱者兩種角色,可以通過事件總線來觸發事件和監聽事件,本節我們實現一個簡單的全局事件總線,我們使用單例模式,代碼如下:
//訂閱者回調簽名 typedef void EventCallback(arg); class EventBus { //私有構造函數 EventBus._internal(); //保存單例 static EventBus _singleton = new EventBus._internal(); //工廠構造函數 factory EventBus()=> _singleton; //保存事件訂閱者隊列,key:事件名(id),value: 對應事件的訂閱者隊列 var _emap = new Map<Object, List<EventCallback>>(); //添加訂閱者 void on(eventName, EventCallback f) { if (eventName == null || f == null) return; _emap[eventName] ??= new List<EventCallback>(); _emap[eventName].add(f); } //移除訂閱者 void off(eventName, [EventCallback f]) { var list = _emap[eventName]; if (eventName == null || list == null) return; if (f == null) { _emap[eventName] = null; } else { list.remove(f); } } //觸發事件,事件觸發后該事件所有訂閱者會被調用 void emit(eventName, [arg]) { var list = _emap[eventName]; if (list == null) return; int len = list.length - 1; //反向遍歷,防止在訂閱者在回調中移除自身帶來的下標錯位 for (var i = len; i > -1; --i) { list[i](arg); } } } //定義一個top-level變量,頁面引入該文件后可以直接使用bus var bus = new EventBus();
使用
//頁面A中 ... //監聽登錄事件 —— 寫在監聽事件里
@override void initState() { super.initState(); //監聽登錄事件 bus.on("icon", (arg) { print('我試試'); setState(() { _tabIndex = 2; }); }); }
@override void dispose() { super.dispose(); bus.off("icon");//移除廣播機制 }
//登錄頁B中 ... //登錄成功后觸發登錄事件,頁面A中訂閱者會被調用 bus.emit("icon", userInfo);
注意:Dart中實現單例模式的標准做法就是使用static變量+工廠構造函數的方式,這樣就可以保證
new EventBus()
始終返回都是同一個實例,讀者應該理解並掌握這種方法。
事件總線通常用於Widget之間狀態共享,但關於Widget之間狀態共享也有一些專門的Package如redux,這和web框架Vue/React是一致的。通常情況下事件總線是足以滿足業務需求的,如果你決定使用redux的話,一定要想清楚業務是否真的有必要用它,防止“化簡為繁”、過度設計。