在Spring boot使用redis缓存

Posted mcorleon

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了在Spring boot使用redis缓存相关的知识,希望对你有一定的参考价值。

1.maven引包

<dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

注:springboot版本1.5.2

 

2. 配置application.properties

# 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.pool.max-active=8
# 连接池最大阻塞等待时间(使用负值表示没有限制)
spring.redis.pool.max-wait=-1
# 连接池中的最大空闲连接
spring.redis.pool.max-idle=8
# 连接池中的最小空闲连接
spring.redis.pool.min-idle=0
# 连接超时时间(毫秒)
spring.redis.timeout=0

注:sever,mybatis等配置不赘述

 

3.为启动类添加注解:

@SpringBootApplication
@MapperScan("com.tqh.demo.mapper")
@EnableScheduling
@EnableCaching
public class DemoApplication {

    public static void main(String[] args) {
        SpringApplication.run(DemoApplication.class, args);
    }
}

 

4.创建redis的配置类

@Configuration
@EnableCaching
public class RedisConfig extends CachingConfigurerSupport {
    @Value("${spring.redis.host}")
    private String host;
    @Value("${spring.redis.port}")
    private int port;
    @Value("${spring.redis.timeout}")
    private int timeout;

    //自定义缓存key生成策略
//    @Bean
//    public KeyGenerator keyGenerator() {
//        return new KeyGenerator(){
//            @Override
//            public Object generate(Object target, java.lang.reflect.Method method, Object... params) {
//                StringBuffer sb = new StringBuffer();
//                sb.append(target.getClass().getName());
//                sb.append(method.getName());
//                for(Object obj:params){
//                    sb.append(obj.toString());
//                }
//                return sb.toString();
//            }
//        };
//    }
    //缓存管理器
    @Bean
    public CacheManager cacheManager(@SuppressWarnings("rawtypes") RedisTemplate redisTemplate) {
        RedisCacheManager cacheManager = new RedisCacheManager(redisTemplate);
        //设置缓存过期时间
        cacheManager.setDefaultExpiration(10000);
        return cacheManager;
    }
    @Bean
    public RedisTemplate<String, String> redisTemplate(RedisConnectionFactory factory){
        StringRedisTemplate template = new StringRedisTemplate(factory);
        setSerializer(template);//设置序列化工具
        template.afterPropertiesSet();
        return template;
    }
    private void setSerializer(StringRedisTemplate template){
        @SuppressWarnings({ "rawtypes", "unchecked" })
        Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
        ObjectMapper om = new ObjectMapper();
        om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
        jackson2JsonRedisSerializer.setObjectMapper(om);
        template.setValueSerializer(jackson2JsonRedisSerializer);
    }
}

 

4.创建测试类 User

public class User {
    String id;
    String name;
    String age;

    public String getId() {
        return id;
    }

    public void setId(String id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public String getAge() {
        return age;
    }

注:数据库里也要创建好相应的表和测试的数据

 

5.创建UserMapper

@Repository
public interface UserMapper {
    @Insert("insert into user(name,age) values(#{name},#{age})")
    int addUser(@Param("name")String name,@Param("age")String age);

    @Select("select * from user where id =#{id}")
    User findById(@Param("id") String id);


    @Update("update user set name=#{name} where id=#{id}")
    void updataById(@Param("id")String id,@Param("name")String name);


    @Delete("delete from user where id=#{id}")
    void deleteById(@Param("id")String id);
}

 

6.创建UserService,缓存就在这层工作

//@Cacheable将查询结果缓存到redis中,(key="#p0")指定传入的第一个参数作为redis的key。
//
//@CachePut,指定key,将更新的结果同步到redis中
//
//@CacheEvict,指定key,删除缓存数据,allEntries=true,方法调用后将立即清除缓存
@Service
@CacheConfig(cacheNames = "users")
public class UserService {
    @Autowired
    UserMapper userMapper;

    @Cacheable(key ="#p0")
    public User selectUser(String id){
        System.out.println("select");
        return userMapper.findById(id);
    }

    @CachePut(key = "#p0")
    public void updataById(String id, String name){
        System.out.println("update");
        userMapper.updataById(id,name);
    }

    //如果指定为 true,则方法调用后将立即清空所有缓存
    @CacheEvict(key ="#p0",allEntries=true)
    public void deleteById(String id){
        System.out.println("delete");
        userMapper.deleteById(id);
    }
}

注: 给key增加额外字符的写法 @Cacheable(key ="\'user\'+#p0")

 

 

7.Controller

@Controller
@RequestMapping("/")
public class RedisController {
    @Autowired
    UserService userService;

    @RequestMapping("select/{id}")
    @ResponseBody
    public User ForTest(@PathVariable String id){
      return userService.selectUser(id);
    }

    @RequestMapping( "/update/{id}")
    @ResponseBody
    public String update(@PathVariable String id){
        userService.updataById(id,"aaa");
        return "update success";
    }

    @RequestMapping( "/delete/{id}")
    @ResponseBody
    public String delete (@PathVariable String id){
        userService.deleteById(id);
        return "delete success";
    }

}

 

测试:

 

第一次select成功,会在控制台打印“select”,说明查询了mysql数据库

第二次以后就不会打印了,因为查的是redis缓存

 

update和delete不赘述,可以在redis客户端查看keys * 看到修改和删除对应的数据变化

 

注:

redis默认的持久化方案是RDB,每xxx分钟如果发生xxx条数据变化就存一次dump文件,重启后会自动恢复(在dump文件的储存目录下启动redis)。

另一种方案是AOF,记录每一次数据的变化,二者都可在redis.conf里配置

 

以上是关于在Spring boot使用redis缓存的主要内容,如果未能解决你的问题,请参考以下文章

Spring Boot 整合Redis 实现缓存

在Spring boot使用redis缓存

spring boot 使用 redis 缓存

spring boot集成redis缓存

spring boot集成redis缓存

spring boot 使用redis缓存