aa

business/jxstore/event/event.go

@@ -169,6 +169,7 @@ func ImMessage(userID string, ws *websocket.Conn) (err error) {
 			})
 		}
 	}
+	ws.Close()
 	return err
 }
 

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 查询聊天记录