fusen/fusenapi
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix

Browse Source
This commit is contained in:
laodaming 2023-09-05 14:39:35 +08:00
parent afe85433fd
commit fdb4abce3d
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
server/websocket/internal/logic/datatransferlogic.go
View File

@ -164,7 +164,7 @@ func (l *DataTransferLogic) DataTransfer(w http.ResponseWriter, r *http.Request)
return return
} }
//循环读客户端信息 //循环读客户端信息
go ws.acceptBrowserMessage() go ws.reciveBrowserMessage()
//消费出口数据并发送浏览器端 //消费出口数据并发送浏览器端
go ws.consumeOutChanData() go ws.consumeOutChanData()
//消费入口数据 //消费入口数据
@ -487,7 +487,7 @@ func (w *wsConnectItem) consumeInChanData() {
} }
// 接受浏览器端发来的消息并写入入口缓冲队列 // 接受浏览器端发来的消息并写入入口缓冲队列
func (w *wsConnectItem) acceptBrowserMessage() { func (w *wsConnectItem) reciveBrowserMessage() {
defer func() { defer func() {
if err := recover(); err != nil { if err := recover(); err != nil {
logx.Error("acceptBrowserMessage panic:", err) logx.Error("acceptBrowserMessage panic:", err)