SpringDataRedis
SpringData是Spring中数据操作的模块,包含对各种数据库的集成,其中对Redis的集成模块就叫做SpringDataRedis
提供了对不同Redis客户端的整合(Lettuce和Jedis)
提供了RedisTemplate统一API来操作Redis
支持Redis的发布订阅模型
支持Redis哨兵和Redis集群
支持基于Lettuce的响应式编程
支持基于JDK、JSON、字符串、Spring对象的数据序列化及反序列化
支持基于Redis的JDKCollection实现
SpringDataRedis快速入门
API |
返回值类型 |
说明 |
redisTemplate.opsForValue() |
ValueOperations |
操作String数据类型 |
redisTemplate.opsForHash() |
HashOperations |
操作Hash类型数据 |
redisTemplate.opsForList() |
ListOperations |
操作List类型数据 |
redisTemplate.opsForSet() |
SetOperations |
操作Set类型数据 |
redisTemplate.opsForZSet() |
ZSetOperations |
操作SortedSet类型数据 |
redisTemplate |
|
通用的命令 |
使用(基于SpringBoot)
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> </dependency>
<dependency> <groupId>org.apache.commons</groupId> <artifactId>commons-pool2</artifactId> </dependency>
|
spring: redis: host: 192.168.72.128 port: 6379 password: 123456 lettuce: pool: max-active: 8 max-idle: 8 min-idle: 0 max-wait: 100
|
@Autowired private RedisTemplate redisTemplate;
|
@SpringBootTest public class RedisTest { @Autowired private RedisTemplate 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("Wang", 21)); User o = (User) redisTemplate.opsForValue().get("user:100"); System.out.println("o = " + o); } }
|
插入数据出现了问题,序列化出现了问题,变成了字节
缺点:可读性差且占用内存大
改进(自己定义序列化和反序列化)
public class RedisConfig {
@Bean public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory connectionFactory) { RedisTemplate<String, Object> template = new RedisTemplate<>(); template.setConnectionFactory(connectionFactory); GenericJackson2JsonRedisSerializer jsonRedisSerializer = new GenericJackson2JsonRedisSerializer(); template.setKeySerializer(RedisSerializer.string()); template.setHashKeySerializer(RedisSerializer.string()); template.setValueSerializer(jsonRedisSerializer); template.setHashValueSerializer(jsonRedisSerializer); return template; } }
|
为了在反序列化时知道对象的类型,JSON序列化器会将类的class类型写入json结果中,存入Redis,会带来额外的内存开销。
为了节省内存空间,我们并不会使用JSON序列化器来处理value,而是统一使用String序列化器,要求只能存储String类型的key和value。当需要存储Java对象时,手动完成对象的序列化和反序列化。
Spring默认提供了一个StringRedisTemplate类,它的key和value的序列化方式默认就是String方式。省去了我们自定义RedisTemplate的过程:
使用StringRedisTemplate和手动序列化和反序列化
@SpringBootTest class RedisStringTests {
@Autowired private StringRedisTemplate stringRedisTemplate;
@Test void testString() { stringRedisTemplate.opsForValue().set("name", "string测试"); Object name = stringRedisTemplate.opsForValue().get("name"); System.out.println("name = " + name); }
private static final ObjectMapper mapper = new ObjectMapper();
@Test void testSaveUser() throws JsonProcessingException { User user = new User("Wang-nine", 9); 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); }
}
|
==RedisTemplate的两种序列化实践方案:==
- 方案一:
1.自定义RedisTemplate
2.修改RedisTemplate的序列化器为GenericJackson2JsonRedisSerializer
- 方案二:
1.使用StringRedisTemplate
2.写入Redis时,手动把对象序列化为JSON
3.读取Redis时,手动把读取到的JSON反序列化为对象
注意:有关于Hash数据结构的存取
@Test void TestHash() { stringRedisTemplate.opsForHash().put("user:400", "测试300", "300"); stringRedisTemplate.opsForHash().put("user:400", "测试400", "400");
Map<Object, Object> entries = stringRedisTemplate.opsForHash().entries("user:400"); System.out.println(entries); }
|