Penyelesaian raja antara kunci yang diedarkan - Redisson

Terdapat pelbagai penyelesaian di Internet untuk melaksanakan kunci teragih di Redis, tetapi apakah penyelesaian raja?

Jawapannya ialah: Redisson.

Mari kita lihat dahulu apa yang dikatakan oleh tapak web rasmi Redis tentang kunci teragih:

Dan versi Java rangka kerja kunci teragih ialah Redisson.

Kandungan praktikal ini akan berdasarkan projek sumber terbuka saya PassJava untuk menyepadukan Redisson.

Saya letak 后端、前端、小程序都上传到同一个仓库里面了，大家可以通过 Github 或 码云lawatan. Alamatnya adalah seperti berikut:

Github: https://github.com/Jackson0714/PassJava-Platform

Code Cloud: https://gitee.com/jayh2018/PassJava-Platform

Code Cloud: https://gitee.com/jayh2018/PassJava- Tutorial

: www.passjava.cn

Sebelum pertempuran sebenar, mari kita lihat dahulu prinsip penggunaan Redisson. 🎜

1. Apakah itu Redisson?

Jika anda pernah menggunakan Redis sebelum ini, anda akan mendapat hasil dua kali ganda dengan separuh usaha dengan menggunakan Redisson menyediakan cara yang paling mudah dan mudah untuk menggunakan Redis.

Tujuan Redisson adalah untuk mempromosikan pengasingan kebimbangan pengguna (Separation of Concern) tentang Redis, supaya pengguna boleh lebih menumpukan pada memproses logik perniagaan.

Redisson ialah Grid Data Dalam Memori Java yang dilaksanakan berdasarkan Redis.

• Rangka kerja Netty: Redisson mengguna pakai rangka kerja Netty berasaskan NIO, yang bukan sahaja boleh berfungsi sebagai pelanggan pemacu asas Redis, tetapi juga menyediakan fungsi sambungan untuk pelbagai konfigurasi Redis, dan boleh menyegerakkan arahan Redis . Fungsi penghantaran, penghantaran tak segerak, penghantaran aliran tak segerak atau penghantaran saluran paip, pemprosesan pelaksanaan skrip LUA, dan fungsi memproses hasil yang dikembalikan

• Struktur data asas: Redis asli Hash，List，Set，String，Geo，HyperLogLog等数据结构封装为Java里大家最熟悉的映射（Map），列表（List），集（Set），通用对象桶（Object Bucket），地理空间对象桶（Geospatial Bucket），基数估计算法（HyperLogLog） dan struktur lain,

• Struktur data teragih: Atas dasar ini, ia juga menyediakan pemetaan berbilang tempatan, pemetaan berbilang (LocalCachedMap), set tersusun (SortedSet), set diisih markah (ScoredSortedSet), set diisih kamus (LexSortedSet), baris gilir (Baris Gilir), baris gilir menyekat (Baris Gilir Penyekat), baris gilir sekatan bersempadan (Baris Gilir Penyekatan Terhad), Deque berganda, Deque Menyekat , Menyekat Baris Adil, Baris Tertunda, Penapis Mekar, AtomicLong, Nombor titik terapung Ketepatan Berganda Atom (AtomicDouble), BitSet dan struktur data teragih lain yang pada asalnya tidak ada pada Redis.

• Kunci teragih: Redisson juga melaksanakan kunci teragih yang disebut dalam dokumen Redis LockSenario aplikasi yang lebih maju. Malah, Redisson tidak berhenti di situ berdasarkan kunci yang diedarkan, ia juga menyediakan MultiLock ), ReadWriteLock (ReadWriteLock), Kunci Adil, RedLock, Semaphore, Semaphore Boleh Luput (PermitExpirableSemaphore) dan Latch (CountDownLatch) Ini adalah komponen asas yang penting untuk aplikasi konkurensi tinggi berbilang benang. Melalui pelaksanaan penyelesaian aplikasi peringkat tinggi berdasarkan Redis, Redisson menjadi alat penting untuk membina sistem teragih. Lock这样的更高阶应用场景。事实上Redisson并没有不止步于此，在分布式锁的基础上还提供了联锁（MultiLock），读写锁（ReadWriteLock），公平锁（Fair Lock），红锁（RedLock），信号量（Semaphore），可过期性信号量（PermitExpirableSemaphore）和闭锁（CountDownLatch）这些实际当中对多线程高并发应用至关重要的基本部件。正是通过实现基于Redis的高阶应用方案，使Redisson成为构建分布式系统的重要工具。

