完善ws
This commit is contained in:
@@ -30,7 +30,7 @@ type EventController struct {
|
|||||||
var clients = make(map[*websocket.Conn]bool)
|
var clients = make(map[*websocket.Conn]bool)
|
||||||
|
|
||||||
//广播频道(通道)
|
//广播频道(通道)
|
||||||
var broadcast = make(chan model.ImMessageRecord)
|
var broadcast = make(chan *model.ImMessageRecord)
|
||||||
|
|
||||||
// 配置升级程序(升级为websocket)
|
// 配置升级程序(升级为websocket)
|
||||||
var upgrader = websocket.Upgrader{}
|
var upgrader = websocket.Upgrader{}
|
||||||
@@ -132,7 +132,7 @@ func (c *EventController) TestWebsocket() {
|
|||||||
//将当前客户端放入map中
|
//将当前客户端放入map中
|
||||||
clients[ws] = true
|
clients[ws] = true
|
||||||
|
|
||||||
m := model.ImMessageRecord{}
|
m := &model.ImMessageRecord{}
|
||||||
//把消息 写入通道
|
//把消息 写入通道
|
||||||
broadcast <- m
|
broadcast <- m
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user