事件总线 - 人间烟火的日常

太久没坚持学习，已经被俊给批评了，现在重操旧业。

在一个App中，我们经常需要一个类似广播的东西来在各个模块之间发布通知或者通知更新状态

这个就是事件总线，通常它实现了订阅者模式（包含发布者和订阅者），可以通过事件总线来触发事件和监听事件

下面实现一个简单的全局事件总线，我们使用单列模式（dart语言中，私有化可以使用”_”作名称前缀）来实现

Dart中实现单例模式的标准做法就是使用static变量+工厂构造函数的方式，这样就可以保证EventBus()始终返回都是同一个实例，读者应该理解并掌握这种方法

//订阅者回调签名
typedef void Eventcallback(arg);

//私有构造函数
class EventBus{
 EventBus._internal();
 }

//单列模式
static EventBus _singleton = EventBus._internal();

//工厂构造函数
factory EventBus(){
 reture _singleton;
}
//保存事件订阅者队列，key:事件名(id)，value: 对应事件的订阅者队列
final _emap = Map<Object,List<EventCallback>?>();
//添加订阅者
void on(eventName,EventCallback callback){
 _emap[eventName] ??= <EventCallback>[];
 _emap[eventName]!.add(callback);
}
//移除订阅者
void off(eventName, [EventCallback? callback]){
 var list = _emap[eventName];
 if(eventName == null || list == null) reture ;
 if(callback == null){
  _emap[eventName] = null;
 }else{
  list.remove(callback);
 }
}
//触发事件，事件触发后该事件所有订阅者会被调用
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 = EventBus();

使用示例：

页面A：

//Page A
bus.on("login",(arg)){
 //do something
}

页面B：

//Page B

//login success
bus.emit("login",userInfo);

说明：事件总线通常用于组件之间的状态共享，但关于组件之间的状态共享也有一些专门的包如：redux、mobx、Provider。
对于一些简单的应用，事件总线足以满足业务需求的，如果你决定使用状态管理包的话，一定要想清楚您的App是否真的需要使用它
防止“化简为繁”、过度设计。