SDR - Spring Data Redis的简称。
Spring Data Redis提供了从Spring应用程序轻松配置和访问Redis的功能。它提供了与商店互动的低级别和高级别抽象,使用户免受基础设施问题的困扰。
Spring Boot 实战
引用依赖
<dependency>
<groupId>org.springframework.boot
</groupId>
<artifactId>spring-boot-starter-data-redis
</artifactId>
<version>${spring-boot.version}
</version>
</dependency>
添加redis配置类
@EnableCaching
@Configuration
public class RedisConfig extends CachingConfigurerSupport {
@Bean
public KeyGenerator
keyGenerator() {
return (Object target, Method method, Object... params) -> {
StringBuilder sb =
new StringBuilder();
sb.append(target.getClass().getName());
sb.append(method.getName());
for (Object obj : params) {
sb.append(obj.toString());
}
return sb.toString();
};
}
@Bean
public CacheManager
cacheManager(RedisTemplate redisTemplate) {
RedisCacheManager cacheManager =
new RedisCacheManager(redisTemplate);
cacheManager.setDefaultExpiration(
10000);
return cacheManager;
}
@Bean
public RedisTemplate<String, String>
redisTemplate(RedisConnectionFactory factory) {
StringRedisTemplate template =
new StringRedisTemplate(factory);
template.setValueSerializer(getSerializer(template));
template.afterPropertiesSet();
return template;
}
private RedisSerializer
getSerializer(StringRedisTemplate template) {
ObjectMapper om =
new ObjectMapper();
om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
Jackson2JsonRedisSerializer serializer =
new Jackson2JsonRedisSerializer(Object.class);
serializer.setObjectMapper(om);
return serializer;
}
}
添加redis配置参数:
spring.redis:
database:
0
host:
192.168.1.168
port:
6379
timeout:
0
pool:
max-active:
8
max-idle:
8
max-
wait: -
1
min-idle:
0
开始使用
@Autowired
private RedisTemplate redisTemplate;
...
redisTemplate.opsForValue().set(
"test", System.currentTimeMillis());
...
通过 RedisTemplate 处理对象
大多数用户可能会使用RedisTemplate它的相应软件包org.springframework.data.redis.core-由于其丰富的功能集,模板实际上是Redis模块的中心类。该模板提供了Redis交互的高级抽象。虽然RedisConnection提供接受和返回二进制值(byte数组)的低级别方法,但模板负责序列化和连接管理,使用户无需处理这些细节。
此外,该模板提供了操作视图,它提供丰富的,通用的接口,用于针对特定类型或某些键(通过KeyBound接口)进行操作,如下所述:
键类型操作:
接口描述
GeoOperationsRedis的地理空间操作,如GEOADD,GEORADIUS..HashOperationsRedis散列类型操作HyperLogLogOperationsRedis的HyperLogLog操作,如PFADD,PFCOUNT..ListOperationsRedis列表操作SetOperationsRedis集合操作ValueOperationsRedis字符串操作ZSetOperationsRedis有序集合操作
键绑定操作:
接口描述
BoundGeoOperationsRedis的地理空间操作BoundHashOperationsRedis散列类型键绑定操作BoundKeyOperationsRedis键绑定操作BoundListOperationsRedis列表键绑定操作BoundSetOperationsRedis集合键绑定操作BoundValueOperationsRedis字符串键绑定操作BoundZSetOperationsRedis有序集合键绑定操作
怎么使用?
Spring Boot实战Redis章节配置完成后,使用Spring直接注入即可。
public class Example {
@Autowired
private RedisTemplate<String, String> template;
@Resource(name=
"redisTemplate")
private ListOperations<String, String> listOps;
public void addLink(String userId, URL url) {
listOps.leftPush(userId, url.toExternalForm());
}
}
RedisTemplate是线程安全的,开箱即用,可以在多个实例中重复使用。
RedisTemplate和StringRedisTemplate区别?
org.springframework.data.redis.core.RedisTemplate
org.springframework.data.redis.core.StringRedisTemplate
1、StringRedisTemplate继承自RedisTemplate
2、StringRedisTemplate默认使用String序列化方式,RedisTemplate默认使用jdk自带的序列化方式。
3、两者数据不互通,只能各自管理各自处理过的数据。
推荐使用StringRedisTemplate。
直接与Redis对话
直接底层的与Redis对话,没有封装。默认配置只能一个数据库,如下,可以直接通过获取StringRedisConnection来切换当前操作的数据库。
stringRedisTemplate
.execute((RedisCallback
<Boolean
>) connection
-> {
StringRedisConnection stringRedisConnection
= (StringRedisConnection) connection;
stringRedisConnection
.select(
5);
stringRedisConnection
.set(
"name",
"zoe");
return true;
});
序列化器
从Spring Data Redis框架本身的角度看,存放到redis的数据只是字节,虽然Redis本身支持各种类型,但大部分是指数据存储的方式,而不是它所代表的内容,由用户决定是否将字节转换为字符串或其他对象。
用户自定义类型和原始数据之间的转换由org.springframework.data.redis.serializer包中的序列化器进行处理。
这个包下面主要包含了两种类型的序列化器:
基于RedisSerializer的双向串行器。元素的读写使用的RedisElementReader和RedisElementWriter。
它们的主要区别是,RedisSerializer序列化成byte[],而后者使用的是ByteBuffer。
序列化器实现类
这里有几种开箱即用的实现,其中有两种在之前的文章已经涉及过。
实现描述
StringRedisSerializerString/byte[]转换,速度快JdkSerializationRedisSerializerJDK自带序列化OxmSerializerXML序列化,占空间,速度慢Jackson2JsonRedisSerializerJSON序列化,需要定义JavaTypeGenericJackson2JsonRedisSerializerJSON序列化,无需定义JavaType
所以,如果只是简单的字符串类型,使用StringRedisSerializer就可以了,如果要有对象就使用Json的序列化吧,可以很方便的组装成对象。
事务支持
Spring Data Redis提供了对Redis的事务支持,如:multi, exec, discard命令。
Spring Data Redis提供了SessionCallback接口,在同一个连接中需要执行多个操作时使用,与使用Redis事务时一样。
示例
@Test
public void testTransaction() {
List<Object> txResults = (List<Object>) stringRedisTemplate
.execute(
new SessionCallback<List<Object>>() {
public List<Object>
execute(RedisOperations operations)
throws DataAccessException {
operations.multi();
operations.opsForSet().add(
"t1",
"value1");
operations.opsForSet().add(
"t2",
"value2");
operations.opsForSet().add(
"t3",
"value3");
return operations.exec();
}
});
txResults.forEach(e -> logger.info(
"txResults: " + e));
}
以上代码,是一个接受字符串值的模板,RedisTemplate会使用相应的序列化器,如果把value3换成非字符串333,那第3条会报错,前面两个也不会保存成功。
当然,exec方法也可以接受自定义的序列化器
List
<Object> exec(RedisSerializer
<?> valueSerializer);
@Transactional注解支持
注解事务支持在默认情况下是禁用的,必须通过把RedisTemplate设置明确开启事务支持:setEnableTransactionSupport(true),如果没有错误即成功,有错误就全部回滚。当前连接所有写操作都会进入操作队列,读操作会转移到一个新的连接。
示例配置
@Configuration
public class RedisTxContextConfiguration {
@Bean
public StringRedisTemplate
redisTemplate() {
StringRedisTemplate template =
new StringRedisTemplate(redisConnectionFactory());
template.setEnableTransactionSupport(
true);
return template;
}
@Bean
public PlatformTransactionManager
transactionManager()
throws SQLException {
return new DataSourceTransactionManager(dataSource());
}
@Bean
public RedisConnectionFactory
redisConnectionFactory( // jedis || lettuce);
@Bean
public DataSource
dataSource()
throws SQLException {
}
使用约束
template.opsForValue().
set(
"foo",
"bar");
connection
template.keys(
"*");
template.opsForValue().get(
"foo");
关注下面的微信公众号,回复 “答案” 获取全套Redis面试题及答案。