修复聊天连接建立不正常断开问题
This commit is contained in:
parent
77401657f5
commit
e7107660d6
|
|
@ -209,10 +209,6 @@ func SRMessage(c *gin.Context) {
|
||||||
err2 := ws.WriteMessage(websocket.TextMessage, res3)
|
err2 := ws.WriteMessage(websocket.TextMessage, res3)
|
||||||
if err2 != nil {
|
if err2 != nil {
|
||||||
worker.SetRedisWithExpire("user_"+id.(string)+"_status", "0", time.Second*120) //设置用户在线状态,1为在线,0为离线,5秒后过期
|
worker.SetRedisWithExpire("user_"+id.(string)+"_status", "0", time.Second*120) //设置用户在线状态,1为在线,0为离线,5秒后过期
|
||||||
clientsMux.Lock()
|
|
||||||
delete(clients, ws)
|
|
||||||
clientsMux.Unlock()
|
|
||||||
break
|
|
||||||
} else {
|
} else {
|
||||||
worker.SetRedisWithExpire("user_"+id.(string)+"_status", "1", time.Second*5) //设置用户在线状态,1为在线,0为离线,5秒后过期
|
worker.SetRedisWithExpire("user_"+id.(string)+"_status", "1", time.Second*5) //设置用户在线状态,1为在线,0为离线,5秒后过期
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue