This commit is contained in:
laodaming 2023-08-10 15:24:30 +08:00
parent 979c5c9e14
commit 22f34ec883

View File

@ -88,7 +88,7 @@ func (l *DataTransferLogic) DataTransfer(svcCtx *svc.ServiceContext, w http.Resp
}
defer conn.Close()
//鉴权不成功后断开
var (
/*var (
userInfo *auth.UserInfo
isAuth bool
)
@ -105,10 +105,10 @@ func (l *DataTransferLogic) DataTransfer(svcCtx *svc.ServiceContext, w http.Resp
//发送关闭信息
_ = conn.WriteMessage(websocket.CloseMessage, nil)
return
}
}*/
//测试的目前写死 39
/*var userInfo auth.UserInfo
userInfo.UserId = 39*/
var userInfo auth.UserInfo
userInfo.UserId = 39
//生成连接唯一标识
uniqueId := websocketIdGenerator.Get()
ws := wsConnectItem{