diff --git a/server/websocket/internal/logic/commonnotifylogic.go b/server/websocket/internal/logic/commonnotifylogic.go index 65fd1ffc..a3668d88 100644 --- a/server/websocket/internal/logic/commonnotifylogic.go +++ b/server/websocket/internal/logic/commonnotifylogic.go @@ -99,7 +99,7 @@ func (l *CommonNotifyLogic) CommonNotify(req *types.CommonNotifyReq, userinfo *a if req.Wid == "" { return resp.SetStatusWithMessage(basic.CodeRequestParamsErr, "websocket connect id is empty") } - //触发消费公共未处理的消息(只有第一次有用) + //触发消费公共未处理的消息(该方法是单例) l.consumeCommonCacheData() //查询websocket连接 value, ok := mapConnPool.Load(req.Wid)