From 25fef67c07f375151104832b9a2ab95f5d700ec3 Mon Sep 17 00:00:00 2001 From: mountain Date: Wed, 6 Sep 2023 12:41:49 +0900 Subject: [PATCH] =?UTF-8?q?=EB=A7=8C=EB=A3=8C=EB=90=9C=20=EC=84=B8?= =?UTF-8?q?=EC=85=98=EB=8F=84=20=ED=99=95=EC=9D=B8=20=ED=95=84=EC=9A=94?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- session/impl_redis.go | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/session/impl_redis.go b/session/impl_redis.go index 61ee10e..770e1bd 100644 --- a/session/impl_redis.go +++ b/session/impl_redis.go @@ -191,13 +191,16 @@ func (c *consumer_redis) query_internal(sk storagekey) (*sessionRedis, bool, err } if ok { - return found, false, nil + if time.Now().Before(found.expireAt) { + // 만료전 세션 + return found, false, nil + } + + // 다른 Consumer가 Touch했을 수도 있으므로 redis에서 읽어본다. } payload, err := c.redisClient.Get(c.ctx, string(sk)).Result() - if err == redis.Nil { - return nil, false, nil - } else if err != nil { + if err != nil && err != redis.Nil { logger.Println("consumer Query :", err) return nil, false, err }