|
@@ -31,7 +31,8 @@ func (s *ServerSentRouter) Notify() {
|
|
|
sessVal := s.Session().GetMultiple()
|
|
sessVal := s.Session().GetMultiple()
|
|
|
userId := common.ObjToString(sessVal["userId"])
|
|
userId := common.ObjToString(sessVal["userId"])
|
|
|
log.Println("message userId:", userId)
|
|
log.Println("message userId:", userId)
|
|
|
- //userId = s.GetString("userId")
|
|
|
|
|
|
|
+ userId = s.GetString("userId")
|
|
|
|
|
+ log.Println("params userId:", s.GetString("userId"))
|
|
|
if userId != "" {
|
|
if userId != "" {
|
|
|
// 创建用户专属的消息通道
|
|
// 创建用户专属的消息通道
|
|
|
messageChan := make(chan string)
|
|
messageChan := make(chan string)
|
|
@@ -39,7 +40,6 @@ func (s *ServerSentRouter) Notify() {
|
|
|
util.SseClientsMu.Lock()
|
|
util.SseClientsMu.Lock()
|
|
|
util.SseClients[userId] = messageChan
|
|
util.SseClients[userId] = messageChan
|
|
|
util.SseClientsMu.Unlock()
|
|
util.SseClientsMu.Unlock()
|
|
|
-
|
|
|
|
|
// 客户端断开时清理资源
|
|
// 客户端断开时清理资源
|
|
|
defer func() {
|
|
defer func() {
|
|
|
util.SseClientsMu.Lock()
|
|
util.SseClientsMu.Lock()
|
