springboot集成redis

我就是我 2021-09-30 14:30 370阅读 0赞

### springboot集成redis ###

*  pom.xml
 *   *  cachRedisUtil(缓存自动化配置)
     *  Controller
     *  Inter
     *  UserImpl
     *  Entity
     *  redis的配置application.properties
     *  swagger运行效果
     *  走缓存效果,效率提高10倍。
     *  未配置转码前，在cmd里面查出的是二进制流效果
     *  配置转码后效果

欢迎大家学习我写的东西，由于工作中没有太多的时间来研究这些内容，所以只有在用到的时候才会仔细去研究，去学习解决问题的方法。欢迎大家多指教。  
本博客实现内容：  
1.redis和springboot集成。  
2.通过统一配置entity类上不需要序列化。  
3.通过统一配置通过redis的控制台命令可以查看到对应的数据信息（解决默认序列化方式造型控制台无法查看的效果）  
使用工具：  
redis： 3.2 windows  
redisClient： 1.5  
springBoot：2.0

# pom.xml #

<dependency>
                <groupId>redis.clients</groupId>
                <artifactId>jedis</artifactId>
                <version>3.1.0</version>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-data-redis</artifactId>
            </dependency>

## cachRedisUtil(缓存自动化配置) ##

package com.liulangtao.frame.demo.utils.redis;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.cache.CacheManager;
    import org.springframework.cache.annotation.EnableCaching;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.data.redis.cache.RedisCacheConfiguration;
    import org.springframework.data.redis.cache.RedisCacheManager;
    import org.springframework.data.redis.connection.RedisConnectionFactory;
    import org.springframework.data.redis.core.RedisTemplate;
    import org.springframework.data.redis.serializer.*;
    
    import java.time.Duration;
    import java.util.HashMap;
    import java.util.HashSet;
    import java.util.Map;
    import java.util.Set;
    
    /**
     *  此方式是通过注解的方式直接放入
     * 1.适合程序的大量的读取方式
     *
     * @version V1.0
     * @Author ---------------------------------
     * @Mail l---------------
     * @Date 2019-08-05  11:25
     * @description
     ***/
    @Configuration
    @EnableCaching
    public class cachRedisUtil {
    
        @Autowired
        private RedisConnectionFactory factory;
        //设置编码方法
        private RedisSerializer<String> keySerializer() {
            return new StringRedisSerializer();
        }
            //设置编码方法
        private RedisSerializer<Object> valueSerializer() {
            return new GenericJackson2JsonRedisSerializer();
        }
        /**
         * 自定义redisTemplate
         * @return
         */
        @Bean
        public RedisTemplate<String, Object> redisTemplate() {
            RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
            redisTemplate.setConnectionFactory(factory);
            // 字符串Key序列化
            redisTemplate.setKeySerializer(keySerializer());
            redisTemplate.setHashKeySerializer(keySerializer());
            redisTemplate.setValueSerializer(valueSerializer());
            redisTemplate.setHashValueSerializer(valueSerializer());
            return redisTemplate;
        }
    
      /**
         * 自定义RedisCacheConfiguration 配置，这里主要是修改了默认的编码格式             jackson2JsonRedisSerializer
         * @return
         */
        @Bean
        public RedisCacheConfiguration redisCacheConfiguration(){
            Jackson2JsonRedisSerializer<Object> jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer<>(Object.class);
            RedisCacheConfiguration configuration = RedisCacheConfiguration.defaultCacheConfig();
            configuration = configuration.serializeValuesWith(
                    RedisSerializationContext
                            .SerializationPair
                            .fromSerializer(jackson2JsonRedisSerializer))
                    .entryTtl(Duration.ofDays(1));
            return configuration;
        }
    
    
        /**
         * 自定义RedisCacheManager（1）修改默认的编码格式。（2）设置缓存的默认有效时间
         * @return
         */
        @Bean
        public CacheManager cacheManager() {
    
            //重新写redis缓存的序列化编码方式
            Jackson2JsonRedisSerializer<Object> jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer<>(Object.class);
            RedisCacheConfiguration configuration = RedisCacheConfiguration.defaultCacheConfig();
            configuration = configuration.serializeValuesWith(
                    RedisSerializationContext
                            .SerializationPair
                            .fromSerializer(jackson2JsonRedisSerializer));
            // 设置缓存的默认过期时间，也是使用Duration设置
            configuration.entryTtl(Duration.ofDays(1));
            Set<String> nameSet = new HashSet<>();
            //设置缓存名称
            nameSet.add("user");
            // 对每个缓存空间应用不同的配置
            Map<String, RedisCacheConfiguration> configMap = new HashMap<>();
            configMap.put("user", configuration.entryTtl(Duration.ofHours(1))); //1小时有效
            RedisCacheManager redisCacheManager = RedisCacheManager
                    .builder(factory)
                    .initialCacheNames(nameSet)
                    .withInitialCacheConfigurations(configMap)
                    .build();
            return redisCacheManager;
        }
    
    }

