Redis Lock

Overview

This section mainly describes the use of redis to create a distribution lock.

Preparing

1. Complete golang installation
2. Start redis service
3. Redis created

Description

1. Random version number, prevent outdated releases.
2. Can reenter, automatic renewal.

Methodological description

1. NewRedisLock

   Function signature: 
       NewRedisLock func(store *Redis, key string) *RedisLock 
   description: 
       1. Deleting a single record will also clear the key cache
       Default expiration time of 1500 ms
   in participation:
       1. store: redis instance
       2. key: key
   return value:
       1. *RedLock: redis locker instance

2. SetExpire

   Function signature: 
       SetExpire func(seconds int)
   description: 
       1. Set expiration time
   entry:
       1. seconds: expiration time, in seconds

3. Acquire

   Function signature: 
       Acquire func() (bool, error)
   description: 
       1. Get lock
   return value:
       1. bool: get lock
       2. error: operator error

4. AcquireCtx

   Function signature: 
   AcquireCtx func(ctx context.Context) (bool, error)
   description: 
       1. Get lock
   Input:
       1. ctx: context
   Return value:
       1. bool: Whether to get lock
       2. error: operator error

5. Release

   Function signature: 
   Release func() (bool, error)
   description: 
       1. Get lock
   return value:
       1. bool: get lock
       2. error: operator error

6. ReleaseCtx

Function signature: 
    ReleaseCtx function (ctx context.Context) (bool, error)
description: 
    1. Release Lock
Input:
    1. ctx: context
Return value:
    1. bool: Is locked released actively
    . error: operator

Use demo

{
    conf := RedisConf{
        Host: "127.0.0.1:55000",
        Type: "node",
        Pass: "123456",
        Tls:  false,
    }

    rds := MustNewRedis(conf)

    lock := NewRedisLock(rds, "test")

    lock.SetExpire(10)

    acquire, err := lock.Acquire()

    switch {
    case err != nil:
        // deal err
    case acquire:
        defer lock.Release() 
        // Add code here

    case !acquire:
        
    }
}