org.voovan.tools.collection

Class RedisLock

java.lang.Object

org.voovan.tools.collection.RedisLock

public class RedisLock
extends Object

基于 Redis 的分布式锁

Constructor Summary

Constructors

Constructor and Description
RedisLock(redis.clients.util.Pool<redis.clients.jedis.Jedis> jedisPool) 构造函数
RedisLock(redis.clients.util.Pool<redis.clients.jedis.Jedis> jedisPool, String name) 构造函数
RedisLock(String lockName) 构造函数
RedisLock(String host, int port, int timeout, int poolsize, String lockName) 构造函数
RedisLock(String host, int port, int timeout, int poolsize, String lockName, String password) 构造函数

Method Summary

Modifier and Type	Method and Description
int	getDbIndex() 获取当前选择的数据集
boolean	lock(int lockExpireTime, int timewait) 尝试加锁 超时时间 timewait 是尝试加锁的最长时间
boolean	lock(String lockValue, int lockExpireTime, int timewait) 尝试加锁 超时时间 timewait 是尝试加锁的最长时间
void	setDbIndex(int dbIndex) 选择当前数据集
boolean	tryLock(int lockExpireTime) 尝试加锁 快速失败的方式
boolean	tryLock(String lockValue, int lockExpireTime) 尝试加锁 快速失败的方式
boolean	unLock() 释放锁
boolean	unLock(String lockValue) 释放锁

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RedisLock

public RedisLock(String host,
                 int port,
                 int timeout,
                 int poolsize,
                 String lockName,
                 String password)

构造函数

Parameters:

host - redis 服务地址

port - redis 服务端口

timeout - redis 连接超时时间

poolsize - redis 连接池的大小

lockName - 锁的键名

password - redis 服务密码

RedisLock

public RedisLock(String host,
                 int port,
                 int timeout,
                 int poolsize,
                 String lockName)

构造函数

Parameters:

host - redis 服务地址

port - redis 服务端口

timeout - redis 连接超时时间

poolsize - redis 连接池的大小

lockName - 锁的键名称

RedisLock

public RedisLock(String lockName)

构造函数

Parameters:

lockName - 锁的键名

RedisLock

public RedisLock(redis.clients.util.Pool<redis.clients.jedis.Jedis> jedisPool,
                 String name)

构造函数

Parameters:

jedisPool - redis 连接池

name - 在 redis 中的 HashMap的名称

RedisLock

public RedisLock(redis.clients.util.Pool<redis.clients.jedis.Jedis> jedisPool)

构造函数

Parameters:

jedisPool - redis 连接池

Method Detail

getDbIndex

public int getDbIndex()

获取当前选择的数据集

Returns:

数据集序号

setDbIndex

public void setDbIndex(int dbIndex)

选择当前数据集

Parameters:

dbIndex - 数据集序号

tryLock

public boolean tryLock(String lockValue,
                       int lockExpireTime)

尝试加锁 快速失败的方式

Parameters:

lockValue - 锁的值

lockExpireTime - 锁的超时时间

Returns:

true: 成功, false: 失败

tryLock

public boolean tryLock(int lockExpireTime)

尝试加锁 快速失败的方式

Parameters:

lockExpireTime - 超时时间

Returns:

true: 成功, false: 失败

lock

public boolean lock(String lockValue,
                    int lockExpireTime,
                    int timewait)

尝试加锁 超时时间 timewait 是尝试加锁的最长时间

Parameters:

lockValue - 锁的名称

lockExpireTime - 锁的键值对的超时时间

timewait - 获取锁的等待时间, 单位: 毫秒

Returns:

true: 成功, false: 失败

lock

public boolean lock(int lockExpireTime,
                    int timewait)

尝试加锁 超时时间 timewait 是尝试加锁的最长时间

Parameters:

lockExpireTime - 锁的键值对的超时时间

timewait - 获取锁的等待时间, 单位: 毫秒

Returns:

true: 成功, false: 失败

unLock

public boolean unLock()

释放锁

Returns:

true: 成功, false: 失败

unLock

public boolean unLock(String lockValue)

释放锁

Parameters:

lockValue - 锁的名称

Returns:

true: 成功, false: 失败