tcjlj/nezha
1
0
Fork 0
mirror of https://github.com/nezhahq/nezha.git synced 2025-01-22 20:58:14 -05:00
Code Issues Actions Packages Projects Releases Wiki Activity

增加WebSocket的ping包

Browse Source
This commit is contained in:
Erope 2021-04-04 00:22:50 +08:00
parent 1fa9fb0b48
commit ab9dfbc578
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
cmd/dashboard/controller/common_page.go
View File

@ -185,6 +185,7 @@ func (cp *commonPage) ws(c *gin.Context) {
return return
} }
defer conn.Close() defer conn.Close()
count := 0
for { for {
dao.SortedServerLock.RLock() dao.SortedServerLock.RLock()
err = conn.WriteJSON(dao.SortedServerList) err = conn.WriteJSON(dao.SortedServerList)
@ -192,6 +193,10 @@ func (cp *commonPage) ws(c *gin.Context) {
if err != nil { if err != nil {
break break
} }
count += 1
if count%4 == 0 {
conn.WriteMessage(websocket.PingMessage, []byte{})
}
time.Sleep(time.Second * 2) time.Sleep(time.Second * 2)
} }
} }