From dcdd41feaae33c6410faeba1fd856636474797f8 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=8B=8F=E5=B0=B9=E5=B2=9A?= <770236076@qq.com> Date: Thu, 20 Aug 2020 11:38:28 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AE=8C=E5=96=84ws?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- controllers/event.go | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) 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, "")