springboot整合redis的步驟與技巧
-
添加依賴(lài)
<!--默認(rèn)是lettuce客戶(hù)端--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> </dependency> <!-- redis依賴(lài)commons-pool 這個(gè)依賴(lài)一定要添加 --> <dependency> <groupId>org.apache.commons</groupId> <artifactId>commons-pool2</artifactId> </dependency> <!-- 這是Apache的工具類(lèi),主要用他的(對(duì)象轉(zhuǎn)map)與map轉(zhuǎn)對(duì)象的方法 --> <dependency> <groupId>commons-beanutils</groupId> <artifactId>commons-beanutils</artifactId> <version>1.9.4</version> </dependency> -
配置類(lèi)
//有過(guò)時(shí)方法,可以重新找最新的 import com.fasterxml.jackson.annotation.JsonAutoDetect; import com.fasterxml.jackson.annotation.PropertyAccessor; import com.fasterxml.jackson.databind.ObjectMapper; import org.springframework.cache.CacheManager; import org.springframework.cache.annotation.CachingConfigurerSupport; import org.springframework.cache.interceptor.KeyGenerator; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.data.redis.cache.RedisCacheConfiguration; import org.springframework.data.redis.cache.RedisCacheManager; import org.springframework.data.redis.cache.RedisCacheWriter; import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer; import org.springframework.data.redis.serializer.StringRedisSerializer; import java.lang.reflect.Method; /** * @ClassName RedisConfig * @Description TODO * @Author shj * @Version 1.0 */ @Configuration public class RedisConfig extends CachingConfigurerSupport { /** * 自定義緩存key的生成策略。默認(rèn)的生成策略是看不懂的(亂碼內(nèi)容) 通過(guò)Spring 的依賴(lài)注入特性進(jìn)行自定義的配置注入并且此類(lèi)是一個(gè)配置類(lèi)可以更多程度的自定義配置 * * @return */ @Bean @Override public KeyGenerator keyGenerator() { return new KeyGenerator() { @Override public Object generate(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(LettuceConnectionFactory factory) { //以鎖寫(xiě)入的方式創(chuàng)建RedisCacheWriter對(duì)象 RedisCacheWriter writer = RedisCacheWriter.lockingRedisCacheWriter(factory); //創(chuàng)建默認(rèn)緩存配置對(duì)象 RedisCacheConfiguration config = RedisCacheConfiguration.defaultCacheConfig(); RedisCacheManager cacheManager = new RedisCacheManager(writer, config); return cacheManager; } @Bean public RedisTemplate<String,Object> redisTemplate(LettuceConnectionFactory factory){ RedisTemplate<String,Object> template = new RedisTemplate <>(); template.setConnectionFactory(factory); Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class); ObjectMapper om = new ObjectMapper(); om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY); om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL); jackson2JsonRedisSerializer.setObjectMapper(om); StringRedisSerializer stringRedisSerializer = new StringRedisSerializer(); // 在使用注解@Bean返回RedisTemplate的時(shí)候，同時(shí)配置hashKey與hashValue的序列化方式。 // key采用String的序列化方式 template.setKeySerializer(stringRedisSerializer); // value序列化方式采用jackson template.setValueSerializer(jackson2JsonRedisSerializer); // hash的key也采用String的序列化方式 template.setHashKeySerializer(stringRedisSerializer); // hash的value序列化方式采用jackson template.setHashValueSerializer(jackson2JsonRedisSerializer); template.afterPropertiesSet(); return template; } } -
使用與技巧
-
利用spring的自動(dòng)注入,注入ValueOperations,相當(dāng)于redisTemplate.opsForValue()并且自動(dòng)轉(zhuǎn)換類(lèi)型,但是如果類(lèi)型對(duì)應(yīng)不上會(huì)報(bào)錯(cuò)
//redis的封裝的模板方法 @Autowired private RedisTemplate<String, Object> redisTemplate; //注入redisTemplate,類(lèi)型可以更改,k-v與redis對(duì)應(yīng).此時(shí)這里的String可以實(shí)現(xiàn)redis常用方法 @Resource(name = "redisTemplate") private ValueOperations<String, String> string; @Resource(name = "redisTemplate") private ValueOperations<String, Integer> integer; @Resource(name = "redisTemplate") private ValueOperations<String, Verification> obj; -
ValueOperations(與redisTemplate.opsForValue的類(lèi)似)的方法
-
increment(K key, double delta) 以增量的方式將double值存儲(chǔ)在變量中。
-
setIfAbsent(K key, V value) 如果鍵不存在則新增,存在則不改變已經(jīng)有的值。
-
set(K key, V value, long timeout, TimeUnit unit) 設(shè)置變量值的過(guò)期時(shí)間。
-
set(K key, V value, long offset) 覆蓋從指定位置開(kāi)始的值。
-
multiSet(Map<? extends K,? extends V> map) 設(shè)置map集合到redis。
-
multiGet(Collection<K> keys) 根據(jù)集合取出對(duì)應(yīng)的value值。
-
multiSetIfAbsent(Map<? extends K,? extends V> map) 如果對(duì)應(yīng)的map集合名稱(chēng)不存在，則添加；如果存在則不做修改。
-
append(K key, String value) 在原有的值基礎(chǔ)上新增字符串到末尾。
-
-
注入HashOperations
優(yōu)點(diǎn):存入的為對(duì)象,取值時(shí)可以根據(jù) 對(duì)象名+變量名 直接從redis中取出
注意:如果通過(guò)Beanutils將對(duì)象變?yōu)閙ap時(shí)會(huì)附加一個(gè)class的變量
@Autowired private RedisTemplate<String, Object> redisTemplate; //直接注入 與redisTemplate.opsForHash類(lèi)似 @Resource(name = "redisTemplate") private HashOperations<String, String,String> hash;/** * 通過(guò)Beanutils的BeanMap方法直接轉(zhuǎn)換 */ public Boolean set() { Verification verification = new Verification(); verification.setNum(true); verification.setRandom("shj"); Map beanMap = new BeanMap(verification); hash.putAll("person2",beanMap); return true; }public String getString() { //直接拿到對(duì)象中的屬性 String s = hash.get("person2", "class"); //獲取整個(gè)對(duì)象 Map<String, String> person2 = hash.entries("person2"); Verification verification = new Verification(); try { //使用Apache的方法進(jìn)行 map轉(zhuǎn)對(duì)象 org.apache.commons.beanutils.BeanUtils.populate(verification, person2); } catch (IllegalAccessException e) { e.printStackTrace(); } catch (InvocationTargetException e) { e.printStackTrace(); } System.out.println(verification); return s; }
-
通過(guò)注入的方式還能注入其他許多的XXXOperations 的類(lèi)
private ListOperations private SetOperations private ZSetOperations ....
-
