Redis分布式锁项目实践

本文是向大家介绍项目中如何快速使用redis实现分布式锁，落地实现步骤。

简介

实现分布式锁有多种方式，常见redis,zookeeper,数据库等多种方式实现，由于redis实现相对简单快捷，所以本次分享聚焦redis分布式锁实现方式，下面我们介绍下在我们实际项目已经正式落地的实现方式。具体方案见如下。

方案1. spring-integration中redis分布锁 

spring-integration对redis分布锁的支持，底层应该也是lua脚本的实现，可完美解决线程挂掉造成的死 锁，以及执行时间过长锁释放掉，误删别人的锁。不适用redis集群，（可用于阿里云redis,阿里云redis相当于单机）

使用步骤：

第一步：引入jar

<!-- redis分布式锁 begin-->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-integration</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.integration</groupId>
    <artifactId>spring-integration-redis</artifactId>
</dependency>
<!-- redis分布式锁 end-->

第二步：配置redisLockRegistry

@Configuration
public class RedisLockConfiguration {
    @Bean
    public RedisLockRegistry redisLockRegistry(RedisConnectionFactory redisConnectionFactory) {
        return new RedisLockRegistry(redisConnectionFactory, "mfbizcore:redis_lock");
    }
}

第三步：配置文件

#Redis服务器地址
spring.redis.host=127.0.1.1
#Redis服务器连接密码
spring.redis.password=123456
#Redis服务器连接端口
spring.redis.port=30079
spring.redis.database=1
#连接池最大连接数
spring.redis.pool.maxActive=8
#连接池最大阻塞等待时间
spring.redis.pool.maxWait=-1
#连接池中的最大空闲连接
spring.redis.pool.maxIdle=8
#连接池中的最小空闲连接
spring.redis.pool.minIdle=0
#连接超时时间（毫秒）
spring.redis.timeout=10000

第四步：分布式锁使用示例

@Autowired
private RedisLockRegistry redisLockRegistry;

// 省略

Lock lock = redisLockRegistry.obtain(redisLockKey);
if(!lock.tryLock()){
    //加锁失败
    LOGGER.info("当前用户:{},已有扣款流程正在处理中,redis锁key{}",userId,redisLockKey);
    return false;
}
try{
  // 省略业务
}finally{
  if (lock != null) {
    //释放锁
    lock.unlock();
    LOGGER.info("当前用户:{},扣款流程结束,进行锁释放操作,redis锁key:{}",userId,redisLockKey);
   }
}

方案2. Redission分布式锁 (可用于集群)

Redission是Redis官方推荐的客户端，提供了一个RLock的锁，RLock继承自juc的Lock接口，提供了中断，超时，尝试获取锁等操作，支持可重入，互斥等特性。

使用步骤：

第一步：引入依赖包

				<dependency>
            <groupId>org.redisson</groupId>
            <artifactId>redisson-spring-boot-starter</artifactId>
            <version>3.11.2</version>
        </dependency>

第二步：配置redission

@Configuration
public class RedissonConfig {
    @Autowired
    private RedisConfigProperties redisConfigProperties;

    //添加redisson的bean
    @Bean
    public Redisson redisson() {
        //redisson版本是3.5，集群的ip前面要加上“redis://”，不然会报错，3.2版本可不加
        List<String> clusterNodes = new ArrayList<>();
        for (int i = 0; i < redisConfigProperties.getCluster().getNodes().size(); i++) {
            clusterNodes.add("redis://" + redisConfigProperties.getCluster().getNodes().get(i));
        }
        Config config = new Config();
        ClusterServersConfig clusterServersConfig = config.useClusterServers()
                .addNodeAddress(clusterNodes.toArray(new String[clusterNodes.size()]));
        clusterServersConfig.setPassword(redisConfigProperties.getPassword());//设置密码
        return (Redisson) Redisson.create(config);
    }
}

@Component
@ConfigurationProperties(prefix = "spring.redis")
public class RedisConfigProperties {
    private String password;
    private cluster cluster;

    public static class cluster {
        private List<String> nodes;

        public List<String> getNodes() {
            return nodes;
        }

        public void setNodes(List<String> nodes) {
            this.nodes = nodes;
        }
    }

    public String getPassword() {
        return password;
    }

    public void setPassword(String password) {
        this.password = password;
    }

    public RedisConfigProperties.cluster getCluster() {
        return cluster;
    }

    public void setCluster(RedisConfigProperties.cluster cluster) {
        this.cluster = cluster;
    }
}

第三步：使用示例

 @Autowired
 private Redisson redisson;


@GetMapping("/test4")
    public void test4() {
        String stockKey = "product_1001";
        RLock lock = redisson.getLock(stockKey);
        try {
            // 加锁
            lock.lock();
            int stock = Integer.parseInt(redisTemplate.opsForValue().get("stock"));
            if (stock > 0) {
                int realStock = stock -1;
                redisTemplate.opsForValue().set("stock", String.valueOf(realStock));
                System.out.println("扣减成功，剩余库存：" + realStock);
            } else {
                System.out.println("扣减失败，库存不足");
            }
        } finally {
            // 释放锁
            lock.unlock();
        }
    }