mysql实现分布式锁

1、最近再学分布式锁，把自己所学的一点心得分享给大家
2、首先介绍我的spring boot项目结构

 数据库表的结构很简单，t_lock表就一个主键字段id

 3、实现锁的代码

这里运用了模板设计模式

锁接口：

public interface TestLock {

 

/**

* 加锁

*/

public void getLock();

/**

* 解锁

*/

public void unLock();

 

}

锁的抽象实现类：

public abstract class AbstractTestLock implements TestLock{

 

@Override

public void getLock() {

/**

* 1、竞争锁

* 2、占有锁

* 3、任务阻塞

* 4、释放锁

*/

if(tryLock()) {

System.out.println("========获取锁的资源===========");

}else {

//等待

waitLock();

//重新获取资源

getLock();

}

}

public abstract void waitLock();

public abstract boolean tryLock();

}

 锁的实现：

@Service

public class MySqlLock extends AbstractTestLock{

 

@Resource

private LockMapper lockMapper;

 

private static final Integer ID = 1;

 

@Override

public boolean tryLock() {

try {

Lock lock = new Lock();

lock.setId(ID);

lockMapper.save(lock);

}catch (Exception e) {

return false;

}

return true;

}

 

@Override

public void unLock() {

lockMapper.delete(ID);

}

 

@Override

public void waitLock() {

try {

Thread.currentThread().sleep(10);

}catch (Exception e) {

e.printStackTrace();

}

}

 

}

仿照订单生成：

public class OrderGenerator {

// 全局订单号

public static int num = 0;

 

public String getNumber() {

SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

return sdf.format(new Date())+"-"+ ++num;

}

}

 

4、测试

public class MysqlLockTest extends LockApplicationTests{

 

public OrderGenerator generator = new OrderGenerator();

 

@Resource

private TestLock lock;

 

@Test

public void testGetOrderNum() throws InterruptedException {

System.out.println("=======生成唯一订单号==========");

for(int i=0; i< 50 ; i++) {

new Thread(

(Runnable) () -> { getNumber(); }

).start();

}

Thread.currentThread().join();

}

 

private void getNumber() {

try {

lock.getLock();

String number = generator.getNumber();

System.out.println(Thread.currentThread().getName() + ",生成订单ID:"+ number);

}catch (Exception e) {

e.printStackTrace();

}finally {

lock.unLock();

}

}

 

}

 

测试结果：

 可以看见总共生成了50个订单号，没有重复出现同样的订单号，这样子就实现了用mysql实现分布式锁。

 

5、使用mysql实现分布式锁的弊端：

    a、性能差，无法适应高并发场景，众所周知，mysql的并发瓶颈在300-700之间，当然也有可能达不到，所以一旦并发超过700的话，那么mysql就没法应用于此场景；

    b、容易死锁，一旦数据库中数据一开始有数据，那么就会一直处于死锁状态，或者删除数据失败，那么也会一直处于死锁；

    c、无法优雅的实现阻塞式锁。