com.seeyon.ctp.common.lock.manager

类 DatabaseLockManagerImpl

java.lang.Object

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

com.seeyon.ctp.common.lock.manager.DatabaseLockManagerImpl

所有已实现的接口:

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

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

字段概要

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

EXPIRE_MILLIS, lockLogger, READ_ACTIOM

构造器概要

构造器

构造器和说明
DatabaseLockManagerImpl()

方法概要

限定符和类型	方法和说明
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) 取得资源的指定操作的锁。
com.seeyon.ctp.common.po.lock.Lock	getLock(long owner, long resourceId, int action)
LockDAO	getLockDao()
java.util.List<com.seeyon.ctp.common.po.lock.Lock>	getLocks(long resourceId) 取得资源的所有锁。
void	init()
boolean	lock(com.seeyon.ctp.common.po.lock.Lock lock) 对资源的操作加锁(高级使用，谨慎，lock参数需使用lockManager.createDefaultLock创建此对象才行)。
boolean	lock(long owner, long resourceId, java.lang.String from)
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	setLockDao(LockDAO lockDao)
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 rd, int action, long time)

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

activeWriteLock, check, check, check, check, getLoginTime, getMember, getModule, getOnLineManager, getOrgManager, getOwnerName, getSortOrder, getValidator, initialize, isValid, 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, lockForRead, lockForWrite, unlockForWrite

构造器详细资料

DatabaseLockManagerImpl

public DatabaseLockManagerImpl()

方法详细资料

lock

@Transactional(propagation=REQUIRES_NEW,
               rollbackFor=com.seeyon.ctp.common.exceptions.BusinessException.class)
public boolean lock(java.lang.String module,
                                                                                                                                                    long owner,
                                                                                                                                                    long resourceId)

指定者:

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

lock

@Transactional(propagation=REQUIRES_NEW,
               rollbackFor=com.seeyon.ctp.common.exceptions.BusinessException.class)
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

@Transactional(propagation=REQUIRES_NEW,
               rollbackFor=com.seeyon.ctp.common.exceptions.BusinessException.class)
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

@Transactional(propagation=REQUIRES_NEW,
               rollbackFor=com.seeyon.ctp.common.exceptions.BusinessException.class)
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

lock

@Transactional(propagation=REQUIRES_NEW,
               rollbackFor=com.seeyon.ctp.common.exceptions.BusinessException.class)
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

@Transactional(propagation=REQUIRES_NEW,
               rollbackFor=com.seeyon.ctp.common.exceptions.BusinessException.class)
public boolean lock(long owner,
                                                                                                                                                    long resourceId,
                                                                                                                                                    java.lang.String from)

指定者:

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

覆盖:

lock 在类中 AbstractLockManager

from - 来自哪个端，目前只有WXT用到，WXT表示微协同

返回:

lock

@Transactional(propagation=REQUIRES_NEW,
               rollbackFor=com.seeyon.ctp.common.exceptions.BusinessException.class)
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

返回:

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。

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。

getLock

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

unlock

@Transactional(propagation=REQUIRES_NEW,
               rollbackFor=com.seeyon.ctp.common.exceptions.BusinessException.class)
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

@Transactional(propagation=REQUIRES_NEW,
               rollbackFor=com.seeyon.ctp.common.exceptions.BusinessException.class)
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

@Transactional(propagation=REQUIRES_NEW,
               rollbackFor=com.seeyon.ctp.common.exceptions.BusinessException.class)
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

getLockDao

public LockDAO getLockDao()

setLockDao

public void setLockDao(LockDAO lockDao)

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

@Transactional(propagation=REQUIRES_NEW,
               rollbackFor=com.seeyon.ctp.common.exceptions.BusinessException.class)
public void updateLockExpirationTime(long rd,
                                                                                                                                                                     int action,
                                                                                                                                                                     long time)

指定者:

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

覆盖:

updateLockExpirationTime 在类中 AbstractLockManager

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

返回:

releaseOutDateLock

@Transactional(propagation=NOT_SUPPORTED,
               rollbackFor=com.seeyon.ctp.common.exceptions.BusinessException.class)
public void releaseOutDateLock(int beforeSeconds)

指定者:

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

覆盖:

releaseOutDateLock 在类中 AbstractLockManager

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

@Transactional(propagation=REQUIRES_NEW,
               rollbackFor=com.seeyon.ctp.common.exceptions.BusinessException.class)
public boolean lockForRead(java.lang.String module,
                                                                                                                                                           long owner,
                                                                                                                                                           long resourceId)

指定者:

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

unlockForRead

@Transactional(propagation=REQUIRES_NEW,
               rollbackFor=com.seeyon.ctp.common.exceptions.BusinessException.class)
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

activeReadLock

@Transactional(propagation=REQUIRES_NEW,
               rollbackFor=com.seeyon.ctp.common.exceptions.BusinessException.class)
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

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 - 监听器

init

public void init()

覆盖:

init 在类中 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