• 节点：Redisson作为独立节点可以用于独立执行其他节点发布到分布式执行服务和分布式调度服务

Nod: Redisson sebagai nod bebas boleh digunakan untuk melaksanakan secara bebas nod lain yang diterbitkan ke Perkhidmatan pelaksanaan Gaya Pengedaran dan <p data-tool="mdnice编辑器" style="margin-bottom: 20px;line-height: 1.8em;color: rgb(58, 58, 58);"></p> <ul class="list-paddingleft-2" data-tool="mdnice编辑器" style="margin-top: 8px;margin-bottom: 8px;padding-left: 25px;"> <li><section style="margin-top: 5px;margin-bottom: 5px;line-height: 26px;color: rgb(1, 1, 1);">2. Integrate Redisson</section></li> <li>Spring Boot integration Redisson mempunyai dua penyelesaian: <section style="margin-top: 5px;margin-bottom: 5px;line-height: 26px;color: rgb(1, 1, 1);"></section> </li> </ul>Konfigurasi program. <p data-tool="mdnice编辑器" style="margin-bottom: 20px;line-height: 1.8em;color: rgb(58, 58, 58);"></p>🎜🎜Konfigurasi mod fail. 🎜🎜🎜🎜Artikel ini memperkenalkan cara mengintegrasikan Redisson secara pemrograman. 🎜<h3 data-tool="mdnice编辑器" style="font-weight: bold;font-size: 20px;line-height: 1.4;padding-top: 10px;margin-top: 10px;margin-bottom: 5px;"><span style="color: rgb(81, 81, 81);font-size: 1em;padding-left: 20px;border-left: 3px solid rgb(249, 191, 69);">2.1 Memperkenalkan kebergantungan Maven </span></h3> <p data-tool="mdnice编辑器" style="margin-bottom: 20px;line-height: 1.8em;color: rgb(58, 58, 58);">Perkenalkan kebergantungan maven redisson dalam pom.xml perkhidmatan mikro soalan passjava. </p><pre class="brush:php;toolbar:false;">&lt;!-- https://mvnrepository.com/artifact/org.redisson/redisson --&gt; &lt;dependency&gt; &lt;groupId&gt;org.redisson&lt;/groupId&gt; &lt;artifactId&gt;redisson&lt;/artifactId&gt; &lt;version&gt;3.15.5&lt;/version&gt; &lt;/dependency&gt;</pre><h3 data-tool="mdnice编辑器" style="font-weight: bold;font-size: 20px;line-height: 1.4;padding-top: 10px;margin-top: 10px;margin-bottom: 5px;"><span style="color: rgb(81, 81, 81);font-size: 1em;padding-left: 20px;border-left: 3px solid rgb(249, 191, 69);">2.2 Kelas konfigurasi tersuai</span></h3> <p data-tool="mdnice编辑器" style="margin-bottom: 20px;line-height: 1.8em;color: rgb(58, 58, 58);">Kod berikut ialah konfigurasi nod tunggal Redis. </p><pre class="brush:php;toolbar:false;">@Configuration public class MyRedissonConfig { /** * 对 Redisson 的使用都是通过 RedissonClient 对象 * @return * @throws IOException */ @Bean(destroyMethod=&quot;shutdown&quot;) // 服务停止后调用 shutdown 方法。 public RedissonClient redisson() throws IOException { // 1.创建配置 Config config = new Config(); // 集群模式 // config.useClusterServers().addNodeAddress(&quot;127.0.0.1:7004&quot;, &quot;127.0.0.1:7001&quot;); // 2.根据 Config 创建出 RedissonClient 示例。 config.useSingleServer().setAddress(&quot;redis://127.0.0.1:6379&quot;); return Redisson.create(config); } }</pre><h3 data-tool="mdnice编辑器" style="font-weight: bold;font-size: 20px;line-height: 1.4;padding-top: 10px;margin-top: 10px;margin-bottom: 5px;"><span style="color: rgb(81, 81, 81);font-size: 1em;padding-left: 20px;border-left: 3px solid rgb(249, 191, 69);">2.3 Kelas konfigurasi ujian</span></h3> <p data-tool="mdnice编辑器" style="margin-bottom: 20px;line-height: 1.8em;color: rgb(58, 58, 58);">Buat kaedah ujian unit baharu. </p><pre class="brush:php;toolbar:false;">@Autowired RedissonClient redissonClient; @Test public void TestRedisson() { System.out.println(redissonClient); }</pre><p data-tool="mdnice编辑器" style="margin-bottom: 20px;line-height: 1.8em;color: rgb(58, 58, 58);">Kami menjalankan kaedah ujian ini dan mencetak redissonClient</p><pre class="brush:php;toolbar:false;">org.redisson.Redisson@77f66138</pre><h2 data-tool="mdnice编辑器" style="font-weight: bold;font-size: 22px;line-height: 1.5em;margin-top: 2.2em;margin-bottom: 35px;"><span style="display: inline-block;background-image: linear-gradient(rgb(255, 255, 255) 60%, rgb(255, 177, 27) 40%);background-position: initial;background-size: initial;background-repeat: initial;background-attachment: initial;background-origin: initial;background-clip: initial;color: rgb(81, 81, 81);padding: 2px 13px;margin-right: 3px;height: 50%;"> 3. Kunci reentrant yang diedarkan</span></h2> <h3 data-tool="mdnice编辑器" style="font-weight: bold;font-size: 20px;line-height: 1.4;padding-top: 10px;margin-top: 10px;margin-bottom: 5px;"><span style="color: rgb(81, 81, 81);font-size: 1em;padding-left: 20px;border-left: 3px solid rgb(249, 191, 69);">3.1 Ujian kunci reentrant</span></h3> <p data-tool="mdnice编辑器" style="margin-bottom: 20px;line-height: 1.8em;color: rgb(58, 58, 58);">Redisson px1 reentrant style based on:4scode reentrant distributed px;4 jejari sempadan: 4px;font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;word-break: break-all;color: rgb(155, 110, 35); 245, 227);padding: 3px;margin: 3px;">RLock</p>Implementasi objek Javajava .util.concurrent.locks.Lockantara muka. Ia juga menyediakan antara muka standard tak segerak (Async), reflektif (Reaktif) dan RxJava2. RLockJava 对象实现了java.util.concurrent.locks.Lock接口。同时还提供了异步（Async）、反射式（Reactive）和RxJava2标准的接口。

