本文共 8632 字，大约阅读时间需要 28 分钟。

springboot整合redis

步骤

springboot整合redis由于springboot只有一个配置文件，所以在application.yml中可以用配置完成前三步。 application.yml 注意要配置在spring:下面

redis:    database: 0    host: 192.168.23.128    port: 6379    password: 123456    jedis:      pool:        max-active: 100        max-idle: 3        max-wait: -1        min-idle: 0    timeout: 1000

打开redis

最后一步则需要SpringBoot配置类来完成

SpringBoot配置类

配置缓存策略

注解标签 @Configuration @Configuration底层是含有@Component ，所以@Configuration 具有和 @Component 的作用。 @Configuration可理解为用spring的时候xml里面的标签。 注： 1.配置类必须以类的形式提供（不能是工厂方法返回的实例），允许通过生成子类在运行时增强（cglib 动态代理）。 2.配置类不能是 final 类（没法动态代理）。 3. 配置注解通常为了通过 @Bean 注解生成 Spring 容器管理的类 4. 配置类必须是非本地的（即不能在方法中声明，不能是 private）。 5任何嵌套配置类都必须声明为static。 6.@Bean方法不能创建进一步的配置类（也就是返回的bean如果带有@Configuration，也不会被特殊处理，只会作为普通的 bean）。 @EnableCaching 1.@EnableCaching注解是spring framework中的注解驱动的缓存管理功能。自spring版本3.1起加入了该注解。 2.如果你使用了这个注解，那么你就不需要在XML文件中配置cache manager了。 3.当你在配置类(@Configuration)上使用@EnableCaching注解时，会触发一个post processor，这会扫描每一个spring bean，查看是否已经存在注解对应的缓存。如果找到了，就会自动创建一个代理拦截方法调用，使用缓存的bean执行处理。 @Bean @Bean可理解为用spring的时候xml里面的标签。 注： 1.@Bean注解在返回实例的方法上，如果未通过@Bean指定bean的名称，则默认与标注的方法名相同； 2.@Bean注解默认作用域为单例singleton作用域，可通过@Scope(“prototype”)设置为原型作用域； 3.既然@Bean的作用是注册bean对象，那么完全可以使用@Component、@Controller、@Service、@Repository等注解注册bean（在需要注册的类上加注解），当然需要配置@ComponentScan注解进行自动扫描。 导入redis的依赖

   		
    
     org.springframework.boot
    		
    
     spring-boot-starter-data-redis
    	
   	
   		
    
     redis.clients
    		
    
     jedis
    	
   

创建RedisConfig

RedisConfig类用于Redis数据缓存。 //继承CachingConfigurerSupport，为了自定义生成KEY的策略。可以不继承。

