消息总线

assembly/base/service/msg_bus.go

@@ -6,6 +6,7 @@ import (
 	"sync"
 )
 
+// 监听列表， key: userId
 var msgBusDataMap = map[int]chan model.Msg{}
 var msgBusDataMapMu = sync.Mutex{}