RLock lock = redisson.getLock("anyLock");
// 最常见的使用方法
lock.lock();

我们用 passjava 这个开源项目测试下可重入锁的两个点：

• （1）多个线程抢占锁，后面锁需要等待吗？
• （2）如果抢占到锁的线程所在的服务停了，锁会不会被释放？

3.1.1 验证一：可重入锁是阻塞的吗？

为了验证以上两点，我写了个 demo 程序：代码的流程就是设置WuKong-lock

@ResponseBody
@GetMapping("test-lock")
public String TestLock() {
    // 1.获取锁，只要锁的名字一样，获取到的锁就是同一把锁。
    RLock lock = redisson.getLock("WuKong-lock");

    // 2.加锁
    lock.lock();
    try {
        System.out.println("加锁成功，执行后续代码。线程 ID：" + Thread.currentThread().getId());
        Thread.sleep(10000);
    } catch (Exception e) {
        //TODO
    } finally {
        lock.unlock();
        // 3.解锁
        System.out.println("Finally，释放锁成功。线程 ID：" + Thread.currentThread().getId());
    }

    return "test lock ok";
}

Kami menggunakan projek sumber terbuka passjava untuk menguji dua titik penguncian masuk semula:

• (1) Jika berbilang benang merampas kunci, adakah mereka perlu menunggu kunci berikutnya?
• (2) Jika perkhidmatan di mana benang yang merampas kunci terletak berhenti, adakah kunci itu akan dilepaskan?

3.1.1 Pengesahan 1: Adakah kunci peserta semula menyekat?

