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;
    }