diff --git a/server/websocket/internal/logic/datatransferlogic.go b/server/websocket/internal/logic/datatransferlogic.go index e2be99e8..b1a942c5 100644 --- a/server/websocket/internal/logic/datatransferlogic.go +++ b/server/websocket/internal/logic/datatransferlogic.go @@ -402,7 +402,7 @@ func (w *wsConnectItem) sendToOutChan(data []byte) { return case w.outChan <- data: return - case <-time.After(time.Millisecond * 200): //阻塞超过200ms丢弃 + case <-time.After(time.Millisecond * 50): //阻塞超过50ms丢弃 logx.Error("failed to send to out chan,time expired,data:", string(data)) return }