Untuk mengesahkan dua perkara di atas, saya menulis program demo: proses kod adalah untuk menetapkan WuKong -lock mengunci, kemudian mengunci, mencetak ID benang, menunggu selama 10 saat dan kemudian melepaskan kunci, dan akhirnya mengembalikan respons: "uji kunci ok".

http://localhost:11000/question/v1/redisson/test/test-lock

Sahkan mata pertama dahulu dan gunakan dua permintaan http untuk menguji kunci preemption. 🎜🎜URL yang diminta: 🎜

http://localhost:11000/question/v1/redisson/test/test-lock

第一个线程对应的线程 ID 为 86，10秒后，释放锁。在这期间，第二个线程需要等待锁释放。

第一个线程释放锁之后，第二个线程获取到了锁，10 秒后，释放锁。

画了一个流程图，帮助大家理解。如下图所示：

• 第一步：线程 A 在 0 秒时，抢占到锁，0.1 秒后，开始执行等待 10 s。
• 第二步：线程 B 在 0.1 秒尝试抢占锁，未能抢到锁（被 A 抢占了）。
• 第三步：线程 A 在 10.1 秒后，释放锁。
• 第四步：线程 B 在 10.1 秒后抢占到锁，然后等待 10 秒后释放锁。

由此可以得出结论，Redisson 的可重入锁（lock）是阻塞其他线程的，需要等待其他线程释放的。

3.1.2 验证二：服务停了，锁会释放吗？

如果线程 A 在等待的过程中，服务突然停了，那么锁会释放吗？如果不释放的话，就会成为死锁，阻塞了其他线程获取锁。

我们先来看下线程 A 的获取锁后的，Redis 客户端查询到的结果，如下图所示：

WuKong-lock 有值，而且大家可以看到 TTL 在不断变小，说明 WuKong-lock 是自带过期时间的。

通过观察，经过 30 秒后，WuKong-lock 过期消失了。说明 Redisson 在停机后，占用的锁会自动释放。

那这又是什么原理呢？这里就要提一个概念了，看门狗。

3.2 看门狗原理

如果负责储存这个分布式锁的 Redisson 节点宕机以后，而且这个锁正好处于锁住的状态时，这个锁会出现锁死的状态。为了避免这种情况的发生，Redisson内部提供了一个监控锁的看门狗，它的作用是在Redisson实例被关闭前，不断的延长锁的有效期。

默认情况下，看门狗的检查锁的超时时间是30秒钟，也可以通过修改Config.lockWatchdogTimeout来另行指定。

如果我们未制定 lock 的超时时间，就使用 30 秒作为看门狗的默认时间。只要占锁成功，就会启动一个定时任务：每隔 10 秒重新给锁设置过期的时间，过期时间为 30 秒。

如下图所示：

看门狗原理图-1

当服务器宕机后，因为锁的有效期是 30 秒，所以会在 30 秒内自动解锁。（30秒等于宕机之前的锁占用时间+后续锁占用的时间）。

如下图所示：

看门狗原理图-2

3.3 设置锁过期时间

我们也可以通过给锁设置过期时间，让其自动解锁。

如下所示，设置锁 8 秒后自动过期。

lock.lock(8, TimeUnit.SECONDS);

如果业务执行时间超过 8 秒，手动释放锁将会报错，如下图所示：

所以我们如果设置了锁的自动过期时间，则执行业务的时间一定要小于锁的自动过期时间，否则就会报错。

四、王者方案

上一篇我讲解了分布式锁的五种方案：Redis 分布式锁｜从青铜到钻石的五种演进方案，这一篇主要是讲解如何用 Redisson 在 Spring Boot 项目中实现分布式锁的方案。

因为 Redisson 非常强大，实现分布式锁的方案非常简洁，所以称作王者方案。

原理图如下：

代码如下所示：

// 1.设置分布式锁
RLock lock = redisson.getLock("lock");
// 2.占用锁
lock.lock();
// 3.执行业务
...
// 4.释放锁
lock.unlock();

和之前 Redis 的方案相比，简洁很多。

下面讲解下 Redisson 的其他几种分布式锁，相信大家在以后的项目中也会用到。

五、分布式读写锁

