statbate/supreme-disco
1
0
Fork 0
mirror of https://github.com/statbate/supreme-disco.git synced 2026-08-11 03:22:41 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Update websocket.go

Browse source
This commit is contained in:
poiuty 2023-06-09 14:57:43 +03:00
parent 89f19d68cc
commit 2ab97d2d10
1 changed files with 6 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

11
server/websocket.go
View file

@ -36,13 +36,13 @@ var (
json = jsoniter.ConfigCompatibleWithStandardLibrary json = jsoniter.ConfigCompatibleWithStandardLibrary
ws = struct { ws = struct {
Count chan int //Count chan int
Add chan *websocket.Conn Add chan *websocket.Conn
Del chan *websocket.Conn Del chan *websocket.Conn
Send chan wsMessage Send chan wsMessage
Enter chan enterChanel Enter chan enterChanel
}{ }{
Count: make(chan int, 100), //Count: make(chan int, 100),
Add: make(chan *websocket.Conn, 100), Add: make(chan *websocket.Conn, 100),
Del: make(chan *websocket.Conn, 100), Del: make(chan *websocket.Conn, 100),
Send: make(chan wsMessage, 100), Send: make(chan wsMessage, 100),
@ -60,8 +60,8 @@ func broadcast() {
case conn := <-ws.Del: case conn := <-ws.Del:
delete(wsClients, conn) delete(wsClients, conn)
case <-ws.Count: //case <-ws.Count:
ws.Count <- len(wsClients) // ws.Count <- len(wsClients)
case r := <-ws.Enter: case r := <-ws.Enter:
wsClients[r.Conn] = r.Chanel wsClients[r.Conn] = r.Chanel
@ -70,6 +70,7 @@ func broadcast() {
sendMessage(r.Message, r.Decode) sendMessage(r.Message, r.Decode)
case <-ticker.C: case <-ticker.C:
fmt.Println("WebSocket:", len(wsClients))
sendMessage([]byte("ping"), false) sendMessage([]byte("ping"), false)
} }
} }
@ -90,7 +91,7 @@ func sendMessage(message []byte, decode bool) {
} }
} }
fmt.Println(string(message), decode, chanel) //fmt.Println(string(message), decode, chanel)
for conn, ch := range wsClients { for conn, ch := range wsClients {
if decode && ch != chanel { if decode && ch != chanel {