shkong/go-cqhttp
1
0
Fork 0
mirror of https://github.com/Mrs4s/go-cqhttp.git synced 2025-05-05 11:33:48 +08:00
Code Issues Projects Releases Wiki Activity

Merge branch 'master' of https://github.com/Mrs4s/go-cqhttp

Browse Source
This commit is contained in:
Mrs4s 2020-08-23 01:46:13 +08:00
commit 8fa804a2c9
1 changed files with 11 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
server/websocket.go
View File

@ -324,18 +324,21 @@ func (c *websocketConn) handleRequest(bot *coolq.CQBot, payload []byte) {
func (s *websocketServer) onBotPushEvent(m coolq.MSG) { func (s *websocketServer) onBotPushEvent(m coolq.MSG) {
s.eventConnMutex.Lock() s.eventConnMutex.Lock()
defer s.eventConnMutex.Unlock() defer s.eventConnMutex.Unlock()
pos := 0 for i, l := 0, len(s.eventConn); i < l; i++ {
for _, conn := range s.eventConn { conn := s.eventConn[i]
log.Debugf("向WS客户端 %v 推送Event: %v", conn.RemoteAddr().String(), m.ToJson()) log.Debugf("向WS客户端 %v 推送Event: %v", conn.RemoteAddr().String(), m.ToJson())
err := conn.WriteMessage(websocket.TextMessage, []byte(m.ToJson())) if err := conn.WriteMessage(websocket.TextMessage, []byte(m.ToJson())); err != nil {
if err != nil {
_ = conn.Close() _ = conn.Close()
s.eventConn = append(s.eventConn[:pos], s.eventConn[pos+1:]...) next := i + 1
if pos > 0 { if next >= l {
pos++ next = l - 1
} }
s.eventConn[i], s.eventConn[next] = s.eventConn[next], s.eventConn[i]
s.eventConn = append(s.eventConn[:next], s.eventConn[next+1:]...)
i--
l--
conn = nil
} }
pos++
} }
} }