当前位置: 首页>后端>正文

Redis setnx分布式锁与Redisson分布式锁的实现

使用Redis 对于分布式服务进行加锁, 防止一个服务多个部署实例,对资源抢占发生冲突。

在单体应用时,对于并发场景,读取公共资源如扣库存,买车票等,使用简单的加锁即可实现,Java本身提供了很多并发处理的API,如Synchronized。
但是对于分布式服务来说, 一个服务可能被部署在多台机器中,形成多个实例,之前的单进程多线程变成了多进程多线程
Java提供的API就不足以解决此类问题

单体应用

单个锁实现单进程多线程并发访问问题
@GetMapping("/getNumber")
    public Integer getNumber(){
        Integer redPacketNumber;
        synchronized (this){
            log.info("《idea redPacket》   请求红包数量");
            redPacketNumber = Integer.valueOf(stringRedisTemplate.opsForValue().get(RED_PACKET_NUMBER));
            if(redPacketNumber > 0){
                stringRedisTemplate.opsForValue().set(RED_PACKET_NUMBER, String.valueOf(--redPacketNumber));
                log.info("扣除成功,剩余库存 {}", redPacketNumber);
            } else {
                log.warn("扣除失败, 数量为{}", redPacketNumber);
            }
        }
        return redPacketNumber;
    }

分布式应用

一个服务多个实例
如果还用synchronized关键字 因为在不同服务, synchronized只能锁住单个实例的代码, 对于其他服务的代码不起作用。

Redis分布式锁

使用redis当作分布式锁

原理

setnx 命令是redis的一条原生命令
大意为 set if not exists, 在指定的key不存在的情况下,为key设置值
使用如下

redis 127.0.0.1:6379> SETNX KEY_NAME VALUE
setIfAbsent方法

使用 Redis的setIfAbsent方法可以达到setnx命令同样的效果。如果key对应的value为空,则设置值, 返回true,否则返回false

注意:

  • 使用过期时间
  • 为了保证万一服务报错, 锁过一会自动解锁

使用随机Value值进行存储,防止 锁的持续时间小于 业务执行时间, 导致锁自动解锁,使锁失效,下一个请求就会直接进入。所以使用随机Value 使得这个锁唯一,只能自己解开
(实践中出了问题, 锁解开的没访问的快, 还没解开,请求都发送完了)

 public Integer getNumberByDistributed(){
        String redPacket = "redPacket";
        Integer redPacketNumber;
        String vauleId = UUID.randomUUID().toString();
        try{
            Boolean aBoolean = stringRedisTemplate.opsForValue().setIfAbsent(redPacket, vauleId, 5, TimeUnit.SECONDS);
            //已存在,相当于已加锁
            if(!aBoolean){
                return -1;
            }
            log.info("《idea redPacket》   请求红包数量");
            redPacketNumber = Integer.valueOf(stringRedisTemplate.opsForValue().get(RED_PACKET_NUMBER));
            if(redPacketNumber > 0){
                stringRedisTemplate.opsForValue().set(RED_PACKET_NUMBER, String.valueOf(--redPacketNumber));
                log.info("扣除成功,剩余库存 {}", redPacketNumber);
            } else {
                log.warn("扣除失败, 数量为{}", redPacketNumber);
            }
        } finally{
            //释放锁(为当前锁)
            if(stringRedisTemplate.opsForValue().get(redPacket).equals(vauleId)){
                stringRedisTemplate.delete(redPacket);
            }
        }
        return redPacketNumber;
    }

Redisson客户端

高性能的异步,无锁的redis客户端 成熟的分布式锁解决方案, 可以减少开发人员的工作量,且性能优异。 这个方法可以保证较高的可用性 推荐使用
Redisson 架设在 redis 基础上的 Java 驻内存数据网格(In-Memory Data Grid),基于NIO的 Netty 框架上,利用了 redis 键值数据库。功能非常强大,解决了很多分布式架构中的问题。

Github的wiki地址:github.com/redisson/re…

官方文档:github.com/redisson/re…

  • maven依赖
<dependency>
 <groupId>org.redisson</groupId>
 <artifactId>redisson</artifactId>
 <version>3.13.2</version>
</dependency>  
  • 注入实例
@Bean
    public Redisson redisson(){
        Config config = new Config();
        config.useSingleServer().setAddress("redis://127.0.0.1:6379").setPassword("****").setDatabase(0);
        return (Redisson) Redisson.create(config);
    }
  • 使用锁
   @Autowired
    Redisson redisson;

 public Integer getNumberByRedisson(){
        String redPacket = "redPacket";
        Integer redPacketNumber;
        RLock redissonLock = redisson.getLock(redPacket);
        String vauleId = UUID.randomUUID().toString();
        try{
            redissonLock.lock(30, TimeUnit.SECONDS);
            log.info("{}进入redisson分布式锁的接口中",Thread.currentThread().getName());
            log.info("《idea redPacket》   请求红包数量");
            redPacketNumber = Integer.valueOf(stringRedisTemplate.opsForValue().get(RED_PACKET_NUMBER));
            if(redPacketNumber > 0){
                stringRedisTemplate.opsForValue().set(RED_PACKET_NUMBER, String.valueOf(--redPacketNumber));
                log.info("扣除成功,剩余库存 {}", redPacketNumber);
            } else {
                log.warn("扣除失败, 数量为{}", redPacketNumber);
            }
        } finally{
           redissonLock.unlock();
        }
        return redPacketNumber;
    }

https://www.xamrdz.com/backend/3vz1926044.html

相关文章: