Redis应用（3）——Redis的项目应用（二）：抢购图书 ---＞ Redis高并发的问题 & 分布式锁Redission的使用

柔光的暖阳◎ 2023-10-13 20:44 29阅读 0赞

#### 目录 ####

*  引出
 *  Redis的高并发问题
 *   *  redis的高并发问题
     *  Redisson中间件
     *   *  引入Redisson
         *  Redisson配置
         *  Redisson应用
         *   *  报错：java.lang.NoClassDefFoundErro
 *  Redis的项目应用（二）：抢购图书
 *   *  1.0版本，Java代码：数据不安全
     *  测试方法
     *   *  1.用client方法测试
         *  2.用JMeter进行高并发测试
     *  问题：redis出现了数据不安全的情况
 *  2.0版本，改进：加锁分布式锁Redission，保证原子性
 *   *  Redisson中间件
     *  1.导包+配置类
     *  2.进行加锁
     *  3.高并发测试
 *  总结

## 引出 ##

--------------------

1.Redis是线程安全的，但是高并发时出现数据不安全的问题；  
2.解决办法，加锁，Redission分布式锁的使用；  
3.Redis项目应用，图书的抢购，不加锁，数据不安全；  
4.加了Redission中间件，保证原子性，数据安全；

## Redis的高并发问题 ##

![在这里插入图片描述][30272f2a683b46c482961e9d3c57260d.png]

### redis的高并发问题 ###

![在这里插入图片描述][0f8520a8ebed4010bb8c15530b9bbdad.png]

### Redisson中间件 ###

> Redisson是一个基于Redis的Java驻留内存数据网格（In-Memory Data Grid）。它封装了Redis客户端API，并提供了一个分布式锁、分布式集合、分布式对象、分布式Map等常用的数据结构和服务。

#### 引入Redisson ####

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

#### Redisson配置 ####

@Configuration
    public class RedissionConfig {
        
        @Value("${spring.redis.host}")
        private String host;
       // @Bean
        public RedissonClient redissonClient(){
        
            Config config = new Config();
            config.setTransportMode(TransportMode.EPOLL);
            config.useSingleServer().setAddress("redis://192.168.198.130:6379");
            return Redisson.create(config);
        }
    }

#### Redisson应用 ####

@Autowired
    private RedissonClient redissonClient;
    
    // 1.获取锁对象
    RLock myLock = redissonClient.getLock("myLock");
    
    try{
        
    	// 2.准备锁代码，并进行加锁
    	myLock.lock();
        
    }finally{
        
        // 3.解除锁
        myLock.unlock(); // 把锁释放
    }

##### 报错：java.lang.NoClassDefFoundErro #####

java.lang.NoClassDefFoundError: org/springframework/data/redis/connection/zset/Tuple

org.springframework.data.redis.connection.zset.Tuple

![在这里插入图片描述][36fe06e8f07143f3baf7220a5fda55a8.png]

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

## Redis的项目应用（二）：抢购图书 ##

### 1.0版本，Java代码：数据不安全 ###

controller层的代码

package com.tianju.redisDemo.controller;
    
    import com.tianju.redisDemo.dto.HttpResp;
    import com.tianju.redisDemo.dto.ResultCode;
    import com.tianju.redisDemo.service.IBookService;
    import lombok.extern.slf4j.Slf4j;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Controller;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    import java.util.Date;
    
    @Controller
    @RequestMapping("/api/book")
    @Slf4j
    public class BookController {
        
    
        @Autowired
        private IBookService bookService;
    
        @GetMapping("/rush")
        public HttpResp rushBook(String key){
        
            Integer rushBuy = bookService.rushBuy(key);
            // 如果为null，说明图书还没进入抢购的队列
            if (rushBuy==null){
        
                return HttpResp.results(ResultCode.BOOK_RUSH_ERROR,new Date(),"图书还不能秒杀抢购");
            }
            log.debug("》》》》图书剩余库存："+rushBuy);
            return HttpResp.results(ResultCode.BOOK_RUSH_SUCCESS,new Date(),null);
    
        }
    }

service层的代码

package com.tianju.redisDemo.service.impl;
    
    import com.tianju.redisDemo.service.IBookService;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.data.redis.core.StringRedisTemplate;
    import org.springframework.stereotype.Service;
    import org.springframework.transaction.annotation.Transactional;
    
    @Service
    @Transactional
    public class IBookServiceImpl implements IBookService {
        
    
        @Autowired
        private StringRedisTemplate stringRedisTemplate;
    
        @Override
        public Integer rushBuy(String key) {
        
            String numStr = stringRedisTemplate.opsForValue().get(key);
            if (numStr==null){
        
                return null; // 商品剩余数量还没有进入缓存，不能抢购
            }
            int num = Integer.parseInt(numStr);
            // 如果库存数量大于1；执行-1，去库存操作
            if (num>0){
        
                num--; // 去库存
                // 更新当前库存数量
                stringRedisTemplate.opsForValue().set(key, String.valueOf(num));
            }
            return num;
        }
    }

application.yml配置文件

server:
      port: 9099
    
    spring:
      # redis的相关配置
      redis:
        host: localhost
        port: 6379
        database: 0
    
    
    # 日志需要配置一下
    logging:
      level:
        com.tianju.redisDemo: debug

### 测试方法 ###

#### 1.用client方法测试 ####

![在这里插入图片描述][ed5559c55a594cf0a46b802482ff12b4.png]

