From: qydysky Date: Sun, 10 Mar 2024 09:43:26 +0000 (+0800) Subject: 1 X-Git-Tag: v0.28.20240310094912 X-Git-Url: http://127.0.0.1:8081/?a=commitdiff_plain;h=8ba24c1d102caa18143b59060aeaece03db53bea;p=part%2F.git 1 --- diff --git a/websocket/Server.go b/websocket/Server.go index a838332..8d7b99a 100644 --- a/websocket/Server.go +++ b/websocket/Server.go @@ -37,15 +37,15 @@ func New_server() *Server { func (t *Server) WS(w http.ResponseWriter, r *http.Request) (o chan uintptr) { upgrader := websocket.Upgrader{} + o = make(chan uintptr, 1) + ws, err := upgrader.Upgrade(w, r, nil) if err != nil { - w.WriteHeader(http.StatusBadRequest) + close(o) t.ws_mq.Push_tag(`error`, err) return } - o = make(chan uintptr, 1) - //从池中获取本会话id User := t.userpool.Get()