Spring?Cache+Redis緩存數(shù)據(jù)的實現(xiàn)示例
1、為什么使用緩存
我們知道內(nèi)存的讀取速度遠大于硬盤的讀取速度。當需要重復地獲取相同數(shù)據(jù)時,一次一次地請求數(shù)據(jù)庫或者遠程服務,導致在數(shù)據(jù)庫查詢或遠程方法調(diào)用上消耗大量的時間,最終導致程序性能降低,這就是數(shù)據(jù)緩存要解決的問題。
Spring Cache 是一個非常優(yōu)秀的緩存組件。自Spring 3.1起,提供了類似于@Transactional注解事務的注解Cache支持,且提供了Cache抽象,方便切換各種底層Cache(如:redis)
使用Spring Cache的好處
1,提供基本的Cache抽象,方便切換各種底層Cache;
2,通過注解Cache可以實現(xiàn)類似于事務一樣,緩存邏輯透明的應用到我們的業(yè)務代碼上,且只需要更少的代碼就可以完成;
3,提供事務回滾時也自動回滾緩存;
4,支持比較復雜的緩存邏輯;
一旦配置好Spring緩存支持,就可以在Spring容器里管理的Bean中使用緩存注解(基于AOP原理),一般情況下,都是在業(yè)務層(Service類)使用這些注解。
2、常用的緩存注解
2.1 @Cacheable
@Cacheable可以標記在一個方法上,也可以標記在一個類上。當標記在一個方法上時表示該方法是支持緩存的;當標記在一個類上時則表示該類所有的方法都是支持緩存的。對于一個支持緩存的方法,在方法執(zhí)行前,Spring先檢查緩存中是否存在該方法返回的數(shù)據(jù),如果存在,則直接返回緩存數(shù)據(jù);如果不存在,則調(diào)用方法并將方法返回值寫入緩存。
@Cacheable注解經(jīng)常使用value、key、condition等屬性
value:緩存的名稱,指定一個或多個緩存名稱。如
@Cacheable(value="mycache")或者@Cacheable(value={<!--{cke_protected}{C}%3C!%2D%2D%20%2D%2D%3E-->"cache1","cache2"})
該屬性與cacheNames屬性意義相同
key:緩存的key,可以為空。如果指定。需要按照SpEL編寫;如果不指定,則默認按照方法的所有參數(shù)進行組合。如
@Cacheable(value="testcache",key="#student.id")
condition:緩存的條件,可以為空,如果指定,需要按照SpEL編寫,返回true或者false,只有為true才進行緩存。如
@Cacheable(value="testcache",condition="#student.id>2")
該屬性與unless相反,條件成立時,不進行緩存
2.2 @CacheEvict
一般用在更新或者刪除方法上
@CacheEvict是用來標注在需要清除 緩存元素的方法或類上的。當標記在一個類上時,表示其中所有方法的執(zhí)行都會觸發(fā)緩存的清除操作。@CacheEvict可以指定的屬性有value、key、conditon、allEntries和beforeInvocation。其中,value、key和condition的語義與@Cacheable對應的屬性類似。
allEntries:是否清空所有緩存內(nèi)容,默認為false,如果指定為true,則方法調(diào)用后將立即清空所有緩存。如
@CacheEvict(value="testcache",allEntries=true)
beforeInvocation:是否在方法執(zhí)行前就清空,默認為false,如果指定為true,則在方法還沒有執(zhí)行時就清空緩存。默認情況下,如果方法執(zhí)行拋出異常,則不會清空緩存。
2.3、@Cacheput
使用該注解標志的方法,每次都會執(zhí)行,并將結(jié)果存入指定的緩存中。其他方法可以直接從響應的緩存中讀取緩存數(shù)據(jù),而不需要再去查詢數(shù)據(jù)庫。一般用在新增方法上。
2.4、@Caching
該注解可以在一個方法或類上同時指定多個Spring Cache相關(guān)的注解。其擁有三個屬性:cacheable、put和evict,分別用于指定@Cacheable、@CachePut和@CacheEvict。示例代碼如下:
@Caching( cacheable=@Cacheable("cache1"), evict={@CacheEvict("cache2"),@CacheEvict(value="cache3",allEntries=true)} )
2.5、@CacheConfig
所有的Cache注解都需要提供Cache名稱,如果每個Service方法上都包含相同的Cache名稱,可能寫起來重復。此時可以使用@CacheConfig注解作用在類上,設(shè)置當前緩存的一些公共配置。
3、SpringBoot緩存支持
在SpringBoot應用中,使用緩存技術(shù)只需在應用中引入相關(guān)緩存技術(shù)的依賴,并在配置類中使用@EnableCaching注解開啟緩存支持即可。
4、項目繼承Spring Cache+Redis
4.1 添加依賴
<!-- redis --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> </dependency> <!-- spring2.X集成redis所需common-pool2--> <dependency> <groupId>org.apache.commons</groupId> <artifactId>commons-pool2</artifactId> <version>2.6.0</version> </dependency>
4.2 配置類
/** * Redis+Cache配置類 */ @Configuration @EnableCaching public class RedisConfig { /** * 自定義key規(guī)則 * @return */ @Bean 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(); } }; } /** * 設(shè)置RedisTemplate規(guī)則 * @param redisConnectionFactory * @return */ @Bean public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) { RedisTemplate<Object, Object> redisTemplate = new RedisTemplate<>(); redisTemplate.setConnectionFactory(redisConnectionFactory); Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class); //解決查詢緩存轉(zhuǎn)換異常的問題 ObjectMapper om = new ObjectMapper(); // 指定要序列化的域,field,get和set,以及修飾符范圍,ANY是都有包括private和public om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY); // 指定序列化輸入的類型,類必須是非final修飾的,final修飾的類,比如String,Integer等會跑出異常 om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL); jackson2JsonRedisSerializer.setObjectMapper(om); //序列號key value redisTemplate.setKeySerializer(new StringRedisSerializer()); redisTemplate.setValueSerializer(jackson2JsonRedisSerializer); redisTemplate.setHashKeySerializer(new StringRedisSerializer()); redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer); redisTemplate.afterPropertiesSet(); return redisTemplate; } /** * 設(shè)置CacheManager緩存規(guī)則 * @param factory * @return */ @Bean public CacheManager cacheManager(RedisConnectionFactory factory) { RedisSerializer<String> redisSerializer = new StringRedisSerializer(); Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class); //解決查詢緩存轉(zhuǎn)換異常的問題 ObjectMapper om = new ObjectMapper(); om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY); om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL); jackson2JsonRedisSerializer.setObjectMapper(om); // 配置序列化(解決亂碼的問題),過期時間600秒 RedisCacheConfiguration config = RedisCacheConfiguration.defaultCacheConfig() .entryTtl(Duration.ofSeconds(600)) .serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(redisSerializer)) .serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(jackson2JsonRedisSerializer)) .disableCachingNullValues(); RedisCacheManager cacheManager = RedisCacheManager.builder(factory) .cacheDefaults(config) .build(); return cacheManager; } }
4.3 添加redis配置
# redis配置 spring.redis.host=192.168.159.33 spring.redis.port=6379 spring.redis.database= 0 spring.redis.timeout=1800000 spring.redis.lettuce.pool.max-active=20 spring.redis.lettuce.pool.max-wait=-1 #最大阻塞等待時間(負數(shù)表示沒限制) spring.redis.lettuce.pool.max-idle=5 spring.redis.lettuce.pool.min-idle=0
4.4 接口中使用緩存注解
Service實現(xiàn)類中添加相應的注解
@Service public class DictServiceImpl extends ServiceImpl<DictMapper, Dict> implements DictService { //根據(jù)上級id查詢子數(shù)據(jù)列表 @Override @Cacheable(value = "dict",keyGenerator = "keyGenerator") public List<Dict> findChildData(Long id) { QueryWrapper<Dict> wrapper=new QueryWrapper<>(); wrapper.eq("parent_id",id); List<Dict> list = baseMapper.selectList(wrapper); //向list集合中的每個dict對象中設(shè)置hasChildren list.forEach(x->{ Long dictId = x.getId(); boolean isChild = this.isChildren(dictId); x.setHasChildren(isChild); }); return list; } //導出數(shù)據(jù)字典接口 @Override public void exportDictData(HttpServletResponse response) { //設(shè)置下載信息 response.setContentType("application/vnd.ms-excel"); response.setCharacterEncoding("utf-8"); // 這里URLEncoder.encode可以防止中文亂碼 當然和easyexcel沒有關(guān)系 String fileName = "dict"; response.setHeader("Content-disposition", "attachment;filename="+ fileName + ".xlsx"); //查詢數(shù)據(jù)庫 List<Dict> dictList = baseMapper.selectList(null); //Dict-->DictEeVo List<DictEeVo> dictEeVoList=new ArrayList<>(); dictList.forEach(x->{ DictEeVo dictEeVo=new DictEeVo(); BeanUtils.copyProperties(x,dictEeVo); dictEeVoList.add(dictEeVo); }); try { //調(diào)用方法實現(xiàn)寫操作 EasyExcel.write(response.getOutputStream(), DictEeVo.class) .sheet("dict") .doWrite(dictEeVoList); } catch (IOException e) { e.printStackTrace(); } } //導入數(shù)據(jù)字典 @Override @CacheEvict(value = "dict", allEntries=true) public void importDictData(MultipartFile file) { try { //excel數(shù)據(jù)取出來并添加到數(shù)據(jù)庫中 EasyExcel.read(file.getInputStream(),DictEeVo.class,new DictListener(baseMapper)) .sheet() .doRead(); } catch (IOException e) { e.printStackTrace(); } } //判斷id下面是否有子數(shù)據(jù) private boolean isChildren(Long id){ QueryWrapper<Dict> wrapper=new QueryWrapper<>(); wrapper.eq("parent_id",id); Integer count = baseMapper.selectCount(wrapper); return count > 0; } }
4.5 緩存效果測試
我們現(xiàn)在調(diào)用根據(jù)上級id查詢子數(shù)據(jù)列表這個方法的controller
第一次訪問接口
查看控制臺:
查看redis中是否有緩存的數(shù)據(jù)
用連接工具查看下redis中的數(shù)據(jù),方便數(shù)據(jù)的可視化
從上面的數(shù)據(jù)不難發(fā)現(xiàn),數(shù)據(jù)已經(jīng)被緩存到了redis中
清空SpringBoot的控制臺,再次發(fā)起相同的請求,看是否會再次請求數(shù)據(jù)庫
第二次請求的控制臺輸出如下:
頁面中的數(shù)據(jù)也正常獲取到了,如下:
從上面的效果可以很明顯的看到,我們第一次請求后端接口的時候,由于緩存中并沒有需要的數(shù)據(jù),所以會被緩存到redis中,第二次請求相同接口的時候,Spring先檢查緩存中是否存在該方法返回的數(shù)據(jù),如果存在,則直接返回緩存數(shù)據(jù),減小對數(shù)據(jù)庫查詢的壓力。上面的緩存一定要設(shè)置下TTL,這樣長期不用的數(shù)據(jù)就會自動失效
到此這篇關(guān)于Spring Cache+Redis緩存數(shù)據(jù)的實現(xiàn)示例的文章就介紹到這了,更多相關(guān)Spring Cache Redis緩存 內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
使用RestTemplate調(diào)用https接口跳過證書驗證
這篇文章主要介紹了使用RestTemplate調(diào)用https接口跳過證書驗證,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教2021-10-10Java Spring WEB應用實例化如何實現(xiàn)
這篇文章主要介紹了Java Spring WEB應用實例化如何實現(xiàn),文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2020-12-12Java實現(xiàn)自定義ArrayList類的示例代碼
這篇文章主要為大家簡單的介紹ArrayList一下里面的add方法、size方法、isEmpty方法,以及如何實現(xiàn)自定義ArrayList類,感興趣的可以了解一下2022-08-08