diff --git a/handler/im.go b/handler/im.go index 8f7fa56..925a9fb 100644 --- a/handler/im.go +++ b/handler/im.go @@ -126,13 +126,13 @@ func subscribeAndHandleIMMessages(ws *websocket.Conn, userId int) { if sessionID == 0 { //创建会话 //会话名字为前10个字符,如果 - var sessionName string - if len(data.Msg) > 10 { - sessionName = data.Msg[:10] - } else { - sessionName = data.Msg - } - err, sessionID = service.CreateSession(userId, sessionName) + //var sessionName string + //if len(data.Msg) > 10 { + // sessionName = data.Msg[:10] + //} else { + // sessionName = data.Msg + //} + err, sessionID = service.CreateSession(userId, data.Msg) log.Println("create session id:", sessionID) if err != nil { log.Println("Create session error:", err) @@ -154,7 +154,7 @@ func subscribeAndHandleIMMessages(ws *websocket.Conn, userId int) { }() go func() { - defer close(done) + //defer close(done) //从redis订阅消息 for m := range ch { msg := m.Payload // 获取消息,消息格式为json @@ -169,6 +169,7 @@ func subscribeAndHandleIMMessages(ws *websocket.Conn, userId int) { } } } + //查看done是否关闭 }() //发送心跳包