Redisson（三）应用场景及demo

一、基本的存储与查询

分布式环境下，为了方便多个进程之间的数据共享，可以使用RedissonClient的分布式集合类型，如List、Set、SortedSet等。 

1、demo

  <parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.1.8.RELEASE</version><relativePath/></parent><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-actuator</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!--<dependency>--><!--<groupId>org.redisson</groupId>--><!--<artifactId>redisson-spring-boot-starter</artifactId>--><!--<version>3.23.5</version>--><!--</dependency>--><dependency><groupId>org.redisson</groupId><artifactId>redisson</artifactId><version>3.15.0</version></dependency></dependencies>

server.port = 7777
server.servlet.context-path=/redission#1、单机模式
#Redis url should start with redis:// or rediss:// (for SSL connection)
#my.redisson.address = redis://127.0.0.1:6379
#my.redisson.password = wtyy#2、哨兵模式
my.redisson.sentinel.schema=
my.redisson.sentinel.address = redis://xxx.xx.xxx1:19601,redis://xxx.xx.xxx2:19601,redis://xxx.xx.xxx3:19601
my.redisson.sentinel.password = N5WAXX4z9qw
my.redisson.sentinel.master = master-test
my.redisson.sentinel.database = 10

import org.redisson.Redisson;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;@Configuration
public class RedissionConfig {@Value("${my.redisson.sentinel.address}")private String address;@Value("${my.redisson.sentinel.password}")private String password;@Value("${my.redisson.sentinel.master}")private String master;@Value("${my.redisson.sentinel.database}")private Integer dataBase;@Value("${my.redisson.sentinel.schema}")private String schema;/*** 所有对Redisson的使用都是通过RedissonClient对象*/@Bean(destroyMethod = "shutdown")public RedissonClient redissonClient(){Config config = new Config();config.useSentinelServers().setScanInterval(2000) // cluster state scan interval in milliseconds.addSentinelAddress(address.split(",")).setCheckSentinelsList(false).setMasterName(master).setPassword(password).setDatabase(dataBase);RedissonClient redissonClient = Redisson.create(config);return redissonClient;}
}

@Autowiredprivate RedissonClient redissonClient;@RequestMapping("/setStr")public void setStr(String key,String value){redissonClient.getBucket(key).set(value);}@RequestMapping("/getStr")public String getStr(String key){return (String) redissonClient.getBucket(key).get();}

 测试：

访问localhost:7777/redission/setStr?key=userName&value=李四

查看redis存储情况

访问localhost:7777/redission/getStr?key=userName  输出：李四

二、分布式锁

1、背景

关于jedis锁的几个痛点：（1）锁先于业务过期（2）主从节点不一致；

Redisson都很好的解决了。

2、特点

高效的分布式锁设计应该包含以下几个要点：

（1）互斥：

在分布式高并发的条件下，我们最需要保证，同一时刻只能有一个线程获得锁，这是最基本的一点

（2）防止死锁：

在分布式高并发的条件下，比如有个线程获得锁的同时，还没有来得及去释放锁，就因为系统故障或者其它原因使它无法执行释放锁的命令,导致其它线程都无法获得锁，造成死锁。所以分布式非常有必要设置锁的有效时间，确保系统出现故障后，在一定时间内能够主动去释放锁，避免造成死锁的情况。

（3）性能：

对于访问量大的共享资源，需要考虑减少锁等待的时间，避免导致大量线程阻塞。所以在锁的设计时，需要考虑两点：

① 锁的颗粒度要尽量小。比如你要通过锁来减库存，那这个锁的名称你可以设置成是商品的ID,而不是任取名称。这样这个锁只对当前商品有效,锁的颗粒度小。

② 锁的范围尽量要小。比如只要锁2行代码就可以解决问题的，就不要去锁10行代码了。

（4）重入：

ReentrantLock是可重入锁，它的特点是：同一个线程可以重复拿到同一个资源的锁。重入锁非常有利于资源的高效利用。

3、原理

