文章目录
- 1、为什么要进行序列化操作?
- 2、序列化方式
- 2.1、自定义序列化
- 2. 2、StringRedisTemplate(重点)
1、为什么要进行序列化操作?
不进行序列化向redis存入数据代码:
@SpringBootTest
class RedisDemoApplicationTests {
@Autowired
private RedisTemplate redisTemplate;
@Test
void testString() {
redisTemplate.opsForValue().set("name", "狗哥");
Object name = redisTemplate.opsForValue().get("name");
System.out.println("name = " + name);
}
}
默认使用的JDK的序列化为字节的方式,JDK序列化的缺点:
- 可读性差
- 内存占用大
2、序列化方式
2.1、自定义序列化
使用Json序列化代替JDK序列化
@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.setHashKeySerializer(jsonRedisSerializer);
//返回
return template;
}
}
@SpringBootTest
class RedisDemoApplicationTests {
@Autowired
private RedisTemplate<String, Object> redisTemplate;
@Test
void testString() {
redisTemplate.opsForValue().set("name", "狗哥");
Object name = redisTemplate.opsForValue().get("name");
System.out.println("name = " + name);
}
@Test
void testSaveUser(){
//写入数据
redisTemplate.opsForValue().set("user:100", new User("虎哥", 21));
//获取数据
Object o = (User)redisTemplate.opsForValue().get("user:100");
System.out.println("o = " + o);
}
}
2. 2、StringRedisTemplate(重点)
不使用JSON序列化器来处理value,统一使用String序列化器。
只存储String类型的key和value。
存储Java对象时,手动进行对象的序列化和反序列化。
@SpringBootTest
public class RedisStringTests {
@Autowired
private StringRedisTemplate stringRedisTemplate;
@Test
void testString() {
stringRedisTemplate.opsForValue().set("name1", "哥");
Object name = stringRedisTemplate.opsForValue().get("name1");
System.out.println("name1 = " + name);
}
//定义序列化对象
private static final ObjectMapper mapper = new ObjectMapper();
@Test
void testSaveUser() throws JsonProcessingException {
//创建对象
User user = new User("虎哥", 18);
//手动序列化
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);
}
}