diff --git a/controllers/event.go b/controllers/event.go index abecea9fe..f9d4cf433 100644 --- a/controllers/event.go +++ b/controllers/event.go @@ -132,13 +132,9 @@ func (c *EventController) TestWebsocket() { //将当前客户端放入map中 clients[ws] = true - m := &model.ImMessageRecord{} - //把消息 写入通道 - broadcast <- m - c.EnableRender = false //Beego不启用渲染 - var s model.ImMessageRecord + var s *model.ImMessageRecord for { //接收客户端的消息 err := ws.ReadJSON(&s) @@ -147,6 +143,8 @@ func (c *EventController) TestWebsocket() { delete(clients, ws) //删除map中的客户端 break //结束循环 } else { + //把消息 写入通道 + broadcast <- s //接受消息 业务逻辑 db := dao.GetDB() dao.WrapAddIDCULDEntity(&s, "")