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

fix(server): panic on multi ws server.

Browse Source
This commit is contained in:
wdvxdr 2021-07-09 22:45:30 +08:00
parent e768ff0dc2
commit ccc344ab1c
No known key found for this signature in database
GPG Key ID: 55FF1414A69CEBA6
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
server/websocket.go
View File

@ -70,12 +70,13 @@ func RunWebSocketServer(b *coolq.CQBot, conf *config.WebsocketServer) {
s.handshake = fmt.Sprintf(`{"_post_method":2,"meta_event_type":"lifecycle","post_type":"meta_event","self_id":%d,"sub_type":"connect","time":%d}`, s.handshake = fmt.Sprintf(`{"_post_method":2,"meta_event_type":"lifecycle","post_type":"meta_event","self_id":%d,"sub_type":"connect","time":%d}`,
b.Client.Uin, time.Now().Unix()) b.Client.Uin, time.Now().Unix())
b.OnEventPush(s.onBotPushEvent) b.OnEventPush(s.onBotPushEvent)
http.HandleFunc("/event", s.event) mux := http.ServeMux{}
http.HandleFunc("/api", s.api) mux.HandleFunc("/event", s.event)
http.HandleFunc("/", s.any) mux.HandleFunc("/api", s.api)
mux.HandleFunc("/", s.any)
go func() { go func() {
log.Infof("CQ WebSocket 服务器已启动: %v", addr) log.Infof("CQ WebSocket 服务器已启动: %v", addr)
log.Fatal(http.ListenAndServe(addr, nil)) log.Fatal(http.ListenAndServe(addr, &mux))
}() }()
} }