Spring Data Redis

https://blog.csdn.net/lydms/article/details/105224210

Spring-data-redis是 Spring 家族的一部分，提供了在 spring 应用中通过简单的配置访问redis服务，对redis底层开发包(Jedis, JRedis, and RJC)进行了高度封装，RedisTemplate提供了redis各种操作、异常处理及序列化，支持发布订阅，并对spring 3.1 cache进行了实现。 Spring-data-redis针对jedis提供了如下功能：

1. 连接池子冻管理，提供了一个高度封装的RedisTemplate类。

2. 正对jedis客户端中大量api进行归类封装，将同一类型操作封装为operation接

   1. ValueOperations：简单K-V操作

   2. SetOperations：set类型数据操作

   3. ZSetOperations：zset类型数据操作

   4. HashOperations：针对map类型的数据操作

   5. ListOperations：针对list类型的数据操作

3. 提供了对key的“bound”(绑定)便捷化操作API，可以通过bound封装指定的key，然后进行一系列的操作而无须“显式”的再次指定Key，即BoundKeyOperations：

   1. BoundValueOperations

   2. BoundSetOperations

   3. BoundListOperations

   4. BoundSetOperations

   5. BoundHashOperations

4. 将事务操作封装，有容器控制。

5. 针对数据的“序列化/反序列化”，提供了多种可选择策略(RedisSerializer)

RedisTemplate 使用

1. 导入redis启动器依赖

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

1. 配置文件

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

Redis 乱码问题

默认情况下，如果直接使用RedisTemplate，存储在 Redis 中的key看起来会是乱码格式的。

redisTemplate.opsForValue().set("code", "这是一个验证吗123456");

此时真实存储在 Redis 中的验证码及其数据如下图所示：

乱码

这是因为RedisTemplate默认使用的序列化器是JdkSerializationRedisSerializer，而StringRedisTemplate默认使用的是StringRedisSerializer。

序列化器

在实际开发中，一般情况下使用StringRedisTemplate就能满足日常开发的需求。我们也可以通过对RedisTemplate的配置来修复乱码问题

@Configuration
public class RedisConf {
    @Bean
    public RedisTemplate<Object, Object> redisTemplate(LettuceConnectionFactory lettuceConnectionFactory) {
        RedisTemplate<Object, Object> redisTemplate = new RedisTemplate<>();
        redisTemplate.setConnectionFactory(lettuceConnectionFactory);
        // 设置key的序列化方式
        redisTemplate.setKeySerializer(redisTemplate.getStringSerializer());
        // 设置value的序列化方式
        redisTemplate.setValueSerializer(redisTemplate.getStringSerializer());
        return redisTemplate;
    }
}

这里的值显示异常是因为CLI客户端对中文的不支持，但是通过Spring获取到的数据是正常的，我们可以在连接Redis时添加--raw参数对中文的支持

常用API

// 向redis里存入数据并设置缓存时间  
stringRedisTemplate.opsForValue().set("baike", "100", 60 * 10, TimeUnit.SECONDS);
// value 做 -1 操作  
stringRedisTemplate.boundValueOps("baike").increment(-1);
// 根据key获取缓存中的value  
stringRedisTemplate.opsForValue().get("baike")
//val +1  
stringRedisTemplate.boundValueOps("baike").increment(1);
//根据key获取过期时间  
stringRedisTemplate.getExpire("baike");
//根据key获取过期时间并换算成指定单位  
stringRedisTemplate.getExpire("baike",TimeUnit.SECONDS);
//根据key删除缓存  
stringRedisTemplate.delete("baike");
//检查key是否存在，返回boolean值  
stringRedisTemplate.hasKey("baike");
//向指定key中存放set集合  
stringRedisTemplate.opsForSet().add("baike", "1","2","3");
//设置过期时间  
stringRedisTemplate.expire("baike",1000 , TimeUnit.MILLISECONDS);
//根据key查看集合中是否存在指定数据  
stringRedisTemplate.opsForSet().isMember("baike", "1");
//根据key获取set集合  
stringRedisTemplate.opsForSet().members("baike");
//验证有效时间
Long expire = redisTemplate.boundHashOps("baike").getExpire();
System.out.println("redis有效时间："+expire+"S");