ljydlv
/
saw-go
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修复重复关闭问题，修改会话名称

This commit is contained in:
junleea 2025-03-22 17:56:39 +08:00
parent 8477862e68
commit 08d134ac41
1 changed files with 9 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
handler/im.go
View File

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