aa
This commit is contained in:
@@ -165,12 +165,14 @@ func handleMessages() {
|
||||
msg := <-broadcast
|
||||
if msg.GroupID == 0 {
|
||||
globals.SugarLogger.Debugf("heart %v", utils.Format4Output(msg, false))
|
||||
if err := clientsHeart[msg.UserID].WriteJSON(&model.ImMessageRecord{
|
||||
Key: "pang",
|
||||
}); err != nil {
|
||||
globals.SugarLogger.Debugf("heart client.WriteJSON error: %v", err)
|
||||
clientsHeart[msg.UserID].Close() //关闭
|
||||
delete(clientsHeart, msg.UserID)
|
||||
if clientsHeart[msg.UserID] != nil {
|
||||
if err := clientsHeart[msg.UserID].WriteJSON(&model.ImMessageRecord{
|
||||
Key: "pang",
|
||||
}); err != nil {
|
||||
globals.SugarLogger.Debugf("heart client.WriteJSON error: %v", err)
|
||||
clientsHeart[msg.UserID].Close() //关闭
|
||||
delete(clientsHeart, msg.UserID)
|
||||
}
|
||||
}
|
||||
} else {
|
||||
globals.SugarLogger.Debugf("clients len %v", len(clients))
|
||||
|
||||
Reference in New Issue
Block a user