com.seeyon.ctp.common.lock.manager

类 RedisLockManagerImpl

java.lang.Object

com.seeyon.ctp.common.lock.manager.AbstractLockManager

com.seeyon.ctp.common.lock.manager.RedisLockManagerImpl

所有已实现的接口:

com.seeyon.ctp.common.lock.manager.ConcreteLockManager, com.seeyon.ctp.common.lock.manager.LockManager

public class RedisLockManagerImpl
extends AbstractLockManager
implements com.seeyon.ctp.common.lock.manager.ConcreteLockManager

锁机制Redis实现版 数据格式:resourceId:action:owner lock(JsonString)

字段概要

字段

限定符和类型	字段和说明
static long	CHECK_PERIOD_SECONDS
static long	DEFAULT_EXPIRE_TIME

从类继承的字段 com.seeyon.ctp.common.lock.manager.AbstractLockManager

EXPIRE_MILLIS, lockLogger, READ_ACTIOM

构造器概要

构造器

构造器和说明
RedisLockManagerImpl()

方法概要

限定符和类型	方法和说明
void	activeReadLock(long owner, long resourceId) 激活读锁，保证锁有效，若30秒未激活，锁会被回收。
void	addReleaseLockListener(com.seeyon.ctp.common.lock.manager.ReleaseLockListener listener) 注册锁释放监听器，每个应用智能注册一个监听器
void	addReleaseLockListener(java.lang.String module, com.seeyon.ctp.common.lock.manager.ReleaseLockListener listener)
com.seeyon.ctp.common.po.lock.Lock	createDefaultLock(long owner, long resourceId, int action, java.lang.String from, java.lang.String param0, java.lang.String param1, boolean useNowexpirationTime)
java.util.List<com.seeyon.ctp.common.po.lock.Lock>	getAllLock() 该方法存在性能问题，并且使用场景不合理，废弃不再维护
com.seeyon.ctp.common.po.lock.Lock	getLock(long resourceId, int action) 取得资源的指定操作的锁。
java.util.List<com.seeyon.ctp.common.po.lock.Lock>	getLocks(long resourceId) 取得资源的所有锁。
boolean	lock(com.seeyon.ctp.common.po.lock.Lock lock) 对资源的操作加锁(高级使用，谨慎，lock参数需使用lockManager.createDefaultLock创建此对象才行)。
boolean	lock(java.lang.String module, long owner, long resourceId)
boolean	lock(java.lang.String module, long owner, long resourceId, int action)
boolean	lock(java.lang.String module, long owner, long resourceId, int action, boolean ignoreOnlineStatus)
boolean	lock(java.lang.String module, long owner, long resourceId, int action, java.lang.String from)
boolean	lock(java.lang.String module, long owner, long resourceId, int action, java.lang.String from, boolean useNowexpirationTime)
boolean	lock(java.lang.String module, long owner, long resourceId, int action, java.lang.String from, boolean useNowexpirationTime, boolean unlockSelfLock)
boolean	lock(java.lang.String module, long owner, long resourceId, int action, java.lang.String from, boolean useNowexpirationTime, boolean unlockSelfLock, boolean ignoreOnlineStatus)
boolean	lock(java.lang.String module, long owner, long resourceId, java.lang.String from)
boolean	lock(java.lang.String module, long owner, long resourceId, java.lang.String from, boolean ignoreOnlineStatus)
boolean	lockForRead(java.lang.String module, long owner, long resourceId)
void	releaseCurrentLock(com.seeyon.ctp.common.po.lock.Lock lock) 释放锁
void	releaseOutDateLock(int beforeSeconds) 清理内存持有的超时锁
void	unlock(long resourceId) 解锁。
void	unlock(long resourceId, int action) 解锁。
void	unlock(long owner, long resourceId, int action) 解锁。
void	unlockForRead(long owner, long resourceId) 解锁读锁
void	updateLockExpirationTime(long resourceId, int action, long expirationTime)

从类继承的方法 com.seeyon.ctp.common.lock.manager.AbstractLockManager

activeWriteLock, check, check, check, check, getLoginTime, getMember, getModule, getOnLineManager, getOrgManager, getOwnerName, getSortOrder, getValidator, init, initialize, isValid, lock, lock, lock, lock, lock, lock, lock, lock, lock, lockForRead, lockForWrite, setModule, setOnLineManager, setOrgManager, setValidator, unlockForWrite

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

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

从接口继承的方法 com.seeyon.ctp.common.lock.manager.LockManager

activeWriteLock, check, check, getModule, getOwnerName, isValid, lock, lock, lock, lock, lock, lock, lock, lock, lock, lockForRead, lockForWrite, unlockForWrite

字段详细资料

