28个案例问题分析---01---redis没有及时更新问题--Redis

谁借莪１个温暖的怀抱￠ 2023-10-09 15:47 109阅读 0赞

#### redis没有及时更新问题 ####

*  一：背景介绍
 *  二：前期准备
 *   *  2.1 pom依赖
     *  2.2 连接Redis工具类
     *  2.3 连接mysql工具类
     *   *  2.3.1 配置文件
         *  2.3.2 连接mysql工具类
         *  2.3.3 项目结构
 *  三：过程
 *   *  3.1 使用redis缓存，缓存用户年龄
     *   *  3.1.2 业务对应流程图
         *  3.1.3 使用redis缓存用户年龄对应代码
     *  3.2 执行代码，控制台打印
     *  3.3 查看redis内数据
     *  3.4 查看数据库内数据
     *  3.5 更新age数据
     *  3.6 更新完之后redis内数据
     *  3.7 更新完之后数据库内数据
     *  3.8 存在问题
 *  四：总结

## 一：背景介绍 ##

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

*  业务中使用redis做缓存，来减少对数据库的操作，提升速度。
 *  使用的过程是去redis内查询数据。如果有的话直接返回redis内的数据，如果没有的话去数据库查询数据，并将其存储到redis中，那么下次的查询就是在redis内查询的，省去了我们多次查询数据库的操作。
 *  但是我们这个业务里，redis内存的数据可能与数据库的不一致。导致这种现象的原因是。在另外的业务中更改了数据库内的数据后，没有去修改redis内的数据，于是造成了redis数据与数据库数据不一致的问题。
 *  下面我就用一个小例子，演示上述问题，以及解决方案

## 二：前期准备 ##

此实例是一个**普通的maven项目**。使用前需要准备好mysql数据库，redis。具体安装的方式大家可以自行上网查询，这里不做介绍。

### 2.1 pom依赖 ###

项目连接mysql和redis，需要在maven内引入以下两个依赖.

<dependencies>
            <dependency>
                <groupId>redis.clients</groupId>
                <artifactId>jedis</artifactId>
                <version>3.3.0</version>
            </dependency>
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
                <version>5.1.46</version>
            </dependency>
        </dependencies>

### 2.2 连接Redis工具类 ###

编写一个连接Redis的工具类，这里直接使用的Jedis进行的连接。

/**
     * @BelongsProject: redis
     * @BelongsPackage: org.example.utils
     * @Author:hlzs1
     * @Description: redis的工具类
     * @CreateTime: 2023-03-03 20:42
     * @Version: 1.0
     */
    public class RedisUtils {
        
        public static Jedis jedis ;
        static {
        
            jedis = new Jedis("ip地址",6379,10000);
            //没有设置密码可以不填
            jedis.auth("000415");
        }
    
        /**
         * @description: 在redis取出数据
         * @author: haolizhuo
         * @date: 2023/3/4
         * @param: [key]
         * @return: java.lang.Object
         **/
        public  static Object redisGet(String key){
        
            return RedisUtils.jedis.get(key);
        }
    
        /**
         * @description:向redis存储数据
         * @author: haolizhuo
         * @date: 2023/3/4
         * @param: [key, value, seconds]
         * @return: void
         **/
        public static void redisSet(String key, String value, @Nullable Integer seconds){
        
            RedisUtils.jedis.set(key,value);
            if(seconds !=null){
        
                RedisUtils.jedis.expire(key,seconds);
            }
    
        }
    }

### 2.3 连接mysql工具类 ###

连接mysql需要对应的配置文件，新建一个jdbc.properties文件将此文件放到resources目录下即可

#### 2.3.1 配置文件 ####

userName=root
    password=deng123~
    url=jdbc:mysql://ip地址/数据库名?useSSL=false&useUnicode=true&characterEncoding=utf8
    driverClass=com.mysql.cj.jdbc.Driver

#### 2.3.2 连接mysql工具类 ####

连接数据库的工具类

