Redisson 完成分布式锁

举报
yd_249383650 发表于 2023/03/17 11:12:45 2023/03/17
【摘要】 ​ 1、简介Redisson 是架设在 Redis 基础上的一个 Java 驻内存数据网格(In-Memory Data Grid)。充分 的利用了 Redis 键值数据库提供的一系列优势,基于 Java 实用工具包中常用接口,为使用者 提供了一系列具有分布式特性的常用工具类。使得原本作为协调单机多线程并发程序的工 具包获得了协调分布式多机多线程并发系统的能力,大大降低了设计和研发大规模分布...

 1、简介

Redisson 是架设在 Redis 基础上的一个 Java 驻内存数据网格(In-Memory Data Grid)。充分 的利用了 Redis 键值数据库提供的一系列优势,基于 Java 实用工具包中常用接口,为使用者 提供了一系列具有分布式特性的常用工具类。使得原本作为协调单机多线程并发程序的工 具包获得了协调分布式多机多线程并发系统的能力,大大降低了设计和研发大规模分布式 系统的难度。同时结合各富特色的分布式服务,更进一步简化了分布式环境中程序相互之间 的协作。

2、配置

pom依赖

<!-- 分布式锁https://mvnrepository.com/artifact/org.redisson/redisson -->
<dependency>
    <groupId>org.redisson</groupId>
    <artifactId>redisson</artifactId>
    <version>3.12.0</version>
</dependency>

 @bean注入配置

@Configuration
public class MyRedissonConfig {

    @Bean(destroyMethod = "shutdown")
    public RedissonClient redisson(){
        //1.创建配置
        Config config = new Config();
        //Redis url should start with redis:// or rediss:// (for SSL connection)
        config.useSingleServer().setAddress("redis://192.168.107.134:6379");
        return Redisson.create(config);
    }
}

3、使用分布式锁 

编辑

