diff --git a/server/websocket/internal/logic/datatransferlogic.go b/server/websocket/internal/logic/datatransferlogic.go index a8a1e200..103c6758 100644 --- a/server/websocket/internal/logic/datatransferlogic.go +++ b/server/websocket/internal/logic/datatransferlogic.go @@ -246,14 +246,14 @@ func (l *DataTransferLogic) setConnPool(conn *websocket.Conn, userInfo *auth.Use }*/ //保存连接 mapConnPool.Store(uniqueId, ws) + //累加统计连接数 + increaseWebsocketConnectCount(userInfo.UserId, userInfo.GuestId) //非白板用户,需要为这个用户建立map索引便于通过用户查询 createUserConnPoolElement(userInfo.UserId, userInfo.GuestId, uniqueId) if isFirefoxBrowser { time.Sleep(time.Second * 1) //兼容下火狐(直接发回去收不到第一条消息:有待研究) } ws.sendToOutChan(ws.respondDataFormat(constants.WEBSOCKET_CONNECT_SUCCESS, websocket_data.ConnectSuccessMsg{Wid: uniqueId})) - //发送累加统计连接数 - increaseWebsocketConnectCount(userInfo.UserId, userInfo.GuestId) return ws, nil }