Cara membangunkan fungsi kunci teragih menggunakan Redis dan Java

Cara menggunakan Redis dan Java untuk membangunkan fungsi kunci teragih

1. Pengenalan
   Kunci teragih ialah mekanisme untuk mencapai akses eksklusif bersama kepada sumber kongsi dalam sistem teragih. Apabila berbilang nod mengakses sumber yang dikongsi pada masa yang sama, adalah perlu untuk memastikan bahawa hanya satu nod sedang mengakses dan nod lain perlu menunggu. Redis ialah pangkalan data dalam memori yang biasa digunakan dengan prestasi tinggi dan kebolehpercayaan yang tinggi, dan sangat sesuai untuk melaksanakan kunci teragih.
2. Arahan setnx Redis
   Arahan setnx Redis boleh digunakan untuk menetapkan nilai kunci, tetapi operasi tetapan hanya akan dilakukan apabila kunci tidak wujud. Ciri ini boleh digunakan untuk melaksanakan operasi pemerolehan kunci teragih. Gunakan arahan setnx untuk cuba menetapkan kunci dengan masa tamat tempoh. Jika tetapan itu berjaya, ini bermakna kunci telah berjaya diperolehi.
3. Contoh kod Java
   Berikut ialah contoh kod yang menggunakan bahasa Java dan Redis untuk melaksanakan kunci teragih:

import redis.clients.jedis.Jedis;

public class DistributedLock {
    private static final String LOCK_KEY = "distributed_lock";
    private static final int LOCK_TIMEOUT = 3 * 1000; // 锁的超时时间，单位为毫秒
    
    private Jedis jedis;

    public DistributedLock(Jedis jedis) {
        this.jedis = jedis;
    }

    public boolean lock() {
        long start = System.currentTimeMillis();
        try {
            while (true) {
                String result = jedis.set(LOCK_KEY, "locked", "NX", "PX", LOCK_TIMEOUT);
                if ("OK".equals(result)) {
                    return true;
                } else {
                    // 进行重试
                    Thread.sleep(100);
                }
                long end = System.currentTimeMillis();
                if (end - start > LOCK_TIMEOUT) {
                    // 超时退出
                    return false;
                }
            }
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            return false;
        }
    }

    public void unlock() {
        jedis.del(LOCK_KEY);
    }
}

4. Contoh penerangan
   Dalam kod contoh di atas, perpustakaan Jedis digunakan untuk mengendalikan Redis. Mula-mula, LOCK_KEY tetap ditakrifkan sebagai kunci kunci yang diedarkan ini mesti kekal unik di antara semua nod. Selain itu, pemalar LOCK_TIMEOUT ditetapkan untuk mewakili tamat masa kunci. LOCK_KEY作为分布式锁的键，这个键在所有节点中必须保持唯一。另外，设置了一个LOCK_TIMEOUT常量来表示锁的超时时间。

在lock方法中，首先获取当前时间作为开始时间，然后使用一个无限循环来尝试获取分布式锁。在循环中，使用Redis的set命令进行设置操作，设置键为LOCK_KEY，值为"locked"，并且设置了NX和PX选项，NX表示只有键不存在时才执行设置操作，PX表示设置键的过期时间为LOCK_TIMEOUT毫秒。

如果设置成功，则表示获取锁成功，方法返回true；否则继续进行重试，每次重试时会等待100毫秒。同时，还需要判断获取锁的时间是否超过了LOCK_TIMEOUT的值，如果超过则表示获取锁的等待时间已经过长，放弃获取锁，并返回false。

在unlock方法中，通过调用del

Dalam kaedah kunci, mula-mula dapatkan masa semasa sebagai masa mula, dan kemudian gunakan gelung tak terhingga untuk cuba memperoleh kunci yang diedarkan. Dalam gelung, gunakan perintah set Redis untuk melaksanakan operasi tetapan Kekunci set ialah LOCK_KEY, nilainya "dikunci" dan NX. dan pilihan PX, NX bermaksud operasi tetapan hanya dilakukan apabila kunci tidak wujud, PX bermaksud masa tamat tempoh set kunci ialah LOCK_TIMEOUT</ code>milisaat. <li><br>Jika tetapan berjaya, ini bermakna kunci berjaya diperoleh, dan kaedah mengembalikan <code>true jika tidak, teruskan mencuba semula dan akan menunggu selama 100 milisaat untuk setiap percubaan semula. Pada masa yang sama, adalah perlu juga untuk menentukan sama ada masa untuk memperoleh kunci melebihi nilai LOCK_TIMEOUT Jika melebihi, ini bermakna masa menunggu untuk memperoleh kunci telah terlalu lama. berputus asa untuk mendapatkan kunci, dan kembalikan false .

Dalam kaedah unlock, padamkan kunci kunci yang diedarkan dengan memanggil perintah del.

Contoh panggilan
6. Berikut ialah contoh panggilan menggunakan kod sampel:
   

import redis.clients.jedis.Jedis;

public class LockTest {
    public static void main(String[] args) {
        Jedis jedis = new Jedis("localhost");
        DistributedLock lock = new DistributedLock(jedis);
        try {
            if (lock.lock()) {
                // 获取到分布式锁后执行需要保护的代码
                System.out.println("获取到分布式锁");
                // ... 执行需要保护的代码
            } else {
                System.out.println("获取分布式锁失败");
            }
        } finally {
            lock.unlock();
        }
    }
}

Dalam contoh panggilan, objek sambungan Jedis mula-mula dibuat, kemudian objek DistributedLock dicipta dan objek sambungan Jedis dihantar sebagai satu parameter. Dalam blok cuba-akhir, mula-mula cuba dapatkan kunci teragih Jika berjaya, keluarkan "mendapat kunci teragih", jalankan kod yang perlu dilindungi, dan kemudian lepaskan kunci teragih dalam blok akhirnya. 🎜🎜🎜Ringkasan🎜Dengan menggunakan pembangunan Redis dan Java, kami boleh melaksanakan fungsi kunci yang diedarkan dengan mudah. Operasi pemerolehan kunci boleh dilaksanakan menggunakan arahan setnx Redis, dan kod Java boleh dengan mudah memanggil arahan Redis dan merangkumnya ke dalam kelas kunci yang diedarkan. Dalam aplikasi sebenar, tamat masa kunci yang diedarkan boleh dilaraskan mengikut keperluan untuk memastikan bahawa masa menunggu untuk memperoleh kunci tidak akan terlalu lama, dengan itu meningkatkan prestasi dan keselarasan sistem. 🎜🎜

Atas ialah kandungan terperinci Cara membangunkan fungsi kunci teragih menggunakan Redis dan Java. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!