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-04 14:44:35 +08:00
parent c518b5a68d
commit d1b2b24fcf
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -61,8 +61,11 @@ func (r *reuseConnProcessor) allocationMessage(w *wsConnectItem, data []byte) {
} }
//重新绑定 //重新绑定
logx.Info("开始重新绑定websocket连接标识") logx.Info("开始重新绑定websocket连接标识")
oldUniqueId := w.uniqueId
w.uniqueId = wid w.uniqueId = wid
mapConnPool.Store(wid, *w) mapConnPool.Store(wid, *w)
//删除用户id级别之前的索引
deleteUserConnPoolElement(w.userId, w.guestId, oldUniqueId)
//添加用户id级别索引 //添加用户id级别索引
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)