完善ws
This commit is contained in:
@@ -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, "")
|
||||
|
||||
Reference in New Issue
Block a user