From 1a1903c82674c90ebfb237e3cd0f2fca5f11b46f Mon Sep 17 00:00:00 2001 From: laodaming <11058467+laudamine@user.noreply.gitee.com> Date: Mon, 4 Sep 2023 11:21:24 +0800 Subject: [PATCH] fix --- server/websocket/internal/logic/ws_reuse_last_connect.go | 7 +++++++ 1 file changed, 7 insertions(+) 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连接标识成功")