springBoot集成redis

Redis作为一个Java后端面试中的一个常问考点，并且在项目中越来越常用，所以自己动手搭建了一个基于springboot集成redis做为数据缓存的demo（springboot集成mybatis、redis，并具有增删改查询接口）。关注微信公众号【菜鸟阿都】并回复：redis，可获得源码。后面也会继续深入研究redis相关知识，期待与大家一起学习交流。

redis简介基于键值对的开源内存数据库,支持5种数据类型：string（字符串）、hash（哈希）、list（列表）、set（集合）、zset（有序集合）。spring对redis的支持是通过spring Data Redis来实现的，Spring Data Redis 提供了RedisTemplate和StringRedisTemplate两个模板来进行数据操作，StringRedisTemplate只针对键值都是字符型的数据进行操作，StringRedisTemplate继承于RedisTemplate，并采用StringRedisSerializer对键值序列化。

StringRedisTemplate 实现源码

1public class StringRedisTemplate extends RedisTemplate<String, String>{
2    public StringRedisTemplate() {
3    this.setKeySerializer(RedisSerializer.string());
4    this.setValueSerializer(RedisSerializer.string());
5    this.setHashKeySerializer(RedisSerializer.string());
6    this.setHashValueSerializer(RedisSerializer.string());
7    }
8}
9public interface RedisSerializer<T> {
10    static RedisSerializer<String> string() {
11    return StringRedisSerializer.UTF_8;
12    }
13}

1. 添加reids依赖

1<dependency>
2   <groupId>org.springframework.boot</groupId>
3   <artifactId>spring-boot-starter-data-redis</artifactId>
4   <version>2.4.1</version>
5</dependency>

2. 封装redis工具类

将redis的操作方法封装为工具类，方便使用

1 /**
2 * Redis操作工具类
3 */
4@Component
5public class RedisUtil {
6 
7    @Autowired
8    private RedisTemplate<Object, Object> redisTemplate;
9 
10    // 存入数据到缓存
11    public void setValue(String key, Object value) {
12        redisTemplate.opsForValue().set(key, value);
13    }
14 
15    // 通过key获得数据
16    public Object getValue(String key) {
17        return redisTemplate.opsForValue().get(key);
18    }
19 
20    // 存入数据到缓存并设置过期时间（单位为秒）
21    public void setValueAndExpire(String key, Object value, long time){
22        redisTemplate.opsForValue().set(key, value,time,TimeUnit.SECONDS);
23    }
24 
25    // 删除缓存
26    public void delete(String key){
27        redisTemplate.delete(key);
28    }
29}

3. redis使用

查询数据时先查询缓存中是否存在，存在时，返回内存中的数据，缓存中不存在时，再查询数据库并存入缓存，然后返回查询出的数据

1// 根据id查询记录
2@Override
3public User find(int id) {
4    //根据key查询缓存
5    User user=(User) redisUtil.getValue("userKey"+id);
6    //判断是否为空
7    if(user==null){
8        // 缓存为空，查询数据库
9        user=userMapper.find(id);
10        System.out.println("缓存为空，查询数据库");
11        // 插入缓存,并设置过期时间（单位为秒）
12        redisUtil.setValueAndExpire("userKey"+id,user,30);
13        System.out.println("插入缓存");
14    }else{
15        System.out.println("缓存不为空");
16    }
17    return user;
18}

4. 自定义缓存序列化方式

RedisTemplate默认采用JdkSerializaationRedisSerializer方式序列化，以二进制数据存放，使用redis客户端工具查看数据时不直观，并且需要对实体类进行序列化（实现Serializable接口）。所以编写redis的配置类修改RedisTemplate的序列化方式，将JdkSerializaationRedisSerializer序列化方式修改为Jackson2JsonRedisSerialize，以json格式对数据进行保存。StringRedisTemplate默认使用的是StringRedisSerializer。

1@Configuration
2public class RedisConfig   {
3    // 使用Jackson2JsonRedisSerialize替换默认JDK序列化
4    @Bean
5    public RedisTemplate<Object,Object> redisTemplate(RedisConnectionFactory redisConnectionFactory){
6        RedisTemplate<Object,Object> redisTemplate = new RedisTemplate<>();
7        redisTemplate.setConnectionFactory(redisConnectionFactory);
8        // key采用String的序列化方式
9        redisTemplate.setKeySerializer(new StringRedisSerializer());
10        // hash的key也采用String的序列化方式
11        redisTemplate.setHashKeySerializer(new StringRedisSerializer());
12        // value序列化方式采用jackson
13        redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer());
14        // hash的hash的value序列化方式采用jackson
15        redisTemplate.setHashValueSerializer(new GenericJackson2JsonRedisSerializer());
16        return redisTemplate;
17    }    
18}

默认序列化（通过redisClient客户端查看）

使用自定义序列化后，存入缓存中的数据（通过redisClient客户端查看）

5.结果分析

第一次访问时，缓存为空，查询数据库并插入缓存中，总共用时2941毫秒，第二次查询时，直接从缓存中获取，用时仅仅25毫秒。

1缓存为空，查询数据库
2插入缓存
3总用时：2941
4缓存不为空
5总用时：25

springBoot集成redis

评论区

相关推荐