CHECK_PERIOD_SECONDS

public static final long CHECK_PERIOD_SECONDS

另请参阅:

常量字段值

DEFAULT_EXPIRE_TIME

public static final long DEFAULT_EXPIRE_TIME

另请参阅:

常量字段值

构造器详细资料

RedisLockManagerImpl

public RedisLockManagerImpl()

方法详细资料

lock

public boolean lock(java.lang.String module,
                    long owner,
                    long resourceId)

指定者:

lock 在接口中 com.seeyon.ctp.common.lock.manager.ConcreteLockManager

lock

public boolean lock(java.lang.String module,
                    long owner,
                    long resourceId,
                    java.lang.String from)

指定者:

lock 在接口中 com.seeyon.ctp.common.lock.manager.ConcreteLockManager

lock

public boolean lock(java.lang.String module,
                    long owner,
                    long resourceId,
                    java.lang.String from,
                    boolean ignoreOnlineStatus)

指定者:

lock 在接口中 com.seeyon.ctp.common.lock.manager.ConcreteLockManager

lock

public boolean lock(java.lang.String module,
                    long owner,
                    long resourceId,
                    int action)

指定者:

lock 在接口中 com.seeyon.ctp.common.lock.manager.ConcreteLockManager

lock

public boolean lock(java.lang.String module,
                    long owner,
                    long resourceId,
                    int action,
                    boolean ignoreOnlineStatus)

指定者:

lock 在接口中 com.seeyon.ctp.common.lock.manager.ConcreteLockManager

lock

public boolean lock(java.lang.String module,
                    long owner,
                    long resourceId,
                    int action,
                    java.lang.String from)

指定者:

lock 在接口中 com.seeyon.ctp.common.lock.manager.ConcreteLockManager

lock

public boolean lock(java.lang.String module,
                    long owner,
                    long resourceId,
                    int action,
                    java.lang.String from,
                    boolean useNowexpirationTime)

指定者:

lock 在接口中 com.seeyon.ctp.common.lock.manager.ConcreteLockManager

getLocks

public java.util.List<com.seeyon.ctp.common.po.lock.Lock> getLocks(long resourceId)

从接口复制的说明: com.seeyon.ctp.common.lock.manager.LockManager

取得资源的所有锁。用于扩展，取得锁以后可以对check做别的解释。

指定者:

getLocks 在接口中 com.seeyon.ctp.common.lock.manager.LockManager

覆盖:

getLocks 在类中 AbstractLockManager

参数:

resourceId - 资源Id

返回:

锁存在则返回资源的有效锁列表，否则返回size为0的List。

unlock

public void unlock(long resourceId)

从接口复制的说明: com.seeyon.ctp.common.lock.manager.LockManager

解锁。释放所有指定资源的锁，锁不存在则无操作。

指定者:

unlock 在接口中 com.seeyon.ctp.common.lock.manager.LockManager

覆盖:

unlock 在类中 AbstractLockManager

参数:

resourceId - 资源Id。

unlock

public void unlock(long resourceId,
                   int action)

从接口复制的说明: com.seeyon.ctp.common.lock.manager.LockManager

解锁。释放资源的指定操作的锁，锁不存在则无操作，不释放资源其他操作的锁。

指定者:

unlock 在接口中 com.seeyon.ctp.common.lock.manager.LockManager

覆盖:

unlock 在类中 AbstractLockManager

参数:

resourceId - 资源Id。

action - 资源操作。

unlock

public void unlock(long owner,
                   long resourceId,
                   int action)

从接口复制的说明: com.seeyon.ctp.common.lock.manager.LockManager

解锁。释放资源的指定操作的锁，锁不存在则无操作，不释放资源其他操作的锁。

指定者:

unlock 在接口中 com.seeyon.ctp.common.lock.manager.LockManager

覆盖:

unlock 在类中 AbstractLockManager

参数:

owner - 加锁人Id

resourceId - 资源Id。

action - 资源操作。

releaseCurrentLock

public void releaseCurrentLock(com.seeyon.ctp.common.po.lock.Lock lock)

从接口复制的说明: com.seeyon.ctp.common.lock.manager.LockManager

释放锁

指定者:

releaseCurrentLock 在接口中 com.seeyon.ctp.common.lock.manager.LockManager

覆盖:

releaseCurrentLock 在类中 AbstractLockManager

参数:

lock -

lock

public boolean lock(com.seeyon.ctp.common.po.lock.Lock lock)

从接口复制的说明: com.seeyon.ctp.common.lock.manager.LockManager

对资源的操作加锁(高级使用，谨慎，lock参数需使用lockManager.createDefaultLock创建此对象才行)。

指定者:

