diff --git a/server/websocket/internal/logic/ws_reuse_last_connect.go b/server/websocket/internal/logic/ws_reuse_last_connect.go index 1816993b..065f43eb 100644 --- a/server/websocket/internal/logic/ws_reuse_last_connect.go +++ b/server/websocket/internal/logic/ws_reuse_last_connect.go @@ -63,6 +63,13 @@ func (r *reuseConnProcessor) allocationMessage(w *wsConnectItem, data []byte) { logx.Info("开始重新绑定websocket连接标识") w.uniqueId = wid 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) w.sendToOutChan(rsp) logx.Info("重新绑定websocket连接标识成功")