Was ist eine Wiedereintrittssperre? Wie implementiert man eine Wiedereintrittssperre? Der folgende Artikel gibt Ihnen eine ausführliche Diskussion darüber, wie Redis verteilte Wiedereintrittssperren implementiert. Ich hoffe, er wird Ihnen hilfreich sein!
Das heißt, wenn der aktuelle Thread eine Methode ausführt und die Sperre erworben hat, kann er sie beim erneuten Versuch, die Sperre in der Methode zu erlangen, nicht erlangen und wird blockiert.
Wiedereintretende Sperre, auch rekursive Sperre genannt, bedeutet, dass im selben Thread die innere rekursive Funktion die Sperre weiterhin erhalten kann, nachdem die äußere Funktion die Sperre erhalten hat. Das heißt, wenn derselbe Thread denselben Code erneut eingibt, kann er die Sperre erneut erhalten.
Verhindern Sie, dass ein Deadlock die Sperre mehrmals im selben Thread erhält.
Hinweis: In der Java-Programmierung sind synchronisiert und ReentrantLock beide Wiedereintrittssperren. 在java的编程中synchronized 和 ReentrantLock都是可重入锁。
步骤1：双重加锁逻辑
public class SynchronizedDemo {
//模拟库存100
int count=100;
public synchronized void operation(){
log.info("第一层锁:减库存");
//模拟减库存
count--;
add();
log.info("下订单结束库存剩余:{}",count);
}
private synchronized void add(){
log.info("第二层锁：插入订单");
try {
Thread.sleep(1000*10);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}步骤2：加个测试类
public static void main(String[] args) {
SynchronizedDemo synchronizedDemo=new SynchronizedDemo();
for (int i = 0; i < 3; i++) {
int finalI = i;
new Thread(()->{
log.info("-------用户{}开始下单--------", finalI);
synchronizedDemo.operation();
}).start();
}
}步骤3：测试
20:44:04.013 [Thread-2] INFO com.agan.redis.controller.SynchronizedController - -------用户2开始下单-------- 20:44:04.013 [Thread-1] INFO com.agan.redis.controller.SynchronizedController - -------用户1开始下单-------- 20:44:04.013 [Thread-0] INFO com.agan.redis.controller.SynchronizedController - -------用户0开始下单-------- 20:44:04.016 [Thread-2] INFO com.agan.redis.Reentrant.SynchronizedDemo - 第一层锁:减库存 20:44:04.016 [Thread-2] INFO com.agan.redis.Reentrant.SynchronizedDemo - 第二层锁：插入订单 20:44:14.017 [Thread-2] INFO com.agan.redis.Reentrant.SynchronizedDemo - 下订单结束库存剩余:99 20:44:14.017 [Thread-0] INFO com.agan.redis.Reentrant.SynchronizedDemo - 第一层锁:减库存 20:44:14.017 [Thread-0] INFO com.agan.redis.Reentrant.SynchronizedDemo - 第二层锁：插入订单 20:44:24.017 [Thread-0] INFO com.agan.redis.Reentrant.SynchronizedDemo - 下订单结束库存剩余:98 20:44:24.017 [Thread-1] INFO com.agan.redis.Reentrant.SynchronizedDemo - 第一层锁:减库存 20:44:24.017 [Thread-1] INFO com.agan.redis.Reentrant.SynchronizedDemo - 第二层锁：插入订单 20:44:34.017 [Thread-1] INFO com.agan.redis.Reentrant.SynchronizedDemo - 下订单结束库存剩余:97
ReentrantLock，是一个可重入且独占式的锁，是一种递归无阻塞的同步锁。和synchronized关键字相比，它更灵活、更强大，增加了轮询、超时、中断等高级功能。
步骤1：双重加锁逻辑
public class ReentrantLockDemo {
private Lock lock = new ReentrantLock();
public void doSomething(int n){
try{
//进入递归第一件事：加锁
lock.lock();
log.info("--------递归{}次--------",n);
if(n<=2){
try {
Thread.sleep(1000*2);
} catch (InterruptedException e) {
e.printStackTrace();
}
this.doSomething(++n);
}else{
return;
}
}finally {
lock.unlock();
}
}
}步骤2：加个测试类
public static void main(String[] args) {
ReentrantLockDemo reentrantLockDemo=new ReentrantLockDemo();
for (int i = 0; i < 3; i++) {
int finalI = i;
new Thread(()->{
log.info("-------用户{}开始下单--------", finalI);
reentrantLockDemo.doSomething(1);
}).start();
}
}步骤3：测试
20:55:23.533 [Thread-1] INFO com.agan.redis.controller.ReentrantController - -------用户1开始下单-------- 20:55:23.533 [Thread-2] INFO com.agan.redis.controller.ReentrantController - -------用户2开始下单-------- 20:55:23.533 [Thread-0] INFO com.agan.redis.controller.ReentrantController - -------用户0开始下单-------- 20:55:23.536 [Thread-1] INFO com.agan.redis.Reentrant.ReentrantLockDemo - --------递归1次-------- 20:55:25.537 [Thread-1] INFO com.agan.redis.Reentrant.ReentrantLockDemo - --------递归2次-------- 20:55:27.538 [Thread-1] INFO com.agan.redis.Reentrant.ReentrantLockDemo - --------递归3次-------- 20:55:27.538 [Thread-2] INFO com.agan.redis.Reentrant.ReentrantLockDemo - --------递归1次-------- 20:55:29.538 [Thread-2] INFO com.agan.redis.Reentrant.ReentrantLockDemo - --------递归2次-------- 20:55:31.539 [Thread-2] INFO com.agan.redis.Reentrant.ReentrantLockDemo - --------递归3次-------- 20:55:31.539 [Thread-0] INFO com.agan.redis.Reentrant.ReentrantLockDemo - --------递归1次-------- 20:55:33.539 [Thread-0] INFO com.agan.redis.Reentrant.ReentrantLockDemo - --------递归2次-------- 20:55:35.540 [Thread-0] INFO com.agan.redis.Reentrant.ReentrantLockDemo - --------递归3次--------
setnx虽然可以实现分布式锁，但是不可重入，在一些复杂的业务场景，我们需要分布式重入锁时,
对于redis的重入锁业界还是有很多解决方案的，目前最流行的就是采用RedissonWiedereintrittssperre basierend auf synchronisiertem
Schritt 1: Doppelte Sperrlogik
public class RedisController {
@Autowired
RedissonClient redissonClient;
@GetMapping(value = "/lock")
public void get(String key) throws InterruptedException {
this.getLock(key, 1);
}
private void getLock(String key, int n) throws InterruptedException {
//模拟递归，3次递归后退出
if (n > 3) {
return;
}
//步骤1：获取一个分布式可重入锁RLock
//分布式可重入锁RLock :实现了java.util.concurrent.locks.Lock接口，同时还支持自动过期解锁。
RLock lock = redissonClient.getLock(key);
//步骤2：尝试拿锁
// 1. 默认的拿锁
//lock.tryLock();
// 2. 支持过期解锁功能,10秒钟以后过期自动解锁, 无需调用unlock方法手动解锁
//lock.tryLock(10, TimeUnit.SECONDS);
// 3. 尝试加锁，最多等待3秒，上锁以后10秒后过期自动解锁
// lock.tryLock(3, 10, TimeUnit.SECONDS);
boolean bs = lock.tryLock(3, 10, TimeUnit.SECONDS);
if (bs) {
try {
// 业务代码
log.info("线程{}业务逻辑处理: {},递归{}" ,Thread.currentThread().getName(), key,n);
//模拟处理业务
Thread.sleep(1000 * 5);
//模拟进入递归
this.getLock(key, ++n);
} catch (Exception e) {
log.error(e.getLocalizedMessage());
} finally {
//步骤3：解锁
lock.unlock();
log.info("线程{}解锁退出",Thread.currentThread().getName());
}
} else {
log.info("线程{}未取得锁",Thread.currentThread().getName());
}
}
}线程http-nio-9090-exec-1业务逻辑处理: ljw,递归1 线程http-nio-9090-exec-2未取得锁 线程http-nio-9090-exec-1业务逻辑处理: ljw,递归2 线程http-nio-9090-exec-3未取得锁 线程http-nio-9090-exec-1业务逻辑处理: ljw,递归3 线程http-nio-9090-exec-1解锁退出 线程http-nio-9090-exec-1解锁退出 线程http-nio-9090-exec-1解锁退出
Polling, Timeout und Interrupt. 🔜 Die Ergebnisse können in jedem Thread gesehen werden kann mehrmals gesperrt und entsperrt werden, und ReentrantLock ist wiedereintrittsfähig. Obwohl setnx verteilte Sperren implementieren kann, ist es in einigen komplexen Geschäftsszenarien nicht wiedereintrittsfähig, wenn wir verteilte wiedereintrittsfähige Sperren benötigen.
Es gibt viele Lösungen für die Wiedereintrittssperre von Redis in der Branche, und die beliebteste ist derzeit die Verwendung von Redisson. [Verwandte Empfehlungen: Redis-Video-Tutorial]
Was ist Redisson?
Basierend auf den gemeinsamen Schnittstellen im Java Utility Toolkit bietet es Benutzern eine Reihe häufig verwendeter Toolklassen mit verteilten Eigenschaften.Redisson ist die von Redis offiziell empfohlene Java-Version des Redis-Clients.
In Bezug auf die Netzwerkkommunikation basiert es auf dem Netty-Framework von NIO, um eine hohe Leistung der Netzwerkkommunikation sicherzustellen.
In Bezug auf die Funktion verteilter Sperren bietet es eine Reihe verteilter Sperren, z. B.: ReadWriteLock)Interlock(MultiLock)最佳实战：
lock.lock(10,TimeUnit.SECONDS); 省掉看门狗续期操作，自动解锁时间一定要大于业务执行时间，手动解锁
步骤3:测试
访问3次：http://127.0.0.1:9090/lock?key=ljw
线程http-nio-9090-exec-1业务逻辑处理: ljw,递归1 线程http-nio-9090-exec-2未取得锁 线程http-nio-9090-exec-1业务逻辑处理: ljw,递归2 线程http-nio-9090-exec-3未取得锁 线程http-nio-9090-exec-1业务逻辑处理: ljw,递归3 线程http-nio-9090-exec-1解锁退出 线程http-nio-9090-exec-1解锁退出 线程http-nio-9090-exec-1解锁退出
通过测试结果：
上面介绍了分布式重入锁的相关知识，证明了Redisson工具能实现了可重入锁的功能。其实Redisson工具包中还包含了读写锁（ReadWriteLock）和 红锁（RedLock）等相关功能，我们下篇文章再详细研究。
更多编程相关知识，请访问：编程入门！！
Das obige ist der detaillierte Inhalt vonWas ist eine Wiedereintrittssperre? Detaillierte Erläuterung, wie Redis verteilte Wiedereintrittssperren implementiert. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!
Häufig verwendete Datenbanksoftware
Was sind In-Memory-Datenbanken?
Welches hat eine schnellere Lesegeschwindigkeit, Mongodb oder Redis?
So verwenden Sie Redis als Cache-Server
Wie Redis die Datenkonsistenz löst
Wie stellen MySQL und Redis die Konsistenz beim doppelten Schreiben sicher?
Welche Daten speichert der Redis-Cache im Allgemeinen?
Was sind die 8 Datentypen von Redis?
![[Web-Frontend] Node.js-Schnellstart](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
