• ADADADADAD

    怎么在MySQL数据库中实现一个分布式锁[ mysql数据库 ]

    mysql数据库 时间:2024-11-29 09:49:46

    作者:文/会员上传

    简介:

    建表CREATETABLE`globallocktable`(`id`int(11)NOTNULLAUTO_INCREMENT,`lockKey`varchar(60)NOTNULLCOMMENT'锁名称',`createTime`datetimeNOTNULLCOMMENT'创建

    以下为本文的正文内容,内容仅供参考!本站为公益性网站,复制本文以及下载DOC文档全部免费。

    建表

    CREATETABLE`globallocktable`(`id`int(11)NOTNULLAUTO_INCREMENT,`lockKey`varchar(60)NOTNULLCOMMENT'锁名称',`createTime`datetimeNOTNULLCOMMENT'创建时间',PRIMARYKEY(`id`),UNIQUEKEY`lockKey`(`lockKey`))ENGINE=InnoDBDEFAULTCHARSET=utf8ROW_FORMAT=DYNAMICCOMMENT='全局锁';

    让别人使用的组件

    @ComponentpublicclassGlobalLockComponent{@ResourceGlobalLockTableDAOglobalLockDAO;/***尝试获得锁,成功为true,失败为false*/publicbooleantryLock(Stringkey){returnGlobalLockUtil.tryLock(this.globalLockDAO,key);}/***如果已经有其他程序占用该锁,并且超过timeoutMs(毫秒)时间,就强制清除这个锁占用*即根据key先删除记录,再添加记录*/publicbooleantryLockWithClear(Stringkey,LongtimeoutMs){returnGlobalLockUtil.tryLockWithClear(this.globalLockDAO,key,timeoutMs);}/***释放锁,根据key删除记录*/publicvoidreleasLock(Stringkey){GlobalLockUtil.releasLock(this.globalLockDAO,key);}}

    锁对象定义如下

    publicclassGlobalLockTable{privateIntegerid;privateStringlockKey;privateDatecreateTime;//省略get和set方法}GlobalLockTableDAO定义如下publicinterfaceGlobalLockTableDAO{intdeleteByPrimaryKey(Integerid);intdeleteByLockKey(StringlockKey);GlobalLockTableselectByLockKey(Stringkey);intinsertSelectiveWithTest(GlobalLockTablerecord);}

    具体加锁和解锁逻辑

    publicclassGlobalLockUtil{privatestaticLoggerlogger=LoggerFactory.getLogger(GlobalLockUtil.class);privatestaticGlobalLockTabletryLockInternal(GlobalLockTableDAOlockDAO,Stringkey){GlobalLockTableinsert=newGlobalLockTable();insert.setCreateTime(newDate());insert.setLockKey(key);//注意的地方1intcount=lockDAO.insertSelectiveWithTest(insert);if(count==0){GlobalLockTableready=lockDAO.selectByLockKey(key);logger.warn("cannotlockthekey:{},{},{}",insert.getLockKey(),ready.getCreateTime(),ready.getId());returnready;}logger.info("yesgotthelockbykey:{}",insert.getId(),insert.getLockKey());returnnull;}/**超时清除锁占用,并重新加锁**/publicstaticbooleantryLockWithClear(GlobalLockTableDAOlockDAO,Stringkey,LongtimeoutMs){GlobalLockTablelock=tryLockInternal(lockDAO,key);if(lock==null)returntrue;if(System.currentTimeMillis()-lock.getCreateTime().getTime()<=timeoutMs){logger.warn("sorry,cannotgetthekey.:{},{},{}",key,lock.getId(),lock.getCreateTime());returnfalse;}logger.warn("thekeyalreadytimeoutwthin:{},{},willclear",key,timeoutMs);//注意的地方2intcount=lockDAO.deleteByPrimaryKey(lock.getId());if(count==0){logger.warn("sorry,thekeyalreadypreemptivedbyothers:{},{}",lock.getId(),lock.getLockKey());returnfalse;}lock=tryLockInternal(lockDAO,key);returnlock!=null?false:true;}/**加锁**/publicstaticbooleantryLock(GlobalLockTableDAOlockDAO,Stringkey){returntryLockInternal(lockDAO,key)==null?true:false;}/**解锁**/publicstaticvoidreleasLock(GlobalLockTableDAOlockDAO,Stringkey){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

    <insertid="insertSelectiveWithTest"useGeneratedKeys="true"keyProperty="id"parameterType="com.javashitang.middleware.lock.mysql.pojo.GlobalLockTable">insertinto`globallocktable`(`id`,`lockKey`,`createTime`)select#{id,jdbcType=INTEGER},#{lockKey,jdbcType=VARCHAR},#{createTime,jdbcType=TIMESTAMP}fromdualwherenotexists(select1fromgloballocktablewherelockKey=#{lockKey,jdbcType=VARCHAR})</insert>

    使用

    当我们想使用时,就只写业务逻辑就行了,非常方便

    if(!globalLockComponent.tryLock(name)){//没有获取到锁返回return;}try{//这里写业务逻辑}catch(Exceptione){}finally{globalLockComponent.releasLock(name)
    怎么在MySQL数据库中实现一个分布式锁.docx

    将本文的Word文档下载到电脑

    推荐度:

    下载
    热门标签: mysql分布式锁