lock 在接口中 com.seeyon.ctp.common.lock.manager.LockManager

覆盖:

lock 在类中 AbstractLockManager

返回:

createDefaultLock

public com.seeyon.ctp.common.po.lock.Lock createDefaultLock(long owner,
                                                            long resourceId,
                                                            int action,
                                                            java.lang.String from,
                                                            java.lang.String param0,
                                                            java.lang.String param1,
                                                            boolean useNowexpirationTime)

指定者:

createDefaultLock 在接口中 com.seeyon.ctp.common.lock.manager.LockManager

覆盖:

createDefaultLock 在类中 AbstractLockManager

返回:

updateLockExpirationTime

public void updateLockExpirationTime(long resourceId,
                                     int action,
                                     long expirationTime)

指定者:

updateLockExpirationTime 在接口中 com.seeyon.ctp.common.lock.manager.LockManager

覆盖:

updateLockExpirationTime 在类中 AbstractLockManager

getLock

public com.seeyon.ctp.common.po.lock.Lock getLock(long resourceId,
                                                  int action)

从接口复制的说明: com.seeyon.ctp.common.lock.manager.LockManager

取得资源的指定操作的锁。

指定者:

getLock 在接口中 com.seeyon.ctp.common.lock.manager.LockManager

覆盖:

getLock 在类中 AbstractLockManager

参数:

resourceId - 资源Id。

action - 操作。

返回:

锁存在且有效则返回，否则返回null。

releaseOutDateLock

public void releaseOutDateLock(int beforeSeconds)

清理内存持有的超时锁

指定者:

releaseOutDateLock 在接口中 com.seeyon.ctp.common.lock.manager.LockManager

覆盖:

releaseOutDateLock 在类中 AbstractLockManager

参数:

beforeSeconds -

addReleaseLockListener

public void addReleaseLockListener(java.lang.String module,
                                   com.seeyon.ctp.common.lock.manager.ReleaseLockListener listener)

指定者:

addReleaseLockListener 在接口中 com.seeyon.ctp.common.lock.manager.ConcreteLockManager

lockForRead

public boolean lockForRead(java.lang.String module,
                           long owner,
                           long resourceId)

指定者:

lockForRead 在接口中 com.seeyon.ctp.common.lock.manager.ConcreteLockManager

activeReadLock

public void activeReadLock(long owner,
                           long resourceId)

从接口复制的说明: com.seeyon.ctp.common.lock.manager.LockManager

激活读锁，保证锁有效，若30秒未激活，锁会被回收。

指定者:

activeReadLock 在接口中 com.seeyon.ctp.common.lock.manager.LockManager

覆盖:

activeReadLock 在类中 AbstractLockManager

resourceId - 加锁资源对象ID

unlockForRead

public void unlockForRead(long owner,
                          long resourceId)

从接口复制的说明: com.seeyon.ctp.common.lock.manager.LockManager

解锁读锁

指定者:

unlockForRead 在接口中 com.seeyon.ctp.common.lock.manager.LockManager

覆盖:

unlockForRead 在类中 AbstractLockManager

参数:

owner - 加锁人员ID

resourceId - 资源对象ID

addReleaseLockListener

public void addReleaseLockListener(com.seeyon.ctp.common.lock.manager.ReleaseLockListener listener)

从接口复制的说明: com.seeyon.ctp.common.lock.manager.LockManager

注册锁释放监听器，每个应用智能注册一个监听器

指定者:

addReleaseLockListener 在接口中 com.seeyon.ctp.common.lock.manager.LockManager

覆盖:

addReleaseLockListener 在类中 AbstractLockManager

参数:

listener - 监听器

getAllLock

public java.util.List<com.seeyon.ctp.common.po.lock.Lock> getAllLock()

从接口复制的说明: com.seeyon.ctp.common.lock.manager.LockManager

该方法存在性能问题，并且使用场景不合理，废弃不再维护

指定者:

getAllLock 在接口中 com.seeyon.ctp.common.lock.manager.LockManager

覆盖:

getAllLock 在类中 AbstractLockManager

返回:

lock

public boolean lock(java.lang.String module,
                    long owner,
                    long resourceId,
                    int action,
                    java.lang.String from,
                    boolean useNowexpirationTime,
                    boolean unlockSelfLock)

指定者:

lock 在接口中 com.seeyon.ctp.common.lock.manager.ConcreteLockManager

lock

public boolean lock(java.lang.String module,
                    long owner,
                    long resourceId,
                    int action,
                    java.lang.String from,
                    boolean useNowexpirationTime,
                    boolean unlockSelfLock,
                    boolean ignoreOnlineStatus)

指定者:

lock 在接口中 com.seeyon.ctp.common.lock.manager.ConcreteLockManager