package com.zxp.springboot02.config;import com.fasterxml.jackson.annotation.JsonAutoDetect;import com.fasterxml.jackson.annotation.PropertyAccessor;import com.fasterxml.jackson.databind.ObjectMapper;import org.springframework.cache.CacheManager;import org.springframework.cache.annotation.CachingConfigurerSupport;import org.springframework.cache.annotation.EnableCaching;import org.springframework.cache.interceptor.KeyGenerator;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.core.StringRedisTemplate;import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;import org.springframework.data.redis.serializer.StringRedisSerializer;import java.lang.reflect.Method;import java.time.Duration;import java.util.HashMap;import java.util.HashSet;import java.util.Map;import java.util.Set;/** * redis配置类 **/@Configuration@EnableCaching//开启注解式缓存//继承CachingConfigurerSupport，为了自定义生成KEY的策略。可以不继承。public class RedisConfig extends CachingConfigurerSupport {    /**     * 生成key的策略 根据类名+方法名+所有参数的值生成唯一的一个key     *可用可不用     * @return     */    @Bean    @Override    public KeyGenerator keyGenerator() {        return new KeyGenerator() {            @Override            public Object generate(Object target, Method method, Object... params) {                StringBuilder sb = new StringBuilder();                sb.append(target.getClass().getName());                sb.append(method.getName());                for (Object obj : params) {                    sb.append(obj.toString());                }                return sb.toString();            }        };    }    /**     * 管理缓存     *     * @param redisConnectionFactory     * @return     */    @Bean    public CacheManager cacheManager(RedisConnectionFactory redisConnectionFactory) {        //通过Spring提供的RedisCacheConfiguration类，构造一个自己的redis配置类，从该配置类中可以设置一些初始化的缓存命名空间        // 及对应的默认过期时间等属性，再利用RedisCacheManager中的builder.build()的方式生成cacheManager：        RedisCacheConfiguration config = RedisCacheConfiguration.defaultCacheConfig();  // 生成一个默认配置，通过config对象即可对缓存进行自定义配置        config = config.entryTtl(Duration.ofMinutes(1))     // 设置缓存的默认过期时间，也是使用Duration设置                .disableCachingNullValues();     // 不缓存空值        // 设置一个初始化的缓存空间set集合        Set
   
     cacheNames = new HashSet<>();        cacheNames.add("my-redis-cache1");        cacheNames.add("my-redis-cache2");        // 对每个缓存空间应用不同的配置        Map
    
      configMap = new HashMap<>();        configMap.put("my-redis-cache1", config);        configMap.put("my-redis-cache2", config.entryTtl(Duration.ofSeconds(120)));        RedisCacheManager cacheManager = RedisCacheManager.builder(redisConnectionFactory)     // 使用自定义的缓存配置初始化一个cacheManager                .initialCacheNames(cacheNames)  // 注意这两句的调用顺序，一定要先调用该方法设置初始化的缓存名，再初始化相关的配置                .withInitialCacheConfigurations(configMap)                .build();        return cacheManager;    }    @Bean    public RedisTemplate
     
       redisTemplate(RedisConnectionFactory connectionFactory) {        RedisTemplate
      
        template = new RedisTemplate<>();        template.setConnectionFactory(connectionFactory);        //使用Jackson2JsonRedisSerializer来序列化和反序列化redis的value值（默认使用JDK的序列化方式）        Jackson2JsonRedisSerializer serializer = new Jackson2JsonRedisSerializer(Object.class);        ObjectMapper mapper = new ObjectMapper();        mapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);        mapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);        serializer.setObjectMapper(mapper);        template.setValueSerializer(serializer);        //使用StringRedisSerializer来序列化和反序列化redis的key值        template.setKeySerializer(new StringRedisSerializer());        template.afterPropertiesSet();        return template;    }    @Bean    public StringRedisTemplate stringRedisTemplate(RedisConnectionFactory factory) {        StringRedisTemplate stringRedisTemplate = new StringRedisTemplate();        stringRedisTemplate.setConnectionFactory(factory);        return stringRedisTemplate;    }}
      
     
    
   

详细针对下面这段代码进行讲解

序列化：导入pom依赖

   
    2.9.3
   
               
    
     com.fasterxml.jackson.core
                
    
     jackson-databind
                
    
     ${jackson.version}
            
           
               
    
     com.fasterxml.jackson.core
                
    
     jackson-core
                
    
     ${jackson.version}
            
           
               
    
     com.fasterxml.jackson.core
                
    
     jackson-annotations
                
    
     ${jackson.version}
            
   

实体类序列化

package com.zxp.springboot02.model;import lombok.ToString;import java.io.Serializable;@ToStringpublic class Book implements Serializable {    private Integer bid;    private String bname;    private Float price;    public Book(Integer bid, String bname, Float price) {        this.bid = bid;        this.bname = bname;        this.price = price;    }    public Book() {        super();    }    public Integer getBid() {        return bid;    }    public void setBid(Integer bid) {        this.bid = bid;    }    public String getBname() {        return bname;    }    public void setBname(String bname) {        this.bname = bname;    }    public Float getPrice() {        return price;    }    public void setPrice(Float price) {        this.price = price;    }}

配置（整合）完成

springboot：redis注解式开发

常用缓存注解

@Cacheable：

作用是主要针对方法配置，能够根据方法的请求参数对其结果进行缓存 主要参数说明：

1. value ： 缓存的名称，在 spring 配置文件中定义，必须指定至少一个
2. key ：缓存的 key，可以为空，如果指定要按照 SpEL 表达式编写，如果不指定，则缺省按照方法的所有参数进行组合
3. condition ：缓存的条件，可以为空

@CachePut：

作用是主要针对方法配置，能够根据方法的请求参数对其结果进行缓存，和 @Cacheable 不同的是，它每次都会触发真实查询 主要参数说明： 参数配置和@Cacheable一样。 @CacheEvic： 作用是主要针对方法配置，能够根据一定的条件对缓存进行清空 主要参数说明：

1. value ： key 和 condition 参数配置和@Cacheable一样。
2. allEntries ：是否清空所有缓存内容，缺省为 false，如果指定为 true，则方法调用后将立即清空所有缓存

代码演示

@Cacheable service层

//表示使用my-redis-cache1缓存空间，key的生成策略为book+bid，达成条件bid>1的时候才会使用缓存    @Cacheable(value = "my-redis-cache1",key = "'id-#='+#bid",condition = "#bid>1")    Book selectByPrimaryKey(Integer bid);

测试代码

@Test    public  void  sel(){        System.out.println(this.bookService.selectByPrimaryKey(2));        System.out.println(this.bookService.selectByPrimaryKey(2));    }

测试截图

@CachePut service层

//只写不读      @CachePut(value = "my-redis-cache1",key = "'id-#='+#bid",condition = "#bid>1")    Book selectByPrimaryKey(Integer bid);

测试代码

@Test    public  void  sel(){        System.out.println(this.bookService.selectByPrimaryKey(2));        System.out.println(this.bookService.selectByPrimaryKey(2));    }

测试截图

小结 @CachePut： 只写不读

高并发

数据的读写分离 @CacheEvic service层

@CacheEvict(value = "my-redis-cache2",allEntries = true)    void clear();

测试代码

@Test    public void clear() {        bookService.clear();    }

测试截图

转载地址：http://murzi.baihongyu.com/