基于数据库实现分布式锁

叁歲伎倆 2022-09-07 15:51 146阅读 0赞

基于数据库行记录实现的分布式锁基本方式，创建一张表，其中有一个代表资源的字段resource.同时需要对该字段加上唯一性约束。加锁时就往这张表里面添加一条记录，解锁时就把这条记录删掉。当然了还有很多其他的问题，例如性能，过期时间等。这些问题都暂不考虑.

1.创建表

CREATE TABLE \`yh\_distribute\_lock\` (  
  \`id\` bigint(20) NOT NULL AUTO\_INCREMENT COMMENT '主键id',  
  \`resource\` varchar(255) DEFAULT NULL COMMENT '锁定资源',  
  PRIMARY KEY (\`id\`),  
  UNIQUE KEY \`uiq\_idx\_resource\` (\`resource\`) USING BTREE  
) ENGINE=InnoDB AUTO\_INCREMENT=28 DEFAULT CHARSET=utf8;

2.加锁代码

/**
         * 加上分布式锁，基于数据库实现 
         * 插入一条有唯一索引的记录
         * 基于数据库实现的分布式锁的缺点:
         * 这把锁强依赖数据库的可用性，数据库是一个单点，一旦数据库挂掉，会导致业务系统不可用。
         *
         * 这把锁没有失效时间，一旦解锁操作失败，就会导致锁记录一直在数据库中，其他线程无法再获得到锁。
         *
         * 这把锁是非重入的，同一个线程在没有释放锁之前无法再次获得该锁。因为数据中数据已经存在了。
         *
         * 这把锁是非公平锁，所有等待锁的线程凭运气去争夺锁。
         * @param resource        资源
         */
        @Override
        @Transactional
        public void lock(String resource) {
            YhDistributeLockDAO distributeLock = new YhDistributeLockDAO();
            distributeLock.setResource(resource);
            this.save(distributeLock);
        }

解锁代码

/**
         * 解除分布式锁，基于数据库实现
         * 删除这条记录
         * @param resource  资源
         */
        @Override
        @Transactional
        public void unLock(String resource) {
            EntityWrapper<YhDistributeLockDAO> entityWrapper = new EntityWrapper<>();
            entityWrapper.eq("resource", resource);
            delete(entityWrapper);
        }