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-12 10:54:02 +08:00
parent 3fdf14c493
commit 0015ef7540
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -15,7 +15,7 @@ type reuseConnProcessor struct {
// 处理分发到这里的数据 // 处理分发到这里的数据
func (r *reuseConnProcessor) allocationMessage(w *wsConnectItem, data []byte) { func (r *reuseConnProcessor) allocationMessage(w *wsConnectItem, data []byte) {
logx.Info("收到请求恢复上次连接标识数据:", string(data)) //logx.Info("收到请求恢复上次连接标识数据:", string(data))
var wid string var wid string
if err := json.Unmarshal(data, &wid); err != nil { if err := json.Unmarshal(data, &wid); err != nil {
logx.Error(" invalid format of wid :", wid) logx.Error(" invalid format of wid :", wid)
@ -60,7 +60,7 @@ func (r *reuseConnProcessor) allocationMessage(w *wsConnectItem, data []byte) {
} }
} }
//重新绑定 //重新绑定
logx.Info("开始重新绑定websocket连接标识") //logx.Info("开始重新绑定websocket连接标识")
oldUniqueId := w.uniqueId oldUniqueId := w.uniqueId
w.uniqueId = wid w.uniqueId = wid
mapConnPool.Store(wid, *w) mapConnPool.Store(wid, *w)