com.plc.cachelock

类 CacheLockManager

java.lang.Object

com.plc.cachelock.CacheLockManager

public class CacheLockManager
extends java.lang.Object

构造器概要

构造器

构造器和说明
CacheLockManager(org.springframework.data.redis.core.RedisTemplate redisTemplate, java.lang.String lockedPrefix, java.lang.String lockKey) Detailed constructor with default acquire timeout 10000 msecs and lock expiration of 60000 msecs.

方法概要

限定符和类型	方法和说明
java.lang.String	getLockKey()
boolean	lock(long timeoutMsecs, int expireMsecs) 获得 lock.
void	unlock() Acqurired lock release.

从类继承的方法 java.lang.Object

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

构造器详细资料

CacheLockManager

public CacheLockManager(org.springframework.data.redis.core.RedisTemplate redisTemplate,
                        java.lang.String lockedPrefix,
                        java.lang.String lockKey)

Detailed constructor with default acquire timeout 10000 msecs and lock expiration of 60000 msecs.

参数:

lockKey - lock key (ex. account:1, ...)

方法详细资料

getLockKey

public java.lang.String getLockKey()

返回:

lock key

lock

public boolean lock(long timeoutMsecs,
                    int expireMsecs)
             throws java.lang.InterruptedException

获得 lock. 实现思路: 主要是使用了redis 的setnx命令,缓存了锁. reids缓存的key是锁的key,所有的共享, value是锁的到期时间(注意:这里把过期时间放在value了,没有时间上设置其超时时间) 执行过程: 1.通过setnx尝试设置某个key的值,成功(当前没有这个锁)则返回,成功获得锁 2.锁已经存在则获取锁的到期时间,和当前时间比较,超时的话,则设置新的值

返回:

true if lock is acquired, false acquire timeouted

抛出:

java.lang.InterruptedException - in case of thread interruption

unlock

public void unlock()

Acqurired lock release.