Spring整合Redis
一、SpringDataRedis客户端
SpringData是Spring中数据操作的模块,包含对各种数据库的集成,其中对Redis的集成模块就叫做SpringDataRedis,官网地址
- 提供了对不同Redis客户端的整合(Lettuce和Jedis)
- 提供了RedisTemplate统一API来操作Redis
- 支持Redis的发布订阅模型
- 支持Redis哨兵和Redis集群
- 支持基于Lettuce的响应式编程
- 支持基于JDK、JSON、字符串、Spring对象的数据序列化及反序列化
- 支持基于Redis的JDKCollection实现
SpringDataRedis中提供了RedisTemplate工具类,其中封装了各种对Redis的操作。并且将不同数据类型的操作API封装到了不同的类型中:
二、快速入门
首先新建一个Springboot项目,勾选上lombok和SpringDataRedis的依赖。
然后再加入以下依赖
<!--common-pool-->
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-pool2</artifactId>
</dependency>
<!--Jackson依赖-->
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
配置redis:
spring:
application:
name: redis-study
redis:
host: 改成你的服务器公网ip
port: 6379
password: 改成你的密码
lettuce:
pool:
max-active: 8
max-idle: 8
min-idle: 0
max-wait: 100ms
注入RedisTemplate
因为有了SpringBoot的自动装配,我们可以拿来就用:
@SpringBootTest
class RedisStringTests {
@Autowired
private RedisTemplate<String, String> redisTemplate;
}
最后进行单元测试:
@Test
void testString(){
//写入string数据
redisTemplate.opsForValue().set("name","哈哈");
//获取redis数据
final String name = redisTemplate.opsForValue().get("name");
System.out.println("name: "+name);
}
结果如下:
我们可以自定义RedisTemplate的序列化方式,代码如下:
@Configuration
public class RedisConfig {
@Bean
public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory connectionFactory){
// 创建RedisTemplate对象
RedisTemplate<String, Object> template = new RedisTemplate<>();
// 设置连接工厂
template.setConnectionFactory(connectionFactory);
// 创建JSON序列化工具
GenericJackson2JsonRedisSerializer jsonRedisSerializer =
new GenericJackson2JsonRedisSerializer();
// 设置Key的序列化
template.setKeySerializer(RedisSerializer.string());
template.setHashKeySerializer(RedisSerializer.string());
// 设置Value的序列化
template.setValueSerializer(jsonRedisSerializer);
template.setHashValueSerializer(jsonRedisSerializer);
// 返回
return template;
}
}
现在修改测试代码如下:
@Autowired
private RedisTemplate<String, Object> redisTemplate;
@Test
void testString(){
//写入string数据
redisTemplate.opsForValue().set("k1","哈哈");
//获取redis数据
final Object name = redisTemplate.opsForValue().get("k1");
System.out.println("k1: "+name);
}
最后能发现同样测试成功
然后我们测试是否能保存对象
@Data
@NoArgsConstructor
@AllArgsConstructor
public class User {
private String name;
private Integer age;
}
测试:
@Test
void testSaveUser(){
//写入User数据
redisTemplate.opsForValue().set("user:100",new User("djq",23));
//获取数据
final User user =(User) redisTemplate.opsForValue().get("user:100");
System.out.println("user: "+user);
}
直接在数据库内查看,发现存储成了json字符串:
不过,其中记录了序列化时对应的class名称,目的是为了查询时实现自动反序列化。这会带来额外的内存开销。
为了节省内存空间,我们可以不使用JSON序列化器来处理value,而是统一使用String序列化器,要求只能存储String类型的key和value。当需要存储Java对象时,手动完成对象的序列化和反序列化。
Spring默认提供了一个StringRedisTemplate类,他的key和value的序列化方式默认就是String方式。省去了我们自定义RedisTemplate的过程
@Autowired
private StringRedisTemplate stringRedisTemplate;
// JSON序列化工具
private static final ObjectMapper mapper = new ObjectMapper();
@Test
void testSaveUser() throws JsonProcessingException {
// 创建对象
User user = new User("虎哥", 21);
// 手动序列化
String json = mapper.writeValueAsString(user);
// 写入数据
stringRedisTemplate.opsForValue().set("user:200", json);
// 获取数据
String jsonUser = stringRedisTemplate.opsForValue().get("user:200");
// 手动反序列化
User user1 = mapper.readValue(jsonUser, User.class);
System.out.println("user1 = " + user1);
}
这样就不会有包信息了
演示哈希结构的存储:
@Test
void testHash(){
stringRedisTemplate.opsForHash().put("user:300","name","djq");
stringRedisTemplate.opsForHash().put("user:300","age","26");
final Map<Object, Object> entries = stringRedisTemplate.opsForHash().entries("user:300");
System.out.println("entries:"+entries);
}