diff --git a/server/websocket.go b/server/websocket.go index e415ff2..4e9fe04 100644 --- a/server/websocket.go +++ b/server/websocket.go @@ -313,6 +313,7 @@ func (s *webSocketServer) any(w http.ResponseWriter, r *http.Request) { func (s *webSocketServer) listenAPI(c *wsConn) { defer func() { _ = c.Close(websocket.StatusNormalClosure, "") }() + c.Conn.SetReadLimit(1024 * 1024 * 128) for { buffer := global.NewBuffer() t, reader, err := c.Reader(context.Background())