diff --git a/controllers/event.go b/controllers/event.go index 337c161cb..1c0e6ccdc 100644 --- a/controllers/event.go +++ b/controllers/event.go @@ -6,6 +6,8 @@ import ( "net/http" "time" + "git.rosy.net.cn/jx-callback/business/model" + "github.com/gorilla/websocket" "git.rosy.net.cn/baseapi/utils" @@ -25,7 +27,7 @@ type EventController struct { var clients = make(map[*websocket.Conn]bool) //广播频道(通道) -var broadcast = make(chan Message) +var broadcast = make(chan *model.ImMessageRecord) // 配置升级程序(升级为websocket) var upgrader = websocket.Upgrader{} @@ -127,15 +129,13 @@ func (c *EventController) TestWebsocket() { //将当前客户端放入map中 clients[ws] = true - m := Message{ - Data: 0, - } + m := &model.ImMessageRecord{} //把消息 写入通道 broadcast <- m c.EnableRender = false //Beego不启用渲染 - var s Message + var s model.ImMessageRecord for { //接收客户端的消息 err := ws.ReadJSON(&s)