电商项目（十六）--缓存系统

红太狼 2023-07-16 06:58 7阅读 0赞

缓存重要数据，首页在打开时，需要查询很多的数据，访问量也比较大，为了首页打开快快速，渲染的效果更快，用户的体验更好，则需要使用缓存，缓存的效率要高的多。

为了提高首页的查询效率，将数据迁移到缓存中  
先插缓存，若缓存中没有，再去关系型数据库中查询，在将查询的结果插入到缓存中。

# 创建common\_redis模块 #

## 在pom文件中添加依赖 ##

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0"
             xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <parent>
            <artifactId>bz_parent</artifactId>
            <groupId>com.bjsxt</groupId>
            <version>1.0-SNAPSHOT</version>
        </parent>
        <modelVersion>4.0.0</modelVersion>
    
        <artifactId>common_redis</artifactId>
    
        <dependencies>
            
            <dependency>
                <groupId>com.bjsxt</groupId>
                <artifactId>common_pojo</artifactId>
                <version>1.0-SNAPSHOT</version>
            </dependency>
    
            
            <dependency>
                <groupId>com.bjsxt</groupId>
                <artifactId>common_utils</artifactId>
                <version>1.0-SNAPSHOT</version>
            </dependency>
    
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
            </dependency>
            
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-openfeign</artifactId>
            </dependency>
    
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-data-redis</artifactId>
            </dependency>
    
            
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-config</artifactId>
            </dependency>
    
            
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-bus-amqp</artifactId>
            </dependency>
    
            
            <dependency>
                <groupId>net.logstash.logback</groupId>
                <artifactId>logstash-logback-encoder</artifactId>
            </dependency>
        </dependencies>
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
    </project>

## 创建配置文件appilication.yml ##

spring: 
     	application: 
    		name: common-redis 
     	redis: 
     		database: 1 
     		host: 192.168.54.60
    		port: 6379 
    		jedis:
    			pool: 
     			max-active: 200 #最大连接数 
     			max-wait: -1 #连接池最大等待时间(负数表示没有限制) 
    			max-idle: 10 #连接池最大空闲数 
     			min-idle: 0 #连接池最小空闲数 
     			timeout: 2000 #连接超时时间
      server: 
      	port: 9080 
      eureka: 
     	 client: 
     		 serviceUrl: 
     			 defaultZone: http://eureka-server:8761/eureka/

## 创建启动类 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzY2NjA1MQ_size_16_color_FFFFFF_t_70]

## 配置RedisTemplate序列化器 ##

创建一个RedisConfig类，配置RedisTemplate序列化器，

/** * 配置序列化器 */
    @Configuration
    public class RedisConfig { 
    
        /** * 配置RedisTemplate序列化器 */
        @Bean
        public RedisTemplate<String,Object> setRedisTemplate(RedisConnectionFactory factory){ 
    
            //创建RedisTemplate
            RedisTemplate<String,Object> redisTemplate = new RedisTemplate<>();
            redisTemplate.setConnectionFactory(factory);
    
            //设置序列化器
            //创建Redis中的value的序列化器，默认是jdk的，但是内存消耗特别大，换成Jackson2JsonRedisSerializer 比较好
            Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
            //创建ObjectMapper 对象，Jackson2JsonRedisSerializer 转换的核心对象
            ObjectMapper objectMapper = new ObjectMapper();
            objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
            objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
            jackson2JsonRedisSerializer.setObjectMapper(objectMapper);
    
            //创建Redis中的key的序列化器
            StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();
    
            //设置Redis中的String类型的value的序列化器
            redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);
            //设置Redis中的Hash类型的value的序列化器
            redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer);
    
            //设置Redis中的String类型的key的序列化器
            redisTemplate.setKeySerializer(stringRedisSerializer);
    
            //设置Redis中的Hash类型的key的序列化器
            redisTemplate.setHashKeySerializer(stringRedisSerializer);
    		//创建对象以后，在对对象进行设置
            redisTemplate.afterPropertiesSet();
            return redisTemplate;
        }
    }

# 在common\_redis中实现缓存首页商品分类 #

#### 逻辑分析： ####

在访问首页的时先现请求frontend\_portal服务，在调用common\_item服务，在做数据库mysql的查询，在依次返回浏览器。这个时候子查询的时候回比较耗时，降低了用户的体验，因此引入了缓存。  
在访问首页的时候先请求frontend\_portal服务，先请求调用common\_redis服务，在做数据库redis的查询，有数据就返回给浏览器，若没有在调用common\_item服务，在做数据库mysql的查询，在将数据通过common\_redis添加到redis数据库中，再将数据的结果返回给浏览器。

