基于springBoot的redisson分布式锁

之前使用Redis分布式锁都是自己写的工具类，利用Redis的setNX特性；后来发现Redisson提供的分布式锁是真的好用。
Redisson可以看做是对Redis的一个操作工具类。将原生的RedisHash，List，Set，String等数据结构封装为Java里大家最熟悉的映射（Map），列表（List），集（Set）等。

我的项目中使用了RedisTemplate，现在要在此基础上使用Redisson,如果再在配置文件里面添加一份Redisson的配置，那维护起来就非常麻烦，如果改动了配置信息，就要改动两个地方的配置。所以写一个RedissonConfig配置类，在配置里面读取RedisTemplate的配置信息即可；

一、配置文件

1.pom文件添加依赖

        <dependency><groupId>org.redisson</groupId><artifactId>redisson</artifactId><version>3.16.1</version></dependency>

2.yml配置文件配置

springredis:database: 0host: 1.1.1.1port: 6379password: 123456cluster:nodes: 1.1.1.1:6379, 1.1.1.1:6379, 1.1.1.1:6379, 1.1.1.1:6379, 1.1.1.1:6379

二、RedisTemplate序列化配置

    // 配置序列化@Beanpublic RedisTemplate<String, Object> redisTemplate(LettuceConnectionFactory redisConnectionFactory) {RedisTemplate<String, Object> template = new RedisTemplate<>();redisConnectionFactory.setDatabase(1);template.setKeySerializer(new StringRedisSerializer());template.setValueSerializer(new GenericJackson2JsonRedisSerializer());template.setConnectionFactory(redisConnectionFactory);return template;}

三、RedissonConfig配置

@ConfigurationProperties(prefix = "spring.redis")
@Component
@Data
public class RedissonConfig {// 读取配置文件里面的Redis信息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;}}/*** 配置redisson* @return*/@Beanpublic Redisson redisson() {List<String> clusterNodes = new ArrayList<>();for (int i = 0; i < this.getCluster().getNodes().size(); i++) {clusterNodes.add("redis://" + this.getCluster().getNodes().get(i));}Config config = new Config();ClusterServersConfig clusterServersConfig = config.useClusterServers().addNodeAddress(clusterNodes.toArray(new String[clusterNodes.size()]));clusterServersConfig.setPassword(getPassword());return (Redisson) Redisson.create(config);}}

四、编写RedissonUtil工具类

@Component
public class RedissonUtil {private static final Logger logger = LoggerFactory.getLogger(RedissonUtil.class);/*** redis锁前缀*/public static final String SYS_LOCK_FLAG = "MY_LOCK";/*** 用于隔开缓存前缀与缓存键值*/public static final String KEY_SPLIT = ":";// 静态属性注入private static Redisson redisson;@Autowiredpublic void setRedisson(Redisson redisson) {RedissonUtil.redisson = redisson;}/*** 加锁** @param lockName    锁名  相同的key表示相同的锁，建议针对不同的业务使用不同的key* @param expiresTime 过期时间，单位：秒* @return*/public static boolean getLock(String lockName, long expiresTime) {String key = getLockKey(lockName);//获取锁对象RLock lock = redisson.getLock(key);//设置锁过期时间，防止死锁的产生lock.lock(expiresTime, TimeUnit.SECONDS);logger.info("获取锁成功，Redis Lock key :{}", key);return true;}/*** 释放锁，建议放在 finally里面** @param lockName 锁名称*/public static void unlock(String lockName) {String key = getLockKey(lockName);//获取所对象RLock lock = redisson.getLock(key);// 释放锁,判断要解锁的key是否已被锁定并且是否被当前线程保持if (lock.isLocked() && lock.isHeldByCurrentThread()) {lock.unlock();logger.info("释放Redis锁成功，key:{}", key);}}/*** 对锁的key添加系统标识前缀** @return*/private static String getLockKey(String key) {return RedissonUtil.SYS_LOCK_FLAG + RedissonUtil.KEY_SPLIT + key;}}

五、使用

    @Testpublic void redissonLock(){String key = "zhh11";long expiresTime = 10;// 加锁if (RedissonUtil.getLock(key,expiresTime)){try{Thread.sleep(3000L);// 业务代码}catch (Exception e){e.printStackTrace();}finally {// 释放锁RedissonUtil.unlock(key);// 捕获异常之后需要 手动回滚事务//    TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();}}else {System.out.println("未获取到锁");}}

Redisson分布式锁的配置和使用相关推荐

年轻人，看看 Redisson 分布式锁—可重入锁吧！太重要了
作者 | 李祥责编 | 张文来源 | 企鹅杏仁技术站(ID:xingren-tech) 引言作为后端开发,对于所谓的线程安全.高并发等一系列名词肯定都不会陌生,相关的一些概念及技术框架是面 ...
springboot基础(72):Redisson分布式锁
文章目录前言第一节入门使用Redisson 第二节注解形式的分布式锁 1. 分布式锁的注解实现 2. 分析MyRedissonLock注解和使用传送门前言并发执行是比较场景的场景,单机情 ...
Jmeter Springboot Redisson分布式锁并发订单操作(下单、取消单、完成单、加库存)
Jmeter+Springboot+Redisson分布式锁并发订单操作(下单.取消单.完成单.加库存) 涉及知识点: java+springboot+mybatis开发 redis分布式锁+Redi ...
Redis实战——Redisson分布式锁
目录 1 基于Redis中setnx方法的分布式锁的问题 2 Redisson 2.1 什么是Redisson 2.2 Redisson实现分布式锁快速入门 2.3 Redisson 可重入锁原理什 ...
redisson分布式锁,实战
目录什么时候用分布式锁? 分布式锁入门超时设置释放了不是自己加的锁正确设置锁超时加解锁代码位置有讲究实现可重入锁 Redis Hash 可重入锁主从架构带来的问题什么是 Redlock ...
Redisson分布式锁实现
Redisson分布式锁实现 1. 分布式锁概述 2. 分布式锁实现 2.1 maven依赖 2.2 配置参数 2.3 代码实现 1. 分布式锁概述程序中的锁就是为了解决临界资源访问的同步性问题,而 ...
Redis：Redisson分布式锁的使用（推荐使用）
Redis:Redisson分布式锁的使用(生产环境下)(推荐使用) 关键词基于NIO的Netty框架,生产环境使用分布式锁 redisson加锁:lua脚本加锁(其他客户端自旋) 自动延时机制:启 ...
Redisson分布式锁
目录一.分布式锁 1.分布式锁的设计原则 2.分布式锁的实现方案二.Redisson 三.Redisson分布式锁 1.引入Redisson依赖 2.配置Redis 3.注入RedissonCli ...
Redisson分布式锁详解
概述 setnx分布式锁的问题重入问题重入问题是指获得锁的线程可以再次进入到相同的锁的代码块中,可重入锁的意义在于防止死锁,比如HashTable这样的代码中,它的方法都是使用synchroniz ...

Redisson分布式锁的配置和使用