189 8069 5689
今天就跟大家聊聊有关java中MySQL分布式锁的是什么，可能很多人都不太了解，为了让大家更加了解，小编给大家总结了以下内容，希望大家根据这篇文章可以有所收获。
10年积累的做网站、成都网站设计经验，可以快速应对客户对网站的新想法和需求。提供各种问题对应的解决方案。让选择我们的客户得到更好、更有力的网络服务。我虽然不认识你，你也不认识我。但先做网站设计后付款的网站建设流程，更有林周免费网站建设让你可以放心的选择与我们合作。
（1）什么是分布式锁？
（2）为什么需要分布式锁？
（3）mysql如何实现分布式锁？
（4）mysql分布式锁的优点和缺点？
随着并发量的不断增加，单机的服务迟早要向多节点或者微服务进化，这时候原来单机模式下使用的synchronized或者ReentrantLock将不再适用，我们迫切地需要一种分布式环境下保证线程安全的解决方案，今天我们一起来学习一下mysql分布式锁如何实现分布式线程安全。
mysql中提供了两个函数——get_lock('key', timeout)和release_lock('key')——来实现分布式锁，可以根据key来加锁，这是一个字符串，可以设置超时时间（单位：秒），当调用release_lock('key')或者客户端断线的时候释放锁。
它们的使用方法如下：
mysql> select get_lock('user_1', 10);
-> 1
mysql> select release_lock('user_1');
-> 1get_lock('user_1', 10)如果10秒之内获取到锁则返回1，否则返回0；
release_lock('user_1')如果该锁是当前客户端持有的则返回1，如果该锁被其它客户端持有着则返回0，如果该锁没有被任何客户端持有则返回null；
为了便于举例，本文由公从号“彤哥读源码”原创，这里的超时时间全部设置为0，也就是立即返回。
| 时刻 | 客户端A | 客户端B |
|---|---|---|
| 1 | get_lock('user_1', 0) -> 1 | - |
| 2 | - | get_lock('user_1', 0) -> 0 |
| 3 | - | release_lock('user_1', 0) -> 0 |
| 4 | release_lock('user_1', 0) -> 1 | - |
| 5 | release_lock('user_2', 0) -> null | - |
| 6 | - | get_lock('user_1', 0) -> 1 |
| 7 | - | release_lock('user_1', 0) -> 1 |
为了方便快速实现，这里使用 springboot2.1 + mybatis 实现，并且省略spring的配置，只列举主要的几个类。
接口中只有一个方法，入参1为加锁的key，入参2为执行的命令。
public interface Locker {
void lock(String key, Runnable command);
}mysql的实现中要注意以下两点：
（1）加锁、释放锁必须在同一个session（同一个客户端）中，所以这里不能使用Mapper接口的方式调用，因为Mapper接口有可能会导致不在同一个session。
（2）可重入性是通过ThreadLocal保证的；
@Slf4j
@Component
public class MysqlLocker implements Locker {
private static final ThreadLocal localSession = new ThreadLocal<>();
@Autowired
private SqlSessionFactory sqlSessionFactory;
@Override
public void lock(String key, Runnable command) {
// 加锁、释放锁必须使用同一个session
SqlSessionWrapper sqlSessionWrapper = localSession.get();
if (sqlSessionWrapper == null) {
// 第一次获取锁
localSession.set(new SqlSessionWrapper(sqlSessionFactory.openSession()));
}
try {
// 本文由公从号“彤哥读源码”原创
// -1表示没获取到锁一直等待
if (getLock(key, -1)) {
command.run();
}
} catch (Exception e) {
log.error("lock error", e);
} finally {
releaseLock(key);
}
}
private boolean getLock(String key, long timeout) {
Map param = new HashMap<>();
param.put("key", key);
param.put("timeout", timeout);
SqlSessionWrapper sqlSessionWrapper = localSession.get();
Integer result = sqlSessionWrapper.sqlSession.selectOne("LockerMapper.getLock", param);
if (result != null && result.intValue() == 1) {
// 获取到了锁，state加1
sqlSessionWrapper.state++;
return true;
}
return false;
}
private boolean releaseLock(String key) {
SqlSessionWrapper sqlSessionWrapper = localSession.get();
Integer result = sqlSessionWrapper.sqlSession.selectOne("LockerMapper.releaseLock", key);
if (result != null && result.intValue() == 1) {
// 释放锁成功，state减1
sqlSessionWrapper.state--;
// 当state减为0的时候说明当前线程获取的锁全部释放了，则关闭session并从ThreadLocal中移除
if (sqlSessionWrapper.state == 0) {
sqlSessionWrapper.sqlSession.close();
localSession.remove();
}
return true;
}
return false;
}
private static class SqlSessionWrapper {
int state;
SqlSession sqlSession;
public SqlSessionWrapper(SqlSession sqlSession) {
this.state = 0;
this.sqlSession = sqlSession;
}
}
} 定义get_lock()、release_lock()的语句。