基于 Redis 的 Redisson 分布式可重入读写锁RReadWriteLock Java对象实现了java.util.concurrent.locks.ReadWriteLock接口。其中读锁和写锁都继承了 RLock接口。

写锁是一个排他锁（互斥锁），读锁是一个共享锁。

• 读锁 + 读锁：相当于没加锁，可以并发读。
• 读锁 + 写锁：写锁需要等待读锁释放锁。
• 写锁 + 写锁：互斥，需要等待对方的锁释放。
• 写锁 + 读锁：读锁需要等待写锁释放。

示例代码如下：

RReadWriteLock rwlock = redisson.getReadWriteLock("anyRWLock");
// 最常见的使用方法
rwlock.readLock().lock();
// 或
rwlock.writeLock().lock();

另外Redisson还通过加锁的方法提供了leaseTime的参数来指定加锁的时间。超过这个时间后锁便自动解开了。

// 10秒钟以后自动解锁
// 无需调用unlock方法手动解锁
rwlock.readLock().lock(10, TimeUnit.SECONDS);
// 或
rwlock.writeLock().lock(10, TimeUnit.SECONDS);

// 尝试加锁，最多等待100秒，上锁以后10秒自动解锁
boolean res = rwlock.readLock().tryLock(100, 10, TimeUnit.SECONDS);
// 或
boolean res = rwlock.writeLock().tryLock(100, 10, TimeUnit.SECONDS);
...
lock.unlock();

六、分布式信号量

基于Redis的Redisson的分布式信号量（Semaphore）Java对象RSemaphore采用了与java.util.concurrent.Semaphore相似的接口和用法。同时还提供了异步（Async）、反射式（Reactive）和RxJava2标准的接口。

关于信号量的使用大家可以想象一下这个场景，有三个停车位，当三个停车位满了后，其他车就不停了。可以把车位比作信号，现在有三个信号，停一次车，用掉一个信号，车离开就是释放一个信号。

我们用 Redisson 来演示上述停车位的场景。

先定义一个占用停车位的方法：

/**
* 停车，占用停车位
* 总共 3 个车位
*/
@ResponseBody
@RequestMapping("park")
public String park() throws InterruptedException {
  // 获取信号量（停车场）
  RSemaphore park = redisson.getSemaphore("park");
  // 获取一个信号（停车位）
  park.acquire();

  return "OK";
}

再定义一个离开车位的方法：

/**
 * 释放车位
 * 总共 3 个车位
 */
@ResponseBody
@RequestMapping("leave")
public String leave() throws InterruptedException {
    // 获取信号量（停车场）
    RSemaphore park = redisson.getSemaphore("park");
    // 释放一个信号（停车位）
    park.release();

    return "OK";
}

为了简便，我用 Redis 客户端添加了一个 key：“park”，值等于 3，代表信号量为 park，总共有三个值。

然后用 postman 发送 park 请求占用一个停车位。

Kemudian semak nilai park pada klien redis dan mendapati ia telah ditukar kepada 2. Teruskan membuat panggilan dua kali dan mendapati taman itu bersamaan dengan 0. Apabila panggilan keempat dibuat, anda akan mendapati permintaan telah berada di 等待中, menunjukkan bahawa tempat letak kereta tidak mencukupi. Jika anda ingin mengelak daripada menyekat, anda boleh menggunakan tryAcquire atau tryAcquireAsync.

Kami kemudian memanggil kaedah meninggalkan tempat letak kereta, dan nilai taman berubah kepada 1, bermakna ada 1 tempat letak kereta yang tinggal.

Nota: Jika operasi pelepasan semaphore dilakukan beberapa kali, semafor yang tinggal akan terus meningkat dan bukannya dihadkan selepas 3.

Kunci teragih lain:

• Kunci Adil

• MultiLock

• Berkunci

  Kunci baca-tulis ( ReadWriteLock)

• Semaphore Boleh Luput (PermitExpirableSemaphore )

Selak (CountDownLatch)

🎜🎜🎜 dan kunci yang diedarkan tidak akan dikembangkan dalam artikel ini , berminat untuk Pelajar boleh melihat dokumen rasmi. 🎜🎜🎜

Atas ialah kandungan terperinci Penyelesaian raja antara kunci yang diedarkan - Redisson. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!