一文搞定 Spring Data Redis 详解及实战

转载自  一文搞定 Spring Data Redis 详解及实战

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 {@Beanpublic 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();};}@Beanpublic CacheManager cacheManager(RedisTemplate redisTemplate) {RedisCacheManager cacheManager = new RedisCacheManager(redisTemplate);cacheManager.setDefaultExpiration(10000);return cacheManager;}@Beanpublic 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 # Redis数据库索引(默认为0)host: 192.168.1.168port: 6379#password: 123456timeout: 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 {@Autowiredprivate 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序列化,需要定义JavaType
GenericJackson2JsonRedisSerializerJSON序列化,无需定义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 {@Beanpublic StringRedisTemplate redisTemplate() {StringRedisTemplate template = new StringRedisTemplate(redisConnectionFactory());// explicitly enable transaction supporttemplate.setEnableTransactionSupport(true);return template;}@Beanpublic PlatformTransactionManager transactionManager() throws SQLException {return new DataSourceTransactionManager(dataSource());}@Beanpublic RedisConnectionFactory redisConnectionFactory( // jedis || lettuce);@Beanpublic DataSource dataSource() throws SQLException { // ... }
}

使用约束

// 绑定到当前线程上的连接
template.opsForValue().set("foo", "bar");// 读操作不参与事务
connection template.keys("*");// 当在事务中设置的值不可见时返回null
template.opsForValue().get("foo");

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/325288.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

《四世同堂》金句摘抄(十三)

System.out.println("继续看《四世同堂》"); System.out.println("这本书好长啊"); System.out.println("不断的听&#xff0c;不断的看&#xff0c;才到1000多页"); System.out.println("这几天没有好好的读&#xff0c;追求了速度&#x…

StringBuilder的使用

package com.bjsxt.builder; /** StringBuilder的使用 最常用的操作 StringBuilder builder new StringBuilder(“中华人民共和国”);// String—>StringBuilder builder.append(“北京市”); String str builder.toString(); //StringBuilder—>String 使用场合…

.net Core 生产环境 KestrelServer + Shell 实践

1、背景描述 原项目部署在windwos 服务器下的windwos 服务程序。 2、现已经改版为Linux Centos 下的服务程序。 环境说明&#xff1a; 服务器系统&#xff1a;CentOS 7.0 相关工具&#xff1a;Xshel、Xftp 服务器软件软件&#xff1a;.netcore、 1.安装 CentOS 测试环境…

Spring Boot 主类及目录结构介绍

转载自 Spring Boot 主类及目录结构介绍 Spring Boot 与传统项目最大的区别是&#xff0c;传统项目都是打成 WAR 包部署到服务器上面&#xff0c;需要额外的 Servlet 容器&#xff0c; 而 Spring Boot 则可以直接打成 jar 包&#xff0c;并内置集成了 Servlet 容器&#xff…

《四世同堂》金句摘抄(十四)

System.out.println("继续看《四世同堂》"); System.out.println("这本书好长啊"); System.out.println("不断的听&#xff0c;不断的看&#xff0c;才到1000多页"); System.out.println("这几天没有好好的读&#xff0c;追求了速度&#x…

mysql中ifnull函数

当里面的参数为null时使用第二个参数&#xff0c;否则使用第一个参数

integer

new Integer(123)每次都会创建一个新的对象&#xff1b; Integer.valueOf(123)会调用缓存池中的对象&#xff0c;多次调用会取得同一个对象的引用。

NET Core中使用Irony实现自己的查询语言语法解析器

在之前《在ASP.NET Core中使用Apworks快速开发数据服务》一文的评论部分&#xff0c;.NET大神张善友为我提了个建议&#xff0c;可以使用Compile As a Service的Roslyn为语法解析提供支持。在此非常感激友哥给我的建议&#xff0c;也让我了解了一些Roslyn的知识。使用Roslyn的一…

给你一份超详细 Spring Boot 知识清单

转载自 给你一份超详细 Spring Boot 知识清单 在过去两三年的Spring生态圈&#xff0c;最让人兴奋的莫过于Spring Boot框架。或许从命名上就能看出这个框架的设计初衷&#xff1a;快速的启动Spring应用。因而Spring Boot应用本质上就是一个基于Spring框架的应用&#xff0c;…

MySQL里面的in关键字

里面的类型必须一致&#xff0c;不能使用%等通配符(in类似于&#xff1d;)

《四世同堂》金句摘抄(十五)

System.out.println("继续看《四世同堂》"); System.out.println("这本书好长啊"); System.out.println("不断的听&#xff0c;不断的看&#xff0c;才到1000多页"); System.out.println("这几天没有好好的读&#xff0c;追求了速度&#x…

6月Unity技术路演华东站报名启动!

2017 Unity技术路演华东区现已正式开启报名&#xff01;2017年3&#xff5e;5月期间&#xff0c;Unity官方技术团队已分别造访华南、西南地区开展为期一天的技术分享&#xff0c;现在华东站&#xff08;上海、南京、杭州&#xff09;已正式启动&#xff0c;在这个夏天&#xff…

《四世同堂》金句摘抄(十六)

System.out.println("继续看《四世同堂》"); System.out.println("这本书好长啊"); System.out.println("不断的听&#xff0c;不断的看&#xff0c;才到1000多页"); System.out.println("这几天没有好好的读&#xff0c;追求了速度&#x…

Redis 如何分析慢查询操作

转载自 Redis 如何分析慢查询操作 什么是慢查询 和mysql的慢SQL日志分析一样&#xff0c;redis也有类似的功能&#xff0c;来帮助定位一些慢查询操作。 Redis slowlog是Redis用来记录查询执行时间的日志系统。 查询执行时间指的是不包括像客户端响应(talking)、发送回复等…

Arrays工具类(jre中基本类库提供的工具类)

1.Arrays.sort(arr); 给数组arr排序 2.Arrays.toString(arr) 打印arr数组 3.Arrays.binarySearch(arr,26); 在数组中快速的查询给定元素出现的位置 如果找到元素 返回元素索引 没找到返回一个负数 在使用时,要求数组必须是升序的 4.Array.copyOf(arr,arr.length);拷贝数组&a…

mysql中的isnull

where条件中的等于号不能比较空值

使用面向对象(OO)的思想,实现循环输入多个会员的信息,根据会员编号,查找会员积分

先来看一下运行结果&#xff1a; 主要知识点是&#xff1a;对象数组的使用编写软件&#xff1a;Myeclipse 10.5JDK版本&#xff1a;1.7完成时间&#xff1a;25分钟 实现思路&#xff1a; 在会员类中&#xff08;HuiYuan&#xff09;,我们别的事不用干&#xff0c;只需要声明…

应用软件系统程序员的三个立面

这几年工作的重心其实一直没有在代码上&#xff0c;做了很多产品的工作&#xff0c;一直觉得打造一个全面发展的团队一定是我价值所在&#xff0c;所以一直说自己最擅长谈梦想&#xff0c;也确实跟很多人谈了梦想怎么落地、谈了职业规划、孜孜不倦的去聊如何才能踏踏实实的走好…

10 种保护 Spring Boot 应用的绝佳方法

转载自 10 种保护 Spring Boot 应用的绝佳方法 Spring Boot大大简化了Spring应用程序的开发。它的自动配置和启动依赖大大减少了开始一个应用所需的代码和配置量&#xff0c;如果你已经习惯了Spring和大量XML配置&#xff0c;Spring Boot无疑是一股清新的空气。 Spring Boot…