From fdb4abce3d87b408cce521970e720d595d6a6537 Mon Sep 17 00:00:00 2001 From: laodaming <11058467+laudamine@user.noreply.gitee.com> Date: Tue, 5 Sep 2023 14:39:35 +0800 Subject: [PATCH] fix --- server/websocket/internal/logic/datatransferlogic.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/server/websocket/internal/logic/datatransferlogic.go b/server/websocket/internal/logic/datatransferlogic.go index 90fa9a4a..35f62ac4 100644 --- a/server/websocket/internal/logic/datatransferlogic.go +++ b/server/websocket/internal/logic/datatransferlogic.go @@ -164,7 +164,7 @@ func (l *DataTransferLogic) DataTransfer(w http.ResponseWriter, r *http.Request) return } //循环读客户端信息 - go ws.acceptBrowserMessage() + go ws.reciveBrowserMessage() //消费出口数据并发送浏览器端 go ws.consumeOutChanData() //消费入口数据 @@ -487,7 +487,7 @@ func (w *wsConnectItem) consumeInChanData() { } // 接受浏览器端发来的消息并写入入口缓冲队列 -func (w *wsConnectItem) acceptBrowserMessage() { +func (w *wsConnectItem) reciveBrowserMessage() { defer func() { if err := recover(); err != nil { logx.Error("acceptBrowserMessage panic:", err)