#### 当数据的分类进行了改动，怎么保证数据库的数据和redis的数据同步呢？ ####

若后台进行了增删改操作，需要向common\_redis 的数据全部移除掉即可。  
添加配置文件信息：  
![在这里插入图片描述][2020031814283347.png]

## 下游服务 ##

在common\_redis模块中创建ItemCategoryController类，新增方法：将数据添加缓存首页商品分类，方法的返回值：void，方法的参数：@RequestBody CatResult catResult。向redis缓存中添加数据的方法，查询redis中缓存的商品分类信息的方法。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzY2NjA1MQ_size_16_color_FFFFFF_t_70 1]

在对应的业务层中实现首页商品分类的查询操作。

@Value("${frontend_catresult_redis_key}")
        private String frontend_catresult_redis_key;
    
        /** * 向缓存中添加首页商品分类 * @param catResult */
        @Override
        public void insertItemCategory(CatResult catResult) { 
            this.redisTemplate.opsForValue().set(this.frontend_catresult_redis_key,catResult);
     /** * 查询缓存中的首页商品分类 * @return */
        @Override
        public CatResult selectItemCategory() { 
            return (CatResult)this.redisTemplate.opsForValue().get(this.frontend_catresult_redis_key);
        }
        }

## 上游服务 ##

在frontend\_portal服务中的ItemCategory的类中

在业务层中进行修改先查询缓存，若是有直接查询缓存（使用了try catch 为了不影响下面的查询，即使缓存出错，还可以正常的查询数据库的操作），没有查询数据库，在将数据添加到缓存（使用了try catch 为了不影响下面的查询，即使缓存出错，还可以正常的查询数据库的操作）中即可实现。  
![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzY2NjA1MQ_size_16_color_FFFFFF_t_70 2][]

添加feign的客户端类  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzY2NjA1MQ_size_16_color_FFFFFF_t_70 3]

# 在common\_redis中实现缓存首页大广告位 #

## 下游服务 ##

在common\_redis模块中创建ContentController类，新增方法：将数据缓存首页大广告位，方法的返回值：void，方法的参数：@RequestBody List list。  
新增方法：查询redis中缓存的商品分类信息的方法，方法的返回值：List,方法的参数：无。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzY2NjA1MQ_size_16_color_FFFFFF_t_70 4]

在配置文件中新增配置信息：  
![在这里插入图片描述][20200318151151235.png]  
在业务层中中，新增实现添加数据到缓存的方法。

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzY2NjA1MQ_size_16_color_FFFFFF_t_70 5]

## 上游服务 ##

在frontend\_portal服务中的ContentController 的类中

在业务层中进行修改,先查询缓存，若是有直接查询缓存（使用了try catch 为了不影响下面的查询，即使缓存出错，还可以正常的查询数据库的操作），没有查询数据库，在将数据添加到缓存（使用了try catch 为了不影响下面的查询，即使缓存出错，还可以正常的查询数据库的操作）中即可实现。**(注意：不要忘记在feign中添加对应的接口方法)**  
![在这里插入图片描述][20200318152119161.png]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzY2NjA1MQ_size_16_color_FFFFFF_t_70 6]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzY2NjA1MQ_size_16_color_FFFFFF_t_70]: /images/20230528/f760cb74ebdf4cdd9f99fe6467a507e5.png
[2020031814283347.png]: /images/20230528/6608d8c5ff964523b1539a395231c47f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzY2NjA1MQ_size_16_color_FFFFFF_t_70 1]: /images/20230528/b1ee9a80a899428ab5427935a336a6a1.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzY2NjA1MQ_size_16_color_FFFFFF_t_70 2]: /images/20230528/f5e176ac88644988b86d93dee3ff251d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzY2NjA1MQ_size_16_color_FFFFFF_t_70 3]: /images/20230528/a0b10ae6087e4c9082d67cd0b860c74b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzY2NjA1MQ_size_16_color_FFFFFF_t_70 4]: /images/20230528/63026852c6bc4be9ada54041b4c86eae.png
[20200318151151235.png]: /images/20230528/18d2228922c14a71acb921040e4e8204.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzY2NjA1MQ_size_16_color_FFFFFF_t_70 5]: /images/20230528/2b1cc96e688b4e01a3958c078240a529.png
[20200318152119161.png]: /images/20230528/ebe83b9da2454caba9800c10feca8e62.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzY2NjA1MQ_size_16_color_FFFFFF_t_70 6]: /images/20230528/cea9bd6b7e194206ba23a8d38052cde0.png