javascript
一文搞定 Spring Data Redis 详解及实战
轉(zhuǎn)載自??一文搞定 Spring Data Redis 詳解及實戰(zhàn)
SDR - Spring Data Redis的簡稱。
Spring Data Redis提供了從Spring應用程序輕松配置和訪問Redis的功能。它提供了與商店互動的低級別和高級別抽象,使用戶免受基礎設施問題的困擾。
Spring Boot 實戰(zhàn)
引用依賴
<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配置參數(shù):
spring.redis:database:?0?#?Redis數(shù)據(jù)庫索引(默認為0)host:?192.168.1.168port:?6379#password:?123456timeout:?0?#?連接超時時間(毫秒)pool:?max-active:?8?#?連接池最大連接數(shù)(使用負值表示沒有限制)max-idle:?8?#?連接池中的最大空閑連接max-wait:?-1?#?連接池最大阻塞等待時間(使用負值表示沒有限制)min-idle:?0?#?連接池中的最小空閑連接開始使用
@Autowired private?RedisTemplate?redisTemplate;... redisTemplate.opsForValue().set("test",?System.currentTimeMillis()); ...通過 RedisTemplate 處理對象
大多數(shù)用戶可能會使用RedisTemplate它的相應軟件包org.springframework.data.redis.core-由于其豐富的功能集,模板實際上是Redis模塊的中心類。該模板提供了Redis交互的高級抽象。雖然RedisConnection提供接受和返回二進制值(byte數(shù)組)的低級別方法,但模板負責序列化和連接管理,使用戶無需處理這些細節(jié)。
此外,該模板提供了操作視圖,它提供豐富的,通用的接口,用于針對特定類型或某些鍵(通過KeyBound接口)進行操作,如下所述:
鍵類型操作:
| GeoOperations | Redis的地理空間操作,如GEOADD,GEORADIUS.. |
| HashOperations | Redis散列類型操作 |
| HyperLogLogOperations | Redis的HyperLogLog操作,如PFADD,PFCOUNT.. |
| ListOperations | Redis列表操作 |
| SetOperations | Redis集合操作 |
| ValueOperations | Redis字符串操作 |
| ZSetOperations | Redis有序集合操作 |
鍵綁定操作:
| BoundGeoOperations | Redis的地理空間操作 |
| BoundHashOperations | Redis散列類型鍵綁定操作 |
| BoundKeyOperations | Redis鍵綁定操作 |
| BoundListOperations | Redis列表鍵綁定操作 |
| BoundSetOperations | Redis集合鍵綁定操作 |
| BoundValueOperations | Redis字符串鍵綁定操作 |
| BoundZSetOperations | Redis有序集合鍵綁定操作 |
怎么使用?
Spring Boot實戰(zhàn)Redis章節(jié)配置完成后,使用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區(qū)別?
org.springframework.data.redis.core.RedisTemplate
org.springframework.data.redis.core.StringRedisTemplate
1、StringRedisTemplate繼承自RedisTemplate
2、StringRedisTemplate默認使用String序列化方式,RedisTemplate默認使用jdk自帶的序列化方式。
3、兩者數(shù)據(jù)不互通,只能各自管理各自處理過的數(shù)據(jù)。
推薦使用StringRedisTemplate。
直接與Redis對話
直接底層的與Redis對話,沒有封裝。默認配置只能一個數(shù)據(jù)庫,如下,可以直接通過獲取StringRedisConnection來切換當前操作的數(shù)據(jù)庫。
stringRedisTemplate.execute((RedisCallback<Boolean>)?connection?->?{StringRedisConnection?stringRedisConnection?=?(StringRedisConnection)?connection;stringRedisConnection.select(5);stringRedisConnection.set("name",?"zoe");return?true; });序列化器
從Spring Data Redis框架本身的角度看,存放到redis的數(shù)據(jù)只是字節(jié),雖然Redis本身支持各種類型,但大部分是指數(shù)據(jù)存儲的方式,而不是它所代表的內(nèi)容,由用戶決定是否將字節(jié)轉(zhuǎn)換為字符串或其他對象。
用戶自定義類型和原始數(shù)據(jù)之間的轉(zhuǎn)換由org.springframework.data.redis.serializer包中的序列化器進行處理。
這個包下面主要包含了兩種類型的序列化器:
-
基于RedisSerializer的雙向串行器。
-
元素的讀寫使用的RedisElementReader和RedisElementWriter。
它們的主要區(qū)別是,RedisSerializer序列化成byte[],而后者使用的是ByteBuffer。
序列化器實現(xiàn)類
這里有幾種開箱即用的實現(xiàn),其中有兩種在之前的文章已經(jīng)涉及過。
| StringRedisSerializer | String/byte[]轉(zhuǎn)換,速度快 |
| JdkSerializationRedisSerializer | JDK自帶序列化 |
| OxmSerializer | XML序列化,占空間,速度慢 |
| Jackson2JsonRedisSerializer | JSON序列化,需要定義JavaType |
| GenericJackson2JsonRedisSerializer | JSON序列化,無需定義JavaType |
所以,如果只是簡單的字符串類型,使用StringRedisSerializer就可以了,如果要有對象就使用Json的序列化吧,可以很方便的組裝成對象。
事務支持
Spring Data Redis提供了對Redis的事務支持,如:multi, exec, discard命令。
Spring Data Redis提供了SessionCallback接口,在同一個連接中需要執(zhí)行多個操作時使用,與使用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),如果沒有錯誤即成功,有錯誤就全部回滾。當前連接所有寫操作都會進入操作隊列,讀操作會轉(zhuǎn)移到一個新的連接。
示例配置
@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");總結(jié)
以上是生活随笔為你收集整理的一文搞定 Spring Data Redis 详解及实战的全部內(nèi)容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: 支付宝手机充值方法
- 下一篇: 给你一份超详细 Spring Boot