redislock

Documentation

Index

• Variables
• type Locker
  • func (locker *Locker) Unlock() (err error)
• type RedisLock
  • func NewRedisLock() *RedisLock
  • func (rds *RedisLock) Open(strURL string) (err error)
  • func (rds *RedisLock) TryLock(strKey, strValue string, nExpireTime int) (locker *Locker, ok bool)

Variables

var REDIS_CMD_AUTH = "AUTH"

var REDIS_CMD_DEL = "DEL"

var REDIS_CMD_EVAL = "EVAL"

var REDIS_CMD_EXPIRE = "EXPIRE"

var REDIS_CMD_GET = "GET"

var REDIS_CMD_PING = "PING"

var REDIS_CMD_SET = "SET"

var REDIS_LOCK_SUCC = "OK"

var REDIS_SET_EX = "EX" //设置过期时间（单位：秒）

var REDIS_SET_NX = "NX" //设置key-value当指定key不存在时

var REDIS_SET_WITH_EXPIRE_TIME = "PX" //设置过期时间（单位：毫秒）

var REDIS_UNLOCK_SUCC = int64(1)

Types

type Locker

type Locker struct {
	// contains filtered or unexported fields
}

func (*Locker) Unlock

func (locker *Locker) Unlock() (err error)

* @brief 解锁 * @return err 成功返回nil，失败返回error(失败的情况仅限于redis服务器宕机了或执行脚本出错)

type RedisLock

type RedisLock struct {
	// contains filtered or unexported fields
}

func NewRedisLock

func NewRedisLock() *RedisLock

func (*RedisLock) Open

func (rds *RedisLock) Open(strURL string) (err error)

* @brief 打开Redis连接，初始化连接池 * @param strURL Redis连接URL 有用户名密码 "redis://123456@192.168.1.10:6379" * 没有用户名密码则是 "redis://192.168.1.10:6379" * @return err 成功返回nil，失败返回错误类型

func (*RedisLock) TryLock

func (rds *RedisLock) TryLock(strKey, strValue string, nExpireTime int) (locker *Locker, ok bool)

• @brief 尝试加锁
• @param strKey Redis唯一key
• @param strValue Redis值，用于识别哪个用户加锁
• @param nExpireTime 锁的过期时间（秒）
• @return locker 加锁成功后，返回用于解锁的对象 err 成功返回nil，失败返回error