Fix/redis reacquire (#2)

* fix: redis locker reAcquire

* fix: locker

* fix: redis del lua script

Author: seth-shi

core/stores/redis/lockscript.lua

@@ -5,7 +5,6 @@ import (
 	_ "embed"
 	"errors"
 	"math/rand"
-	"strconv"
 	"sync/atomic"
 	"time"
 
@@ -15,16 +14,10 @@ import (
 )
 
 const (
-	randomLen       = 16
-	tolerance       = 500 // milliseconds
-	millisPerSecond = 1000
+	randomLen = 16
 )
 
 var (
-	//go:embed lockscript.lua
-	lockLuaScript string
-	lockScript    = NewScript(lockLuaScript)
-
 	//go:embed delscript.lua
 	delLuaScript string
 	delScript    = NewScript(delLuaScript)
@@ -58,26 +51,27 @@ func (rl *RedisLock) Acquire() (bool, error) {
 
 // AcquireCtx acquires the lock with the given ctx.
 func (rl *RedisLock) AcquireCtx(ctx context.Context) (bool, error) {
-	seconds := atomic.LoadUint32(&rl.seconds)
-	resp, err := rl.store.ScriptRunCtx(ctx, lockScript, []string{rl.key}, []string{
-		rl.id, strconv.Itoa(int(seconds)*millisPerSecond + tolerance),
-	})
+
+	var (
+		seconds = atomic.LoadUint32(&rl.seconds)
+		res     bool
+		err     error
+	)
+
+	if seconds == 0 {
+		res, err = rl.store.SetnxCtx(ctx, rl.key, rl.id)
+	} else {
+		res, err = rl.store.SetnxExCtx(ctx, rl.key, rl.id, int(seconds))
+	}
+
 	if errors.Is(err, red.Nil) {
 		return false, nil
 	} else if err != nil {
 		logx.Errorf("Error on acquiring lock for %s, %s", rl.key, err.Error())
 		return false, err
-	} else if resp == nil {
-		return false, nil
-	}
-
-	reply, ok := resp.(string)
-	if ok && reply == "OK" {
-		return true, nil
 	}
 
-	logx.Errorf("Unknown reply when acquiring lock for %s: %v", rl.key, resp)
-	return false, nil
+	return res, nil
 }
 
 // Release releases the lock.

core/stores/redis/redislock.go

@@ -3,12 +3,45 @@ package redis
 import (
 	"context"
 	"testing"
+	"time"
 
+	"github.com/alicebob/miniredis/v2"
 	"github.com/stretchr/testify/assert"
 
 	"github.com/zeromicro/go-zero/core/stringx"
 )
 
+func TestRedisLock_SameAcquire(t *testing.T) {
+
+	var (
+		s       = miniredis.RunT(t)
+		seconds = 5
+	)
+	client := MustNewRedis(
+		RedisConf{
+			Host: s.Addr(),
+			Type: NodeType,
+		},
+	)
+
+	key := stringx.Rand()
+	firstLock := NewRedisLock(client, key)
+	firstLock.SetExpire(seconds)
+	firstAcquire, err := firstLock.Acquire()
+	assert.Nil(t, err)
+	assert.True(t, firstAcquire)
+
+	secondAcquire, err := firstLock.Acquire()
+	assert.Nil(t, err)
+	assert.False(t, secondAcquire)
+
+	s.FastForward(time.Second * time.Duration(seconds+1))
+
+	thirdAcquire, err := firstLock.Acquire()
+	assert.Nil(t, err)
+	assert.True(t, thirdAcquire)
+}
+
 func TestRedisLock(t *testing.T) {
 	testFn := func(ctx context.Context) func(client *Redis) {
 		return func(client *Redis) {
@@ -35,31 +68,39 @@ func TestRedisLock(t *testing.T) {
 		}
 	}
 
-	t.Run("normal", func(t *testing.T) {
-		runOnRedis(t, testFn(nil))
-	})
+	t.Run(
+		"normal", func(t *testing.T) {
+			runOnRedis(t, testFn(nil))
+		},
+	)
 
-	t.Run("withContext", func(t *testing.T) {
-		runOnRedis(t, testFn(context.Background()))
-	})
+	t.Run(
+		"withContext", func(t *testing.T) {
+			runOnRedis(t, testFn(context.Background()))
+		},
+	)
 }
 
 func TestRedisLock_Expired(t *testing.T) {
-	runOnRedis(t, func(client *Redis) {
-		key := stringx.Rand()
-		redisLock := NewRedisLock(client, key)
-		ctx, cancel := context.WithCancel(context.Background())
-		cancel()
-		_, err := redisLock.AcquireCtx(ctx)
-		assert.NotNil(t, err)
-	})
-
-	runOnRedis(t, func(client *Redis) {
-		key := stringx.Rand()
-		redisLock := NewRedisLock(client, key)
-		ctx, cancel := context.WithCancel(context.Background())
-		cancel()
-		_, err := redisLock.ReleaseCtx(ctx)
-		assert.NotNil(t, err)
-	})
+	runOnRedis(
+		t, func(client *Redis) {
+			key := stringx.Rand()
+			redisLock := NewRedisLock(client, key)
+			ctx, cancel := context.WithCancel(context.Background())
+			cancel()
+			_, err := redisLock.AcquireCtx(ctx)
+			assert.NotNil(t, err)
+		},
+	)
+
+	runOnRedis(
+		t, func(client *Redis) {
+			key := stringx.Rand()
+			redisLock := NewRedisLock(client, key)
+			ctx, cancel := context.WithCancel(context.Background())
+			cancel()
+			_, err := redisLock.ReleaseCtx(ctx)
+			assert.NotNil(t, err)
+		},
+	)
 }