a
This commit is contained in:
@@ -42,8 +42,8 @@ var heartbit = make(chan *Message)
|
||||
var upgrader = websocket.Upgrader{}
|
||||
|
||||
type Message struct {
|
||||
UserID string `json:"userID"`
|
||||
Data interface{} `json:"data"`
|
||||
UserID string `json:"userID"`
|
||||
Data string `json:"data"`
|
||||
}
|
||||
|
||||
// @Title 测试websocket
|
||||
@@ -174,6 +174,7 @@ func handleMessages() {
|
||||
}
|
||||
}
|
||||
case h := <-heartbit:
|
||||
globals.SugarLogger.Debugf("h %v", utils.Format4Output(h, false))
|
||||
if err := heartClients[h.UserID].WriteJSON(&Message{
|
||||
Data: "pang",
|
||||
}); err != nil {
|
||||
|
||||
Reference in New Issue
Block a user