diff --git a/business/jxstore/event/event.go b/business/jxstore/event/event.go index e7a751a7c..499a872bc 100644 --- a/business/jxstore/event/event.go +++ b/business/jxstore/event/event.go @@ -169,6 +169,7 @@ func ImMessage(userID string, ws *websocket.Conn) (err error) { }) } } + ws.Close() return err } diff --git a/controllers/event_controller.go b/controllers/event_controller.go index ed895d7ef..54e7e1339 100644 --- a/controllers/event_controller.go +++ b/controllers/event_controller.go @@ -57,7 +57,6 @@ func (c *EventController) TestWebsocket() { if err != nil { log.Fatal(err) } - defer ws.Close() var ( userID = c.GetString("userID") ) @@ -76,7 +75,7 @@ func (c *EventController) TestWebsocket() { globals.SugarLogger.Debugf("TestWebsocket connection...") } c.EnableRender = false //Beego不启用渲染 - event.ImMessage(userID, ws) + go event.ImMessage(userID, ws) } // @Title 查询聊天记录