From 4ae67cbcd625b03a0911910ba44196c3333461f2 Mon Sep 17 00:00:00 2001 From: "zhangkun9038@dingtalk.com" Date: Tue, 14 Jan 2025 18:18:13 +0800 Subject: [PATCH] =?UTF-8?q?=E8=B7=9FSaveUikey=E5=85=B3=E7=B3=BB=E4=B8=8D?= =?UTF-8?q?=E5=A4=A7=EF=BC=8C=E5=BA=94=E8=AF=A5=E6=98=AFmax=E6=B2=A1?= =?UTF-8?q?=E6=9C=89=E5=8C=BA=E5=88=867/30=E7=9A=84hash=20key=E9=80=A0?= =?UTF-8?q?=E6=88=90=E5=86=99=E5=85=A5es=E8=A2=AB=E7=BB=9F=E4=B8=80?= =?UTF-8?q?=E5=AF=B9=E5=BE=85=E4=BA=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- candle.go | 15 +++++++-------- 1 file changed, 7 insertions(+), 8 deletions(-) diff --git a/candle.go b/candle.go index ce03797..3833b46 100644 --- a/candle.go +++ b/candle.go @@ -312,16 +312,15 @@ func (cl *Candle) ToStruct(core *Core) (*Candle, error) { // 保证同一个 period, keyName ，在一个周期里，SaveToSortSet只会被执行一次 func (core *Core) SaveUniKey(period string, keyName string, extt time.Duration, tsi int64) { - // refName := keyName + "|refer" - // refRes, _ := core.RedisLocalCli.GetSet(refName, 1).Result() - // core.RedisLocalCli.Expire(refName, extt) + refName := keyName + "|refer" + refRes, _ := core.RedisLocalCli.GetSet(refName, 1).Result() + core.RedisLocalCli.Expire(refName, extt) // 为保证唯一性机制，防止SaveToSortSet 被重复执行 // 关掉唯一性验证，试试 - // if len(refRes) != 0 { - // logrus.Error("refName exist: ", refName) - // return - // } - + if len(refRes) != 0 { + logrus.Error("refName exist: ", refName) + return + } core.SaveToSortSet(period, keyName, extt, tsi) }