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 11:21:24 +08:00
parent ae80cf12f3
commit 1a1903c826
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -63,6 +63,13 @@ func (r *reuseConnProcessor) allocationMessage(w *wsConnectItem, data []byte) {
logx.Info("开始重新绑定websocket连接标识") logx.Info("开始重新绑定websocket连接标识")
w.uniqueId = wid w.uniqueId = wid
mapConnPool.Store(wid, *w) mapConnPool.Store(wid, *w)
//添加用户id级别索引
createUserConnPoolElement(userConnPoolChanItem{
userId: w.userId,
guestId: w.guestId,
uniqueId: wid,
option: 1,
})
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连接标识成功")