/**
     * @author : [haolizhuo]
     * @version : [v1.0]
     * @className : JDBCUtils
     * @description : [描述说明该类的功能]
     * @createTime : [2022/11/30 11:24]
     * @updateUser : [haolizhuo]
     * @updateTime : [2022/11/30 11:24]
     * @updateRemark : [描述说明本次修改内容]
     */
    public class JDBCUtils {
        
        private static String url;
        private static String userName;
        private static String password;
        private static String driverClass;
    
        private static Connection connection;
    
        static {
        
            try {
        
                Properties properties = new Properties();
    
                InputStream inputStream = JDBCUtils.class.getClassLoader().getResourceAsStream("jdbc.properties");
    
                properties.load(inputStream);
    
                driverClass = properties.getProperty("driverClass");
                url = properties.getProperty("url");
                userName = properties.getProperty("userName");
                password = properties.getProperty("password");
    
            } catch (Exception e) {
        
                e.printStackTrace();
            }
        }
    
        /*
         * @version V1.0
         * Title: getConnection
         * @author haolizhuo
         * @description 获取数据库连接
         * @createTime  2022/11/30 11:36
         * @param []
         * @return java.sql.Connection
         */
        public static Connection getConnection() {
        
            try {
        
                connection = DriverManager.getConnection(url, userName, password);
            } catch (Exception e) {
        
                e.printStackTrace();
            }
            return connection;
        }
    
        /*
         * @version V1.0
         * Title: close
         * @author haolizhuo
         * @description 释放资源
         * @createTime  2022/11/30 11:39
         * @param [connection, statement, resultSet]
         * @return void
         */
        public static void close(Connection connection, Statement statement, ResultSet resultSet) {
        
            if (connection != null) {
        
                try {
        
                    connection.close();
                } catch (SQLException e) {
        
                    e.printStackTrace();
                }
            }
    
            if (statement != null) {
        
                try {
        
                    statement.close();
                } catch (SQLException e) {
        
                    e.printStackTrace();
                }
            }
    
            if (resultSet != null) {
        
                try {
        
                    resultSet.close();
                } catch (SQLException e) {
        
                    e.printStackTrace();
                }
            }
        }

#### 2.3.3 项目结构 ####

![在这里插入图片描述][3fa849346cb24b92b0d1bdb9bced6835.png]  
到这里我们真个环境就准备好了，下面我们就复现背景里提到的，使用缓存的情况

## 三：过程 ##

### 3.1 使用redis缓存，缓存用户年龄 ###

这里是一个普通的使用redis的场景，我使用redis缓存了用户的年龄。key值是用户的id，value值是用户的年龄。

#### 3.1.2 业务对应流程图 ####

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

#### 3.1.3 使用redis缓存用户年龄对应代码 ####

public static void main(String[] args) {
        
    
            //使用redis缓存,缓存某个id的用户的年龄，这里以1做示例
            String userId = "1";
            Object redisUserInfo = RedisUtils.redisGet(userId);
            //如果缓存查到信息，直接返回，并且结束
            if(null != redisUserInfo){
        
                System.out.println("redis获取到了用户"+userId+"的年龄，年龄为：" + redisUserInfo);
                return;
            }
            //缓存里没有就去数据库进行查询
            String sql ="select * from user_info where id = " + userId;
            Map<String, Object> userInfo = getUserInfo(sql);
            //如果查询到了信息，更新到缓存内
            if(userInfo != null){
        
                System.out.println("mysql获取到了用户"+userId+"的年龄，年龄为：" + userInfo.get("age"));
                RedisUtils.redisSet(userInfo.get("id").toString(),userInfo.get("age").toString(),60);
            }
    
        }
    
        /**
         * @description: 数据库查询用户数据
         * @author: haolizhuo
         * @date: 2023/3/4
         * @param: [sql]
         * @return: java.util.Map<java.lang.String,java.lang.Object>
         **/
        private static Map<String, Object> getUserInfo(String sql){
        
            Connection connection;
            Statement statement;
            ResultSet resultSet;
            Map<String , Object> map = new HashMap<>(16);
            try {
        
                //创建数据库连接
                connection = JDBCUtils.getConnection();
                statement = connection.createStatement();
                resultSet = statement.executeQuery(sql);
                //将值取出
                while (resultSet.next()){
        
                    map.put("id",resultSet.getInt("id"));
                    map.put("name",resultSet.getString("name"));
                    map.put("age",resultSet.getInt("age"));
                }
    
            } catch (SQLException e) {
        
                throw new RuntimeException(e);
            }
            return map;
        }

这部分代码是没有问题，通过redis做了对应缓存。如果缓存过期了之后，就去数据库内查询，并且更新到缓存中。但是问题是，假设我们有别的业务更新了我们缓存的age数据，同时redis的数据没有过期，这是后就会造成一个数据不一致的问题。

### 3.2 执行代码，控制台打印 ###

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

### 3.3 查看redis内数据 ###

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

### 3.4 查看数据库内数据 ###

![在这里插入图片描述][1b7831deda9f4864b55ccd6f13c3e703.png]  
现在我们的数据是正确无误，缓存与数据库数据一致。可如果我们的业务更新这个age的话，就会产生不一致的问题

### 3.5 更新age数据 ###

public static void main(String[] args) {
        
            String sql = "update user_info set age = 66 where id = 1";
            updateUserInfo(sql);
        }
    
    	    /**
         * @description: 数据库修改用户数据
         * @author: haolizhuo
         * @date: 2023/3/4
         * @param: [sql]
         * @return: void
         **/
        private static void updateUserInfo(String sql){
        
            Connection connection;
            Statement statement;
            int resultSet;
            try {
        
                //创建数据库连接
                connection = JDBCUtils.getConnection();
                statement = connection.createStatement();
                resultSet = statement.executeUpdate(sql);
                System.out.println(resultSet);
            } catch (SQLException e) {
        
                throw new RuntimeException(e);
            }
        }

### 3.6 更新完之后redis内数据 ###

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

### 3.7 更新完之后数据库内数据 ###

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

### 3.8 存在问题 ###

这时候，问题就暴露出来了，缓存数据与数据库数据不一致。并且缓存的数据还未过期。导致过期前查询的数据都不准确。  
所以在使用缓存的时候，如果数据库内数据改了，一定要及时的  
**清空缓存！！！！清空缓存！！！！清空缓存！！！！**

## 四：总结 ##

这个问题的出现的根本原因是。不同的开发人员没有做好沟通，这两个业务是不同的人员编写的，没有考虑的业务的相关性，导致了这种问题的出现！！  
所以不仅仅要实现功能也要考虑业务相关性！！！

[792ac0522aea4a548d840d269c257a76.png]: https://img-blog.csdnimg.cn/792ac0522aea4a548d840d269c257a76.png
[3fa849346cb24b92b0d1bdb9bced6835.png]: https://img-blog.csdnimg.cn/3fa849346cb24b92b0d1bdb9bced6835.png
[553835565af4435baa0b908000ea0379.png]: https://img-blog.csdnimg.cn/553835565af4435baa0b908000ea0379.png
[ca10fcafb52a4fd3a2c27deff332ee43.png]: https://img-blog.csdnimg.cn/ca10fcafb52a4fd3a2c27deff332ee43.png
[e4155caaadd74e34ae1c227b65cdb1f2.png]: https://img-blog.csdnimg.cn/e4155caaadd74e34ae1c227b65cdb1f2.png
[1b7831deda9f4864b55ccd6f13c3e703.png]: https://img-blog.csdnimg.cn/1b7831deda9f4864b55ccd6f13c3e703.png
[63093a4bd45b4702b8e687ae10e7ba33.png]: https://img-blog.csdnimg.cn/63093a4bd45b4702b8e687ae10e7ba33.png
[e828b53d167f430688786f749e577b03.png]: https://img-blog.csdnimg.cn/e828b53d167f430688786f749e577b03.png