Apakah kunci masuk semula? Bagaimana untuk melaksanakan kunci masuk semula? Artikel berikut akan memberi anda perbincangan mendalam tentang cara redis melaksanakan kunci kemasukan semula yang diedarkan saya harap ia akan membantu anda!
Iaitu, jika benang semasa melaksanakan kaedah dan telah memperoleh kunci, maka apabila cuba memperoleh kunci semula dalam kaedah, ia tidak akan dapat memperolehnya dan akan disekat.
Kunci masuk semula, juga dipanggil kunci rekursif, bermakna dalam benang yang sama, selepas fungsi luar memperoleh kunci, fungsi rekursif dalam masih boleh mendapatkan kunci. Iaitu, apabila benang yang sama memasuki kod yang sama sekali lagi, ia boleh mendapatkan kunci semula.
Elakkan kebuntuan daripada memperoleh kunci beberapa kali dalam urutan yang sama.
Nota: 在java的编程中synchronized 和 ReentrantLock都是可重入锁。
Langkah 1: Logik penguncian dua kali
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();
}
}
}Langkah 2: Tambah kelas ujian
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();
}
}Langkah 3: Ujian< . kedua-dua kaedah boleh kunci dilepaskan dan benang lain boleh mengambil kunci Iaitu, benang boleh mendapat kunci yang sama beberapa kali dan boleh masuk semula. Jadi disegerakkan juga kunci reentrant.
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
轮询、超时、中断
Langkah 2: Tambah kelas ujian < . dikunci dan dibuka berbilang kali, dan ReentrantLock ialah reentrant.
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();
}
}
}Bagaimana redis melaksanakan kunci kemasukan semula yang diedarkan? Walaupun setnx boleh melaksanakan kunci yang diedarkan, ia bukan reentrant dalam sesetengah senario perniagaan yang rumit, apabila kita memerlukan kunci reentrant yang diedarkan. Masih terdapat banyak penyelesaian untuk kunci kemasukan semula redis dalam industri, dan yang paling popular pada masa ini ialah menggunakan
. [Cadangan berkaitan: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();
}
}]Apakah Redisson?
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次--------
Dari segi fungsi kunci yang diedarkan, ia menyediakan satu siri kunci yang diedarkan seperti: RedissonReentrant Lock (Reentrant Lock)
Kunci tidak adil ReadWriteLock (ReadWriteLock)
MultiLock (MultiLock)Kunci tiga tindakan penguncian:
Kunci lalailock.tryLock();
Menyokong fungsi buka kunci tamat tempoh, membuka kunci secara automatik selepas 10 saat tamat tempoh
lock.tryLock(10, TimeUnit.SECONDS);
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());
}
}
}最佳实战：
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）等相关功能，我们下篇文章再详细研究。
更多编程相关知识，请访问：编程入门！！
Atas ialah kandungan terperinci Apakah kunci masuk semula? Penjelasan terperinci tentang cara redis melaksanakan kunci kemasukan semula yang diedarkan. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!
Perisian pangkalan data yang biasa digunakan
Apakah pangkalan data dalam memori?
Yang manakah mempunyai kelajuan bacaan yang lebih pantas, mongodb atau redis?
Cara menggunakan redis sebagai pelayan cache
Bagaimana redis menyelesaikan ketekalan data
Bagaimanakah mysql dan redis memastikan konsistensi penulisan dua kali?
Apakah data yang biasanya disimpan oleh redis cache?
Apakah 8 jenis data redis
![[Web front-end] Permulaan pantas Node.js](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
