Caffeine是使用Java8對(duì)Guava緩存的重寫版本性能有很大提升

一 依賴

<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-cache</artifactId> </dependency> <!-- caffeine --> <dependency> <groupId>com.github.ben-manes.caffeine</groupId> <artifactId>caffeine</artifactId> <version>2.7.0</version> </dependency>

二 配置緩存,單獨(dú)使用

只需要配置Bean就可以了,然后進(jìn)行數(shù)據(jù)讀寫,注意這里提供了很多強(qiáng)大的自定義配置,可以查看文檔詳細(xì)配置

//定義緩存,可直接使用 @Bean public LoadingCache expiryCache(){ LoadingCache<String, Object> loadingCache = Caffeine.newBuilder().initialCapacity(100).maximumSize(1000)//緩存寫入/刪除監(jiān)控.writer(new CacheWriter<Object, Object>() { @Override public void write(Object key, Object value) { //此方法是同步阻塞的 System.out.println('--緩存寫入--:key=' + key + ', value=' + value); } @Override public void delete(Object key, Object value, RemovalCause cause) { System.out.println('--緩存刪除--:key=' + key); }}).expireAfterAccess(1, TimeUnit.MINUTES) //過期時(shí)間.build((String key)->'刷新的數(shù)據(jù)'); //cacheload實(shí)現(xiàn)類,刷新時(shí)候調(diào)用 loadingCache.put('name','侯征'); return loadingCache; }

測(cè)試使用:

@Autowired private LoadingCache loadingCache; @GetMapping('/get') public Object getValue(String key){ return loadingCache.get(key); } @GetMapping('/add') public void addValue(String value){ loadingCache.put(value,value); } @GetMapping('/delete') public void deleteValue(String key){ loadingCache.invalidate(key); loadingCache.invalidateAll();//清楚所有 } @GetMapping('/refresh') public void refreshValue(String key){ //刷新時(shí)會(huì)根據(jù)build方法中中指定的cacheload重新加載 loadingCache.refresh(key); }

三 配置CacheManager,和spring緩存注解一起使用

//配置CacheManager @Bean(name = 'caffeine') public CacheManager cacheManagerWithCaffeine() { CaffeineCacheManager cacheManager = new CaffeineCacheManager(); Caffeine caffeine = Caffeine.newBuilder()//cache的初始容量值.initialCapacity(100)//maximumSize用來控制cache的最大緩存數(shù)量，maximumSize和maximumWeight(最大權(quán)重)不可以同時(shí)使用，.maximumSize(1000)//最后一次寫入或者訪問后過久過期.expireAfterAccess(500, TimeUnit.SECONDS)//創(chuàng)建或更新之后多久刷新,需要設(shè)置cacheLoader.refreshAfterWrite(10, TimeUnit.SECONDS); cacheManager.setCaffeine(caffeine); cacheManager.setCacheLoader(cacheLoader); cacheManager.setCacheNames(names);//根據(jù)名字可以創(chuàng)建多個(gè)cache，但是多個(gè)cache使用相同的策略 cacheManager.setAllowNullValues(false);//是否允許值為空 return cacheManager; }

配置 cacheload

/** * 必須要指定這個(gè)Bean，refreshAfterWrite配置屬性才生效 */ @Bean public CacheLoader<Object, Object> cacheLoader() { return new CacheLoader<Object, Object>() { @Override public Object load(Object key) throws Exception { return null;} // 重寫這個(gè)方法將oldValue值返回回去，進(jìn)而刷新緩存 @Override public Object reload(Object key, Object oldValue) throws Exception {System.out.println('--refresh--:'+key);return oldValue; } }; }

其他就是在service中配置spring的幾個(gè)緩存注解使用就行了,這里放一張截圖,這些注解用法,網(wǎng)上很多:[/code]

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持好吧啦網(wǎng)。