 Redisson并没有通过setNx命令来实现加锁，而是基于 Redis+ 看⻔狗机制，自己实现了一套分布式锁逻辑。

（1）加锁机制：

当一个线程想要获取锁时，它会先尝试通过`getLock()`方法获取锁。如果获取成功，它将执行Lua脚本（保证这段复杂业务逻辑执行的原子性）并保存数据到Redis数据库。如果获取失败，一直通过while循环尝试获取锁，直到获取成功后，执行lua脚本，保存数据到redis数据库

如果多个线程同时尝试获取同一个锁，Redisson会将这些请求放入队列中，然后按照FIFO（先进先出）的方式逐个处理它们。如果有一个线程已经获得了锁并且没有释放，那么其他线程将会等待，直到这个线程释放锁。

（2）Watch Dog自动延期机制：

如果一个线程获得了锁但没有立即使用，而是发生了故障或超出了锁的使用期限，Redisson的Watch Dog机制会在一定时间内自动释放锁。用户可以设置锁的有效时间，如果不设置，默认的时间是30秒。

之前使用jedis加锁，提到过业务逻辑耗时较长锁已经过期了这种情况，所以redission加入了看门狗机制。它的作用就是 线程1 业务还没有执行完，时间就过了，线程1 还想持有锁的话，就会启动一个watch dog后台线程，不断的延长锁key的生存时间。

注意 正常这个看门狗线程是不启动的，还有就是这个看门狗启动后对整体性能也会有一定影响，所以不建议开启看门狗。

（3）锁的互斥机制：

Redisson确保同一时刻只有一个线程拥有锁。当一个线程获取到锁后，它会将自己的信息保存在Redis中，以证明它是锁的所有者。当另一个线程试图获取相同的锁时，它会检查Redis中是否存在这条记录。如果存在，说明有其他线程已经拥有了锁，因此当前线程会被阻止继续执行。

（4）锁的释放机制：

当线程完成了所有的资源操作后，它应该及时释放锁。这可以通过发送一个`release()`命令来实现，Redisson会删除锁记录，从而允许其他线程重新获取锁。

综上所述，Redisson的分布式锁机制结合了Lua脚本的执行和Redis的操作，以及Watch Dog自动延期的功能，确保了锁的互斥性和释放的及时性。

（5）可重入：

它最大的优点就是相同线程不需要在等待锁，而是可以直接进行相应操作

4、使用方法

RLock lock = redisson.getLock("lock");
lock.lock();
try {// 处理业务逻辑
} finally {lock.unlock();
}

