13518219792
这篇文章将为大家详细讲解有关怎么在MySQL数据库中实现一个分布式锁，文章内容质量较高，因此小编分享给大家做个参考，希望大家阅读完这篇文章后对相关知识有一定的了解。
介休网站建设公司创新互联建站,介休网站设计制作，有大型网站制作公司丰富经验。已为介休近1000家提供企业网站建设服务。企业网站搭建\外贸营销网站建设要多少钱，请找那个售后服务好的介休做网站的公司定做！
建表
CREATE TABLE `globallocktable` ( `id` int(11) NOT NULL AUTO_INCREMENT, `lockKey` varchar(60) NOT NULL COMMENT '锁名称', `createTime` datetime NOT NULL COMMENT '创建时间', PRIMARY KEY (`id`), UNIQUE KEY `lockKey` (`lockKey`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8 ROW_FORMAT=DYNAMIC COMMENT='全局锁';
让别人使用的组件
@Component
public class GlobalLockComponent {
@Resource
GlobalLockTableDAO globalLockDAO;
/**
* 尝试获得锁，成功为true，失败为false
*/
public boolean tryLock(String key) {
return GlobalLockUtil.tryLock(this.globalLockDAO, key);
}
/**
* 如果已经有其他程序占用该锁，并且超过timeoutMs（毫秒）时间，就强制清除这个锁占用
* 即根据key先删除记录，再添加记录
*/
public boolean tryLockWithClear(String key, Long timeoutMs) {
return GlobalLockUtil.tryLockWithClear(this.globalLockDAO, key, timeoutMs);
}
/**
* 释放锁，根据key删除记录
*/
public void releasLock(String key) {
GlobalLockUtil.releasLock(this.globalLockDAO, key);
}
}锁对象定义如下
public class GlobalLockTable {
private Integer id;
private String lockKey;
private Date createTime;
// 省略get和set方法
}
GlobalLockTableDAO定义如下
public interface GlobalLockTableDAO {
int deleteByPrimaryKey(Integer id);
int deleteByLockKey(String lockKey);
GlobalLockTable selectByLockKey(String key);
int insertSelectiveWithTest(GlobalLockTable record);
}具体加锁和解锁逻辑
public class GlobalLockUtil {
private static Logger logger = LoggerFactory.getLogger(GlobalLockUtil.class);
private static GlobalLockTable tryLockInternal(GlobalLockTableDAO lockDAO, String key) {
GlobalLockTable insert = new GlobalLockTable();
insert.setCreateTime(new Date());
insert.setLockKey(key);
// 注意的地方1
int count = lockDAO.insertSelectiveWithTest(insert);
if (count == 0) {
GlobalLockTable ready = lockDAO.selectByLockKey(key);
logger.warn("can not lock the key: {}, {}, {}", insert.getLockKey(), ready.getCreateTime(),
ready.getId());
return ready;
}
logger.info("yes got the lock by key: {}", insert.getId(), insert.getLockKey());
return null;
}
/** 超时清除锁占用，并重新加锁 **/
public static boolean tryLockWithClear(GlobalLockTableDAO lockDAO, String key, Long timeoutMs) {
GlobalLockTable lock = tryLockInternal(lockDAO, key);
if (lock == null) return true;
if (System.currentTimeMillis() - lock.getCreateTime().getTime() <= timeoutMs) {
logger.warn("sorry, can not get the key. : {}, {}, {}", key, lock.getId(), lock.getCreateTime());
return false;
}
logger.warn("the key already timeout wthin : {}, {}, will clear", key, timeoutMs);
// 注意的地方2
int count = lockDAO.deleteByPrimaryKey(lock.getId());
if (count == 0) {
logger.warn("sorry, the key already preemptived by others: {}, {}", lock.getId(), lock.getLockKey());
return false;
}
lock = tryLockInternal(lockDAO, key);
return lock != null ? false : true;
}
/** 加锁 **/
public static boolean tryLock(GlobalLockTableDAO lockDAO, String key) {
return tryLockInternal(lockDAO, key) == null ? true : false;
}
/** 解锁 **/
public static void releasLock(GlobalLockTableDAO lockDAO, String key) {
lockDAO.deleteByLockKey(key);
}
}这个工具类有2个特别有意思的地方，先看注意的地方2（上面代码中标识了）
1.为了避免锁长时间不释放，用redis实现的话可以设置锁超时时间，超时自动释放（后面会写用Redis实现分布式锁）用MySQL实现的话可以先删除后添加。可以看到删除的时候使用id删的，不是用name删的。为啥呢？先自己想一下
因为如果是通过name删的话，有可能别人删了这个锁后，又通过name加了锁，还没到超时时间，结果你却根据name删除了。通过id删的话，当返回的id=0时，说明别人已经重新加锁了，你需要重新获取。
2.GlobalLockTable 对象dao层的其他方法都见名知意，来看一个这个方法。即代码中的注意点1
可以看到每次尝试加锁的时候，并不是先select，而是直接insertSelectiveWithTest，这样就少了一个查询时间，提高了效率
insertSelectiveWithTest的作用是当lockKey存在时不进行插入操作，返回0。当lockKey不存在时进行插入操作，返回1
