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

11

Browse Source
This commit is contained in:
laodaming 2023-10-07 16:03:54 +08:00
parent 34b2aef763
commit 67fe103ac1
3 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
server/websocket/internal/logic/ws_connect_statistics.go
View File

@ -40,7 +40,7 @@ func ConsumeWebsocketConnectCountCtlChanData(ctx context.Context) {
select { select {
case num = <-websocketConnectCountCtlChan: case num = <-websocketConnectCountCtlChan:
currentWebsocketConnectCount += num currentWebsocketConnectCount += num
logx.Info("当前websocket连接总数:", currentWebsocketConnectCount) //logx.Info("当前websocket连接总数:", currentWebsocketConnectCount)
} }
} }
} }

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

@ -86,12 +86,12 @@ func (w *wsConnectItem) consumeRenderImageData() {
case data := <-w.extendRenderProperty.renderChan: //消费数据 case data := <-w.extendRenderProperty.renderChan: //消费数据
//标签不一样 //标签不一样
if data.RenderData.TemplateTag != w.extendRenderProperty.templateTag { if data.RenderData.TemplateTag != w.extendRenderProperty.templateTag {
logx.Info("标签不一致，丢弃消息") //logx.Info("标签不一致，丢弃消息")
continue continue
} }
//颜色不一致 //颜色不一致
if data.RenderData.TemplateTagColor.SelectedColorIndex != w.extendRenderProperty.selectColorIndex { if data.RenderData.TemplateTagColor.SelectedColorIndex != w.extendRenderProperty.selectColorIndex {
logx.Info("颜色不一致，丢弃消息") //logx.Info("颜色不一致，丢弃消息")
continue continue
} }
limitChan <- struct{}{} limitChan <- struct{}{}

2
server/websocket/internal/logic/ws_reuse_last_connect.go
View File

@ -70,7 +70,7 @@ func (r *reuseConnProcessor) allocationMessage(w *wsConnectItem, data []byte) {
createUserConnPoolElement(w.userId, w.guestId, wid) createUserConnPoolElement(w.userId, w.guestId, wid)
rsp := w.respondDataFormat(constants.WEBSOCKET_CONNECT_SUCCESS, wid) rsp := w.respondDataFormat(constants.WEBSOCKET_CONNECT_SUCCESS, wid)
w.sendToOutChan(rsp) w.sendToOutChan(rsp)
logx.Info("重新绑定websocket连接标识成功") //logx.Info("重新绑定websocket连接标识成功")
} }
// 获取用户拼接部分(复用标识用到) // 获取用户拼接部分(复用标识用到)