 升级写法：判断加锁是否成功

RLock lock = redissonClient.getLock(你的key);try {if (lock.tryLock()) {//你的业务逻辑} else {ResponseWrapper.error("冲突提示语");}} catch (Exception e) {log.error("异常");} finally {lock.unlock();}

5、demo

import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;@Service("productService")
public class ProductServiceImpl implements ProductService {
private static final Logger logger = LoggerFactory.getLogger(ProductServiceImpl.class);@Autowiredprivate RedissonClient redissonClient;int productTotal = 5;@Overridepublic void buy(String productId) {//模拟数据库查询if(productTotal > 0){logger.info(Thread.currentThread().getName()+"买到了一件");productTotal --;}logger.info("库存："+productTotal);}@Overridepublic void lockBuy(String productId) {RLock lock = redissonClient.getLock(productId);lock.lock();try{//模拟数据库查询if(productTotal > 0){logger.info(Thread.currentThread().getName()+"买到了一件");productTotal --;}logger.info("库存："+productTotal);}finally {lock.unlock();}}
}

 

 测试未加锁并发情况：

public class ProductTest implements Runnable{public static void main(String[] args) {ProductTest productTest = new ProductTest();for(int i=0;i<50;i++){Thread thread = new Thread(productTest);thread.start();}}@Overridepublic void run() {String url = "http://localhost:7777/redission/buy";String productId = "abcd";String param = "productId="+productId;HttpRequestUtil.sendGet(url, param);}
}

随机测试，20个并发量的情况下，出现负数，最大为 -4（如下图）；并发量50时出现 -12。

而测试lockBuy接口，无论并发量为多少，都不会出现负数。打印50并发数的某一个结果：

2024-01-28 15:00:43.979  INFO 142656 --- [nio-7777-exec-6] com.demo.service.ProductServiceImpl      : http-nio-7777-exec-6买到了一件
2024-01-28 15:00:43.980  INFO 142656 --- [nio-7777-exec-6] com.demo.service.ProductServiceImpl      : 库存：4
2024-01-28 15:00:44.010  INFO 142656 --- [io-7777-exec-42] com.demo.service.ProductServiceImpl      : http-nio-7777-exec-42买到了一件
2024-01-28 15:00:44.013  INFO 142656 --- [io-7777-exec-42] com.demo.service.ProductServiceImpl      : 库存：3
2024-01-28 15:00:44.050  INFO 142656 --- [io-7777-exec-22] com.demo.service.ProductServiceImpl      : http-nio-7777-exec-22买到了一件
2024-01-28 15:00:44.050  INFO 142656 --- [io-7777-exec-22] com.demo.service.ProductServiceImpl      : 库存：2
2024-01-28 15:00:44.077  INFO 142656 --- [nio-7777-exec-5] com.demo.service.ProductServiceImpl      : http-nio-7777-exec-5买到了一件
2024-01-28 15:00:44.077  INFO 142656 --- [nio-7777-exec-5] com.demo.service.ProductServiceImpl      : 库存：1
2024-01-28 15:00:44.103  INFO 142656 --- [io-7777-exec-30] com.demo.service.ProductServiceImpl      : http-nio-7777-exec-30买到了一件
2024-01-28 15:00:44.103  INFO 142656 --- [io-7777-exec-30] com.demo.service.ProductServiceImpl      : 库存：0
2024-01-28 15:00:44.121  INFO 142656 --- [io-7777-exec-14] com.demo.service.ProductServiceImpl      : 库存：0
2024-01-28 15:00:44.129  INFO 142656 --- [io-7777-exec-46] com.demo.service.ProductServiceImpl      : 库存：0
2024-01-28 15:00:44.138  INFO 142656 --- [io-7777-exec-11] com.demo.service.ProductServiceImpl      : 库存：0
2024-01-28 15:00:44.146  INFO 142656 --- [nio-7777-exec-7] com.demo.service.ProductServiceImpl      : 库存：0
2024-01-28 15:00:44.160  INFO 142656 --- [io-7777-exec-37] com.demo.service.ProductServiceImpl      : 库存：0
2024-01-28 15:00:44.173  INFO 142656 --- [io-7777-exec-19] com.demo.service.ProductServiceImpl      : 库存：0
2024-01-28 15:00:44.201  INFO 142656 --- [io-7777-exec-23] com.demo.service.ProductServiceImpl      : 库存：0
2024-01-28 15:00:44.222  INFO 142656 --- [nio-7777-exec-8] com.demo.service.ProductServiceImpl      : 库存：0
2024-01-28 15:00:44.244  INFO 142656 --- [io-7777-exec-18] com.demo.service.ProductServiceImpl      : 库存：0
2024-01-28 15:00:44.277  INFO 142656 --- [io-7777-exec-15] com.demo.service.ProductServiceImpl      : 库存：0
2024-01-28 15:00:44.314  INFO 142656 --- [io-7777-exec-41] com.demo.service.ProductServiceImpl      : 库存：0
2024-01-28 15:00:44.339  INFO 142656 --- [io-7777-exec-24] com.demo.service.ProductServiceImpl      : 库存：0
2024-01-28 15:00:44.365  INFO 142656 --- [io-7777-exec-10] com.demo.service.ProductServiceImpl      : 库存：0
2024-01-28 15:00:44.392  INFO 142656 --- [io-7777-exec-21] com.demo.service.ProductServiceImpl      : 库存：0
2024-01-28 15:00:44.411  INFO 142656 --- [io-7777-exec-45] com.demo.service.ProductServiceImpl      : 库存：0
2024-01-28 15:00:44.431  INFO 142656 --- [io-7777-exec-48] com.demo.service.ProductServiceImpl      : 库存：0
2024-01-28 15:00:44.455  INFO 142656 --- [io-7777-exec-13] com.demo.service.ProductServiceImpl      : 库存：0
2024-01-28 15:00:44.473  INFO 142656 --- [io-7777-exec-32] com.demo.service.ProductServiceImpl      : 库存：0
2024-01-28 15:00:44.502  INFO 142656 --- [nio-7777-exec-3] com.demo.service.ProductServiceImpl      : 库存：0
2024-01-28 15:00:44.532  INFO 142656 --- [io-7777-exec-20] com.demo.service.ProductServiceImpl      : 库存：0
2024-01-28 15:00:44.553  INFO 142656 --- [io-7777-exec-29] com.demo.service.ProductServiceImpl      : 库存：0
2024-01-28 15:00:44.578  INFO 142656 --- [io-7777-exec-28] com.demo.service.ProductServiceImpl      : 库存：0
2024-01-28 15:00:44.620  INFO 142656 --- [io-7777-exec-36] com.demo.service.ProductServiceImpl      : 库存：0
2024-01-28 15:00:44.642  INFO 142656 --- [io-7777-exec-49] com.demo.service.ProductServiceImpl      : 库存：0
2024-01-28 15:00:44.664  INFO 142656 --- [io-7777-exec-17] com.demo.service.ProductServiceImpl      : 库存：0
2024-01-28 15:00:44.695  INFO 142656 --- [io-7777-exec-16] com.demo.service.ProductServiceImpl      : 库存：0
2024-01-28 15:00:44.711  INFO 142656 --- [io-7777-exec-40] com.demo.service.ProductServiceImpl      : 库存：0
2024-01-28 15:00:44.740  INFO 142656 --- [io-7777-exec-12] com.demo.service.ProductServiceImpl      : 库存：0
2024-01-28 15:00:44.757  INFO 142656 --- [io-7777-exec-44] com.demo.service.ProductServiceImpl      : 库存：0
2024-01-28 15:00:44.772  INFO 142656 --- [nio-7777-exec-2] com.demo.service.ProductServiceImpl      : 库存：0
2024-01-28 15:00:44.789  INFO 142656 --- [io-7777-exec-26] com.demo.service.ProductServiceImpl      : 库存：0
2024-01-28 15:00:44.814  INFO 142656 --- [io-7777-exec-27] com.demo.service.ProductServiceImpl      : 库存：0
2024-01-28 15:00:44.830  INFO 142656 --- [io-7777-exec-50] com.demo.service.ProductServiceImpl      : 库存：0
2024-01-28 15:00:44.845  INFO 142656 --- [io-7777-exec-43] com.demo.service.ProductServiceImpl      : 库存：0
2024-01-28 15:00:44.863  INFO 142656 --- [io-7777-exec-35] com.demo.service.ProductServiceImpl      : 库存：0
2024-01-28 15:00:44.887  INFO 142656 --- [io-7777-exec-47] com.demo.service.ProductServiceImpl      : 库存：0
2024-01-28 15:00:44.912  INFO 142656 --- [io-7777-exec-34] com.demo.service.ProductServiceImpl      : 库存：0
2024-01-28 15:00:44.937  INFO 142656 --- [nio-7777-exec-4] com.demo.service.ProductServiceImpl      : 库存：0
2024-01-28 15:00:44.955  INFO 142656 --- [io-7777-exec-38] com.demo.service.ProductServiceImpl      : 库存：0
2024-01-28 15:00:44.977  INFO 142656 --- [nio-7777-exec-9] com.demo.service.ProductServiceImpl      : 库存：0
2024-01-28 15:00:45.008  INFO 142656 --- [nio-7777-exec-1] com.demo.service.ProductServiceImpl      : 库存：0
2024-01-28 15:00:45.028  INFO 142656 --- [io-7777-exec-39] com.demo.service.ProductServiceImpl      : 库存：0
2024-01-28 15:00:45.050  INFO 142656 --- [io-7777-exec-33] com.demo.service.ProductServiceImpl      : 库存：0
2024-01-28 15:00:45.483  INFO 142656 --- [io-7777-exec-25] com.demo.service.ProductServiceImpl      : 库存：0
2024-01-28 15:00:47.232  INFO 142656 --- [io-7777-exec-31] com.demo.service.ProductServiceImpl      : 库存：0