![在这里插入图片描述][9663ce62eb7042c0adce12e044b9030b.png]  
![在这里插入图片描述][5b22f35ea2604b6e9f27a80bf7ae32bf.png]

#### 2.用JMeter进行高并发测试 ####

![在这里插入图片描述][08002748f7cd47389023212161cf8e8a.png]

![在这里插入图片描述][4b405a1fa5d74464909f6febafbb111c.png]

![在这里插入图片描述][57aecd1d03394301827db6046292d622.png]

### 问题：redis出现了数据不安全的情况 ###

![在这里插入图片描述][57aecd1d03394301827db6046292d622.png]

![在这里插入图片描述][5f26fc7770d149daa31c6c5928e66014.png]

## 2.0版本，改进：加锁分布式锁Redission，保证原子性 ##

### Redisson中间件 ###

要点：

*  获取锁对象；
 *  准备锁代码；
 *  进行加锁；
 *  解除锁，把锁释放；

>     @Autowired
>     private RedissonClient redissonClient;
>     
>     @Override
>     public Integer rushBuy(String key) {
>         // 1.获取锁对象
>         RLock myLock = redissonClient.getLock("myLock");
>         try {
>             // 2.准备锁代码，并进行加锁
>             myLock.lock();
>             // 进行图书的抢购，去库存 -1
>             }
>             return num;
>         } finally {
>             // 3.解除锁
>             myLock.unlock(); // 把锁释放

![在这里插入图片描述][7c94a52e271e47d9a847d3ad794552a2.png]

### 1.导包+配置类 ###

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

RedissonConfig.java

package com.tianju.springboot.config;
    
    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 RedissonConfig {
        
        @Value("${spring.redis.host}")
        private String host;
    
        @Bean // 别人写的对象，放到spring中
        public RedissonClient redissonClient(){
        
            Config config = new Config();
            // "redis://192.168.198.130:6379"
            config.useSingleServer().setAddress("redis://"+host+":6379");
    
            return Redisson.create(config);
        }
    }

### 2.进行加锁 ###

package com.tianju.redisDemo.service.impl;
    
    import com.tianju.redisDemo.service.IBookService;
    import org.redisson.api.RLock;
    import org.redisson.api.RedissonClient;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.data.redis.core.StringRedisTemplate;
    import org.springframework.stereotype.Service;
    import org.springframework.transaction.annotation.Transactional;
    
    @Service
    @Transactional
    public class IBookServiceImpl implements IBookService {
        
    
        @Autowired
        private StringRedisTemplate stringRedisTemplate;
    
        @Autowired
        private RedissonClient redissonClient;
    
        @Override
        public Integer rushBuy(String key) {
        
            // 1.获取锁对象
            RLock myLock = redissonClient.getLock("myLock");
    
            try {
        
                // 2.准备锁代码，并进行加锁
                myLock.lock();
    
                // 进行图书的抢购，去库存 -1
                String numStr = stringRedisTemplate.opsForValue().get(key);
                if (numStr==null){
        
                    return null; // 商品剩余数量还没有进入缓存，不能抢购
                }
                int num = Integer.parseInt(numStr);
                // 如果库存数量大于1；执行-1，去库存操作
                if (num>0){
        
                    num--; // 去库存
                    // 更新当前库存数量
                    stringRedisTemplate.opsForValue().set(key, String.valueOf(num));
                }
                return num;
            } finally {
        
                // 3.解除锁
                myLock.unlock(); // 把锁释放
    
            }
        }
    }

### 3.高并发测试 ###

![在这里插入图片描述][f76190119ec544a1bcdd113e07d19edc.png]

--------------------

## 总结 ##

[30272f2a683b46c482961e9d3c57260d.png]: https://img-blog.csdnimg.cn/30272f2a683b46c482961e9d3c57260d.png
[0f8520a8ebed4010bb8c15530b9bbdad.png]: https://img-blog.csdnimg.cn/0f8520a8ebed4010bb8c15530b9bbdad.png
[36fe06e8f07143f3baf7220a5fda55a8.png]: https://img-blog.csdnimg.cn/36fe06e8f07143f3baf7220a5fda55a8.png
[ed5559c55a594cf0a46b802482ff12b4.png]: https://img-blog.csdnimg.cn/ed5559c55a594cf0a46b802482ff12b4.png
[9663ce62eb7042c0adce12e044b9030b.png]: https://img-blog.csdnimg.cn/9663ce62eb7042c0adce12e044b9030b.png
[5b22f35ea2604b6e9f27a80bf7ae32bf.png]: https://img-blog.csdnimg.cn/5b22f35ea2604b6e9f27a80bf7ae32bf.png
[08002748f7cd47389023212161cf8e8a.png]: https://img-blog.csdnimg.cn/08002748f7cd47389023212161cf8e8a.png
[4b405a1fa5d74464909f6febafbb111c.png]: https://img-blog.csdnimg.cn/4b405a1fa5d74464909f6febafbb111c.png
[57aecd1d03394301827db6046292d622.png]: https://img-blog.csdnimg.cn/57aecd1d03394301827db6046292d622.png
[5f26fc7770d149daa31c6c5928e66014.png]: https://img-blog.csdnimg.cn/5f26fc7770d149daa31c6c5928e66014.png
[7c94a52e271e47d9a847d3ad794552a2.png]: https://img-blog.csdnimg.cn/7c94a52e271e47d9a847d3ad794552a2.png
[f76190119ec544a1bcdd113e07d19edc.png]: https://img-blog.csdnimg.cn/f76190119ec544a1bcdd113e07d19edc.png