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