diff --git a/handler/im.go b/handler/im.go index d4552f9..0afec6b 100644 --- a/handler/im.go +++ b/handler/im.go @@ -209,10 +209,6 @@ func SRMessage(c *gin.Context) { err2 := ws.WriteMessage(websocket.TextMessage, res3) if err2 != nil { worker.SetRedisWithExpire("user_"+id.(string)+"_status", "0", time.Second*120) //设置用户在线状态,1为在线,0为离线,5秒后过期 - clientsMux.Lock() - delete(clients, ws) - clientsMux.Unlock() - break } else { worker.SetRedisWithExpire("user_"+id.(string)+"_status", "1", time.Second*5) //设置用户在线状态,1为在线,0为离线,5秒后过期 }