|
@@ -31,8 +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")
|
|
|
|
|
- log.Println("params 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)
|
