springboot设置集成RedisTemplate和Redisson，使用分布式锁案例 ...

文章要点

• 自定义设置属性类
  
• 集成设置RedisTemplate
  
• 集成设置分布式锁Redisson
  
• 使用分布式锁简单实现超卖方案
  

1. 项目布局

2. 集成RedisTemplate和Redisson

添加依赖
依赖的版本与继续的spring-boot-starter-parent工程相对应，可写可不写

1. <!--spring data redis & cache-->
2.         <dependency>
3.             <groupId>org.springframework.boot</groupId>
4.             <artifactId>spring-boot-starter-data-redis</artifactId>
5.         </dependency>
6.         <!-- redis依赖commons-pool 这个依赖一定要添加 -->
7.         <dependency>
8.             <groupId>org.apache.commons</groupId>
9.             <artifactId>commons-pool2</artifactId>
10.         </dependency>
12.         <!--redisson-->
13.         <dependency>
14.             <groupId>org.redisson</groupId>
15.             <artifactId>redisson-spring-boot-starter</artifactId>
16.             <version>3.15.6</version>
17.         </dependency>
19.         <!-- https://mvnrepository.com/artifact/org.projectlombok/lombok -->
20.         <dependency>
21.             <groupId>org.projectlombok</groupId>
22.             <artifactId>lombok</artifactId>
23.             <scope>provided</scope>
24.         </dependency>

复制代码

大概图解

如上图，先设置application.yml设置Redis的各项属性包罗ip，端口，暗码。再注入。

1. server:
2.   port: 8080
4. # Redis配置
5. spring:
6.   redis:
7.     host: 192.168.200.131
8.     port: 6379
9.     password: root

复制代码

1. // RedisConfigProperties.java
2. @Data
3. @ConfigurationProperties(prefix = "spring.redis")
4. public class RedisConfigProperties {
5.     private String host;
6.     private int port;
7.     private String password;
8. }
10. // RedisTemplateConfig.java
11. @Configuration
12. public class RedisTemplateConfig {
14.     @Autowired
15.     RedisConfigProperties redisConfigProperties;
17.     @Bean
18.     public RedisConnectionFactory redisConnectionFactory() {
19.         RedisStandaloneConfiguration config = new RedisStandaloneConfiguration(
20.                 redisConfigProperties.getHost(), redisConfigProperties.getPort()
21.         );
23.         config.setPassword(redisConfigProperties.getPassword());
24.         return new LettuceConnectionFactory(config);
25.     }
27.     @Bean
28.     public RedisTemplate<String, Object> redisTemplate(){
29.         RedisTemplate<String,Object> template = new RedisTemplate<>();
30.         template.setConnectionFactory(redisConnectionFactory());
31.         // 设置序列化器等其他配置
32.         return template;
33.     }
34. }
36. // RedissonConfig.java
37. @Configuration
38. @EnableConfigurationProperties({RedisConfigProperties.class})
39. public class RedissonConfig {
41.     @Autowired
42.     RedisConfigProperties redisConfigProperties;
44.     @Bean
45.     public RedissonClient redissonClient(){
46.         // 1. 创建配置文件
47.         Config config = new Config();
49.         // 2. 设置单节点服务器配置
50.         config.useSingleServer().setAddress(
51.                 "redis://"+redisConfigProperties.getHost()+":"+redisConfigProperties.getPort()
52.         );
54.         // 3. 如果Redis设置了密码，这里需要设置密码
55.         config.useSingleServer().setPassword(redisConfigProperties.getPassword());
57.         // 4. 创建RedissonClient实例
58.         RedissonClient redisson = Redisson.create(config);
60.         return redisson;
61.     }
62. }

复制代码

到这里，RedisTemplate和Redisson就已经集成好了，后续使用只必要注入就行。
例如

1. @RestController
2. @RequestMapping(value = "/order")
3. public class OrderController {
5.     @Autowired
6.     //private RedisTemplate redisTemplate;
7.     private StringRedisTemplate redisTemplate; //通常用这个StringRedisTemplate
9.     @Autowired
10.     private RedissonClient redissonClient;
12.         ...
13.         ...
14. }

复制代码

3. 模拟分布式场景下超卖现象

OrderController

1.         /***
2.      * 抢单
3.      */
4.     @GetMapping(value = "/v1/{id}/{num}")
5.     public String addv1(@PathVariable(value = "id")String id,@PathVariable("num")Long num) throws InterruptedException {
6.         // 1.查询库存
7.         int count = Integer.valueOf(redisTemplate.opsForValue().get(id));
8.         System.out.println("剩余库存:"+count);
9.         // 2.库存充足
10.         if (count>=num){
11.             //模拟操作
12.             TimeUnit.SECONDS.sleep(5);
14.             //递减库存
15.             Long decrement = redisTemplate.opsForValue().decrement(id, num);
16.             System.out.println("递减库存后剩余库存:"+decrement);
18.             //其它操作 略
19.             System.out.println("----添加订单了！");
21.             return "下单成功";
23.         }
24.         //库存不足
25.         else {
26.             return "库存不足";
27.         }
28.     }

复制代码

复制一个端口为8081的设置，模拟分布式服务

启动两个服务

在Redis中设置一个键值对water:2，模拟水的库存为2.

欣赏器同时发送2个哀求，模拟有2个用户同时每人买2瓶水
http://127.0.0.1:8080/order/v1/water/2
http://127.0.0.1:8081/order/v1/water/2

出现超卖现象
4. 利用Redisson分布式锁，防止超卖

   关键代码

1. RLock lock = redissonClient.getLock("mylock_" + id);
2. lock.lock();   //自旋获取锁
3. ...
4. ...
5. lock.unlock();

复制代码

首先记得set water 2
OrderController

1.         /***
2.      * 抢单，使用分布式锁
3.      */
4.     @GetMapping(value = "/{id}/{num}")
5.     public String add(@PathVariable(value = "id")String id,@PathVariable("num")Long num) throws InterruptedException {
6.         //对该商品加锁，加锁成功，则判断库存，避免多人同时判断某一个商品的库存
7.         RLock lock = redissonClient.getLock("mylock_" + id);
8.         lock.lock();   //自旋获取锁
9.         System.out.println("获取了锁！"+lock.getName());
11.         try {
12.             // 1.查询库存
13.             int count = Integer.valueOf(redisTemplate.opsForValue().get(id));
14.             System.out.println("剩余库存:"+count);
15.             // 2.库存充足
16.             if (count>=num){
17.                 //模拟操作
18.                 TimeUnit.SECONDS.sleep(5);
20.                 //递减库存
21.                 Long decrement = redisTemplate.opsForValue().decrement(id, num);
22.                 System.out.println("递减库存后剩余库存:"+decrement);
24.                 //其它操作 略
25.                 System.out.println("----添加订单了！");
27.                 return "下单成功";
29.             }
30.             //库存不足
31.             else {
32.                 return "库存不足";
33.             }
34.         } finally {
35.             //释放锁
36.             System.out.println("释放了锁！"+lock.getName());
37.             lock.unlock();
38.         }
39.     }

复制代码

启动2个服务，欣赏器同时发送2个哀求
http://127.0.0.1:8080/order/water/2
http://127.0.0.1:8081/order/water/2

防止了超卖现象

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。