可重入锁

    @ResponseBody
    @GetMapping("/hello")
    public  String hello(){
        //1.获取一把锁,只要锁命一样,就是同一把锁
        RLock lock = redissonClient.getLock("mylock");
        //2.加锁
        // 1).锁的自动续期,运行期间自动的给锁续上新的30s,不用担心业务时间长,锁自动过期被删掉
        // 2).加锁的业务只要完成就不会给当前的锁续期,即使不手动释放,锁默认在30s以后会自动删除
//        lock.lock();//阻塞式等待
        lock.lock(10, TimeUnit.SECONDS);//10s后自动解锁,自动解锁时间一定要大于业务的执行时间
        //问题: lock.lock(10, TimeUnit.SECONDS);/ 在锁时间到期以后,不会自动续期
        //1.如果我们传递了锁的超时时间,就发送给redis执行脚本,进行占锁,默认超时加就是我们指定的时间
        //2.如果为指定的锁的超时时间,就使用看门狗的超时时间30s 30*1000
        //      只要占锁成功,就会启动一个定时任务【重新给锁设置时间,新的过期时间就是看门狗的默认时间】
        //      1/3[10s]就会续期一次。 30/3=10s

        //最佳实战 lock.lock(10, TimeUnit.SECONDS);省掉了整个续期操作:手动解锁
        try {
            System.out.println("加锁成功,执行业务...."+Thread.currentThread().getId());
            Thread.sleep(30000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            //3.解锁
            //假设解锁代码没有执行,redisson会不会出现死锁--
            System.out.println("释放锁..."+Thread.currentThread().getId());
            lock.unlock();
        }
        return "hello";
    }


//1.获取一把锁,只要锁命一样,就是同一把锁
//2.加锁
// 1).锁的自动续期,运行期间自动的给锁续上新的30s,不用担心业务时间长,锁自动过期被删掉
// 2).加锁的业务只要完成就不会给当前的锁续期,即使不手动释放,锁默认在30s以后会自动删除

 

//问题: lock.lock(10, TimeUnit.SECONDS);/ 在锁时间到期以后,不会自动续期
//1.如果我们传递了锁的超时时间,就发送给redis执行脚本,进行占锁,默认超时加就是我们指定的时间
//2.如果为指定的锁的超时时间,就使用看门狗的超时时间30s 30*1000
//      只要占锁成功,就会启动一个定时任务【重新给锁设置时间,新的过期时间就是看门狗的默认时间】
//      1/3[10s]就会续期一次。 30/3=10s

//最佳实战 lock.lock(10, TimeUnit.SECONDS);省掉了整个续期操作:手动解锁
//3.解锁
//假设解锁代码没有执行,redisson会不会出现死锁--

读写锁 

大家都知道,如果负责储存这个分布式锁的Redis节点宕机以后,而且这个锁正好处于锁住的状态时,这个锁会出现锁死的状态。为了避免这种情况的发生,Redisson内部提供了一个监控锁的看门狗,它的作用是在Redisson实例被关闭前,不断的延长锁的有效期。默认情况下,看门狗的检查锁的超时时间是30秒钟,也可以通过修改Config.lockWatchdogTimeout来另行指定。

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

 @ResponseBody
    @GetMapping("/write")
    public String write() throws InterruptedException {

        String s="";
        //1.改数据加写锁,读数据加读锁
        RReadWriteLock rwLock = redissonClient.getReadWriteLock("rwLock");
        RLock rLock = rwLock.writeLock();
        try {
            s = UUID.randomUUID().toString();
            redisTemplate.opsForValue().set("writeValue",s);
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            rLock.unlock();
        }

        Thread.sleep(30000);

        return  s;
    }


    @ResponseBody
    @GetMapping("/read")
    public String read() throws InterruptedException {
        String s="";

        RReadWriteLock rwLock = redissonClient.getReadWriteLock("rwLock");
        RLock rLock = rwLock.readLock();
        rLock.lock();
        try {
            s= redisTemplate.opsForValue().get("writeValue");

        }catch (Exception e) {
            e.printStackTrace();
        }finally {
            rLock.unlock();
        }
        return  s;
    }
//保证一定能读到最新数据,修改期间写锁是一个互斥锁,排他锁 ,读锁是一个共享锁
//写锁没释放,读锁必须等待
//读+读 相当于无锁,只会在redis中记录好,所有当前的读锁,他们都会同时加锁成功。
//写+读 等待写锁释放
//写+写 阻塞方式
//读+写 有读锁,写也必须等待
//只要有写的存在,都必须等待

信号量 

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

    /**
     * 车库停车
     * 3车位
     */
    @ResponseBody
    @GetMapping("/park")
    public String park(){

        RSemaphore park = redissonClient.getSemaphore("park");
        try {
            park.acquire();//获取一个信号量,获取一个值,占一个车位
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return "ok";
    }

    @ResponseBody
    @GetMapping("/go")
    public String go(){
        RSemaphore park = redissonClient.getSemaphore("park");
        park.release();//释放车位
        return "ok";
    }

闭锁

   /**
     * 放假锁门
     * 5个班全部走人以后,我们可以锁大门
     */
    @GetMapping("lockDoor")
    @ResponseBody
    public String lockDoor() throws InterruptedException {
        RCountDownLatch door = redissonClient.getCountDownLatch("door");
        door.await();//等待闭锁完成

        return  "放假了";
    }


    @GetMapping("/gogogo/{id}")
    @ResponseBody
    public String gogogo(@PathVariable("id") Long id){
        RCountDownLatch door = redissonClient.getCountDownLatch("door");
        door.countDown();//计数减一
        return "id"+"班的人走了";
    }


【版权声明】本文为华为云社区用户原创内容,转载时必须标注文章的来源(华为云社区)、文章链接、文章作者等基本信息, 否则作者和本社区有权追究责任。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@huaweicloud.com
  • 点赞
  • 收藏
  • 关注作者

评论(0

0/1000
抱歉,系统识别当前为高风险访问,暂不支持该操作

全部回复

上滑加载中

设置昵称

在此一键设置昵称,即可参与社区互动!

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。