diff --git a/business/jxstore/event/event.go b/business/jxstore/event/event.go index 1530904d8..e7a751a7c 100644 --- a/business/jxstore/event/event.go +++ b/business/jxstore/event/event.go @@ -120,14 +120,10 @@ func ImMessage(userID string, ws *websocket.Conn) (err error) { err := ws.ReadJSON(&s) if err != nil { globals.SugarLogger.Debugf("页面可能断开啦 ws.ReadJSON error: %v", err.Error()) - wsClient.s.RLock() for k, _ := range wsClient.Clients { delete(wsClient.Clients[k], userID) } - wsClient.s.RUnlock() - wsClient.s.Lock() delete(wsClient.ClientsHeart, userID) - wsClient.s.Unlock() // delete(clients, ws) //删除map中的客户端 break //结束循环 } else { diff --git a/business/model/message.go b/business/model/message.go index c3996d747..0f5e2994b 100644 --- a/business/model/message.go +++ b/business/model/message.go @@ -63,7 +63,7 @@ type ImMessageRecord struct { GroupID int `orm:"column(group_id)" json:"groupID"` //组ID Content string `orm:"type(text)" json:"content"` //消息内容 MessageType int `json:"messageType"` //消息类型,1文字,2图片,3音频 - Seq int `json:"seq"` + Seq int64 `json:"seq"` Weight int `json:"weight"` Height int `json:"height"` AudioLength string `json:"audioLength"` diff --git a/controllers/event_controller.go b/controllers/event_controller.go index 20a94abd6..ed895d7ef 100644 --- a/controllers/event_controller.go +++ b/controllers/event_controller.go @@ -75,8 +75,8 @@ func (c *EventController) TestWebsocket() { } globals.SugarLogger.Debugf("TestWebsocket connection...") } - event.ImMessage(userID, ws) c.EnableRender = false //Beego不启用渲染 + event.ImMessage(userID, ws) } // @Title 查询聊天记录