## Controller ##

//测试自动添加缓存的方法
     @RequestMapping(value = "/getUserList", method = RequestMethod.POST)
        @ResponseBody
        public List<User> getUserList(User user) {
           return   UserInter.getUserList();
    
        }
        //测试自动删除缓存的方法
        @RequestMapping(value = "/getUpdateUsers", method = RequestMethod.POST)
        @ResponseBody
        public List<User>  getUpdateUsers(User user) {
            return   UserInter.getUpdateUsers();
        }

## Inter ##

/**
         * 获得所有的用户信息
         * @return 查询到的用户的列表
         */
       List<User> getUserList();
    
        /**
         * 测试缓存的清除
         * @return
         */
        List<User> getUpdateUsers();

## UserImpl ##

关键点是：注解 @Cacheable 存储对应的信息到缓存  
@CacheEvict 删除对应缓存名称和key下的数据。  
注意：注解是区分大小写的。

/**
         * 获得所有的用户信息
         * 添加缓存的方法
         * @return 查询到的用户的列表
         */
        @Override
    
        @Cacheable(value = "user", key = "123")
        public List<User> getUserList() {
            return  userMapper.getUserList();
        }
    
        /***
         * 1.下面的方法执行完成后 只要缓存名称和key都匹配到的话缓存就会被清除。
         * 2.缓存区分大小写
         * @return
         */
        @Override
       @CacheEvict(value = "user", key = "123")
        public List<User> getUpdateUsers() {
            User us = new User();
            us.setName("zhang");
            us.setAge(20);
            List<User> user = new ArrayList<User>();
            user.add(us);
            return user;
    
        }

## Entity ##

注意：这里没有实现序列化，因为前面已经自动化配置了。

@Data
    public class User   {
        private   String name;
        private Integer age;
    }

## redis的配置application.properties ##

## Redis 配置
    ## Redis数据库索引（默认为0）
    spring.redis.database=0
    ## Redis服务器地址
    spring.redis.host=127.0.0.1
    ## Redis服务器连接端口
    spring.redis.port=6379
    ## Redis服务器连接密码（默认为空）
    spring.redis.password=
    ## 连接池最大连接数（使用负值表示没有限制）
    spring.redis.jedis.pool.max-active=8
    ## 连接池最大阻塞等待时间（使用负值表示没有限制）
    spring.redis.jedis.pool.max-wait=-1
    ## 连接池中的最大空闲连接
    spring.redis.jedis.pool.max-idle=8
    ## 连接池中的最小空闲连接
    spring.redis.jedis.pool.min-idle=0
    ## 连接超时时间（毫秒）
    spring.redis.timeout=12000

## swagger运行效果 ##

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

## 走缓存效果,效率提高10倍。 ##

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

## 未配置转码前，在cmd里面查出的是二进制流效果 ##

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

## 配置转码后效果 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTI5NzY4Nzk_size_16_color_FFFFFF_t_70 4]  
研究一天，欢迎指教。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTI5NzY4Nzk_size_16_color_FFFFFF_t_70]: /images/20210923/086f64bd223d429b8b003b0b8505caa4.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTI5NzY4Nzk_size_16_color_FFFFFF_t_70 1]: /images/20210923/4d29a078caac41d993fcec9a2e24869b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTI5NzY4Nzk_size_16_color_FFFFFF_t_70 2]: /images/20210923/ae9e3ef6c94147cb89fd891b96f3447e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTI5NzY4Nzk_size_16_color_FFFFFF_t_70 3]: /images/20210923/49ca104f069546c6ae925b617e90ea0d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTI5NzY4Nzk_size_16_color_FFFFFF_t_70 4]: /images/20210923/000a445641044fdcb5a8defd84a61223.png