From 13ca107963514afbda5d7ac6296a12aba3463770 Mon Sep 17 00:00:00 2001 From: laodaming <11058467+laudamine@user.noreply.gitee.com> Date: Wed, 30 Aug 2023 14:02:29 +0800 Subject: [PATCH 1/3] 1 --- server/websocket/internal/logic/datatransferlogic.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/server/websocket/internal/logic/datatransferlogic.go b/server/websocket/internal/logic/datatransferlogic.go index b8520c5a..7104e747 100644 --- a/server/websocket/internal/logic/datatransferlogic.go +++ b/server/websocket/internal/logic/datatransferlogic.go @@ -366,7 +366,7 @@ func (w *wsConnectItem) sendToInChan(data []byte) { case w.inChan <- data: return case <-time.After(time.Millisecond * 200): //200豪秒超时丢弃，说明超过消费速度了 - w.sendToOutChan(w.respondDataFormat(constants.WEBSOCKET_INCOME_CACHE_QUEUE_OVERFLOW, "send message is too frequent,Please reduce the sending speed ,otherwise, the message you sent may be lost")) + w.sendToOutChan(w.respondDataFormat(constants.WEBSOCKET_INCOME_CACHE_QUEUE_OVERFLOW, "send message is too frequent,the message is ignore by system:"+string(data))) return } } From dda3da13cd06ae8f1f3fc0281bccf69703b00b11 Mon Sep 17 00:00:00 2001 From: laodaming <11058467+laudamine@user.noreply.gitee.com> Date: Wed, 30 Aug 2023 14:04:31 +0800 Subject: [PATCH 2/3] 1 --- server/websocket/internal/logic/datatransferlogic.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/server/websocket/internal/logic/datatransferlogic.go b/server/websocket/internal/logic/datatransferlogic.go index 7104e747..9bc386b7 100644 --- a/server/websocket/internal/logic/datatransferlogic.go +++ b/server/websocket/internal/logic/datatransferlogic.go @@ -399,6 +399,6 @@ func (w *wsConnectItem) dealwithReciveData(data []byte) { case constants.WEBSOCKET_REQUEST_REUSE_LAST_CONNECT: w.reuseLastConnect(d) default: - logx.Error("未知消息类型：", parseInfo.T) + logx.Error("未知消息类型：uid:", w.userId, "gid:", w.guestId, "data:", string(data)) } } From 4457eba47f19c7d16d7bb6865b29260cede3733a Mon Sep 17 00:00:00 2001 From: laodaming <11058467+laudamine@user.noreply.gitee.com> Date: Wed, 30 Aug 2023 14:18:55 +0800 Subject: [PATCH 3/3] 1 --- server/websocket/internal/logic/ws_render_image.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/server/websocket/internal/logic/ws_render_image.go b/server/websocket/internal/logic/ws_render_image.go index bab88207..695104d3 100644 --- a/server/websocket/internal/logic/ws_render_image.go +++ b/server/websocket/internal/logic/ws_render_image.go @@ -68,14 +68,14 @@ func (w *wsConnectItem) consumeRenderImageData() { case <-w.closeChan: //已关闭 return case data := <-w.extendRenderProperty.renderChan: - w.consumeRenderCache(data) + w.renderImage(data) } } } -// 消费渲染缓冲数据 -func (w *wsConnectItem) consumeRenderCache(data []byte) { +// 执行渲染任务 +func (w *wsConnectItem) renderImage(data []byte) { logx.Info("消费渲染数据:", string(data)) var renderImageData websocket_data.RenderImageReqMsg if err := json.Unmarshal(data, &renderImageData); err != nil {