文章目錄

• • • • • 一、本地緩存介紹
        • 二、緩存組件 Caffeine 介紹
        • • 2.1. Caffeine 性能
          • 2.2. Caffeine 配置說(shuō)明
          • 2.3. 軟引用與弱引用
        • 三、SpringBoot 集成 Caffeine 方式一
        • • 3.1. Maven 引入相關(guān)依賴
          • 3.2. 配置緩存配置類
          • 3.3. 定義實(shí)體對(duì)象
          • 3.4. 定義服務(wù)接口類
          • 3.5. 定義服務(wù)接口實(shí)現(xiàn)類
          • 3.6. Caffeine工具類
          • 3.7. 測(cè)試案例
        • 四、測(cè)試案例
        • • 4.1. 添加用戶
          • 4.2. 查詢用戶
          • 4.3. 更新用戶
          • 4.4. 刪除用戶
          • 4.5. 效果圖
        • 五、第二種整合方式
        • • 5.1. 依賴
          • 5.2. 接口實(shí)現(xiàn)類（替換）

一、本地緩存介紹

緩存在日常開(kāi)發(fā)中啟動(dòng)至關(guān)重要的作用，由于是存儲(chǔ)在內(nèi)存中，數(shù)據(jù)的讀取速度是非常快的，能大量減少對(duì)數(shù)據(jù)庫(kù)的訪問(wèn)，減少數(shù)據(jù)庫(kù)的壓力。

之前介紹過(guò) Redis 這種 NoSql 作為緩存組件，它能夠很好的作為分布式緩存組件提供多個(gè)服務(wù)間的緩存，但是 Redis 這種還是需要網(wǎng)絡(luò)開(kāi)銷，增加時(shí)耗。本地緩存是直接從本地內(nèi)存中讀取，沒(méi)有網(wǎng)絡(luò)開(kāi)銷，例如秒殺系統(tǒng)或者數(shù)據(jù)量小的緩存等，比遠(yuǎn)程緩存更合適。

二、緩存組件 Caffeine 介紹

按 Caffeine Github 文檔描述，Caffeine 是基于 JAVA 8 的高性能緩存庫(kù)。并且在 spring5 (springboot 2.x) 后，spring 官方放棄了 Guava，而使用了性能更優(yōu)秀的 Caffeine 作為默認(rèn)緩存組件。

2.1. Caffeine 性能

可以通過(guò)下圖觀測(cè)到，在下面緩存組件中 Caffeine 性能是其中最好的。

2.2. Caffeine 配置說(shuō)明

注意：

weakValues 和 softValues 不可以同時(shí)使用。
maximumSize 和 maximumWeight 不可以同時(shí)使用。
expireAfterWrite 和 expireAfterAccess 同事存在時(shí)，以 expireAfterWrite 為準(zhǔn)。

2.3. 軟引用與弱引用

軟引用：如果一個(gè)對(duì)象只具有軟引用，則內(nèi)存空間足夠，垃圾回收器就不會(huì)回收它；如果內(nèi)存空間不足了，就會(huì)回收這些對(duì)象的內(nèi)存。

弱引用：弱引用的對(duì)象擁有更短暫的生命周期。在垃圾回收器線程掃描它所管轄的內(nèi)存區(qū)域的過(guò)程中，一旦發(fā)現(xiàn)了只具有弱引用的對(duì)象，不管當(dāng)前內(nèi)存空間足夠與否，都會(huì)回收它的內(nèi)存.

// 軟引用 Caffeine.newBuilder().softValues().build();// 弱引用 Caffeine.newBuilder().weakKeys().weakValues().build();

三、SpringBoot 集成 Caffeine 方式一

3.1. Maven 引入相關(guān)依賴

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!--字符串工具類--><dependency><groupId>org.apache.commons</groupId><artifactId>commons-lang3</artifactId><version>3.12.0</version></dependency><dependency><groupId>com.github.ben-manes.caffeine</groupId><artifactId>caffeine</artifactId></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId></dependency>

3.2. 配置緩存配置類

package com.gblfy.config;import com.github.benmanes.caffeine.cache.Cache; import com.github.benmanes.caffeine.cache.Caffeine; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration;import java.util.concurrent.TimeUnit;/*** 本地caffeine緩存配置** @author gblfy* @date 2022-03-15*/ @Configuration public class CaffeineCacheConfig {@Beanpublic Cache<String, Object> caffeineCache() {return Caffeine.newBuilder()// 設(shè)置最后一次寫(xiě)入或訪問(wèn)后經(jīng)過(guò)固定時(shí)間過(guò)期.expireAfterWrite(6000, TimeUnit.SECONDS)// 初始的緩存空間大小.initialCapacity(100)// 緩存的最大條數(shù).maximumSize(1000).build();} }

3.3. 定義實(shí)體對(duì)象

package com.gblfy;import lombok.Data; import lombok.ToString;@Data @ToString public class UserInfo {private Integer id;private String name;private String sex;private Integer age; }

3.4. 定義服務(wù)接口類

package com.gblfy.service;import com.gblfy.entity.UserInfo;/*** 用戶模塊接口** @author gblfy* @date 2022-03-15*/ public interface UserInfoService {/*** 增加用戶信息** @param userInfo 用戶信息*/void addUserInfo(UserInfo userInfo);/*** 獲取用戶信息** @param id 用戶ID* @return 用戶信息*/UserInfo getByName(Integer id);/*** 修改用戶信息** @param userInfo 用戶信息* @return 用戶信息*/UserInfo updateUserInfo(UserInfo userInfo);/*** 刪除用戶信息** @param id 用戶ID*/void deleteById(Integer id);}

3.5. 定義服務(wù)接口實(shí)現(xiàn)類

package com.gblfy.service.impl;import com.gblfy.entity.UserInfo; import com.gblfy.service.UserInfoService; import com.gblfy.uitls.CaffeineUtils; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service;import java.util.Map; import java.util.concurrent.ConcurrentHashMap;/*** 用戶模塊接口實(shí)現(xiàn)類** @author gblfy* @date 2022-03-15*/ @Slf4j @Service public class UserInfoServiceImpl implements UserInfoService {/*** 模擬數(shù)據(jù)庫(kù)存儲(chǔ)數(shù)據(jù)*/private Map<Integer, UserInfo> userInfoMap = new ConcurrentHashMap<>();@Autowiredprivate CaffeineUtils caffeineUtils;@Overridepublic void addUserInfo(UserInfo userInfo) {log.info("create");userInfoMap.put(userInfo.getId(), userInfo);// 加入緩存caffeineUtils.putAndUpdateCache(String.valueOf(userInfo.getId()), userInfo);}@Overridepublic UserInfo getByName(Integer userId) {// 先從緩存讀取UserInfo userInfo = caffeineUtils.getObjCacheByKey(String.valueOf(userId), UserInfo.class);if (userInfo != null) {return userInfo;}// 如果緩存中不存在，則從庫(kù)中查找log.info("get");userInfo = userInfoMap.get(userId);// 如果用戶信息不為空，則加入緩存if (userInfo != null) {caffeineUtils.putAndUpdateCache(String.valueOf(userInfo.getId()), userInfo);}return userInfo;}@Overridepublic UserInfo updateUserInfo(UserInfo userInfo) {log.info("update");if (!userInfoMap.containsKey(userInfo.getId())) {return null;}// 取舊的值UserInfo oldUserInfo = userInfoMap.get(userInfo.getId());// 替換內(nèi)容if (StringUtils.isNotBlank(oldUserInfo.getName())) {oldUserInfo.setName(userInfo.getName());}if (StringUtils.isNotBlank(oldUserInfo.getSex())) {oldUserInfo.setSex(userInfo.getSex());}oldUserInfo.setAge(userInfo.getAge());// 將新的對(duì)象存儲(chǔ)，更新舊對(duì)象信息userInfoMap.put(oldUserInfo.getId(), oldUserInfo);// 替換緩存中的值caffeineUtils.putAndUpdateCache(String.valueOf(oldUserInfo.getId()), oldUserInfo);return oldUserInfo;}@Overridepublic void deleteById(Integer id) {log.info("delete");userInfoMap.remove(id);// 從緩存中刪除caffeineUtils.removeCacheByKey(String.valueOf(id));}}

3.6. Caffeine工具類

package com.gblfy.uitls;import com.github.benmanes.caffeine.cache.Cache; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component;/*** Caffeine緩存工具類** @Author gblfy* @Date 2022-03-15 14:58**/ @Component public class CaffeineUtils {@AutowiredCache<String, Object> caffeineCache;/*** 添加或更新緩存** @param key* @param value*/public void putAndUpdateCache(String key, Object value) {caffeineCache.put(key, value);}/*** 獲取對(duì)象緩存** @param key* @return*/public <T> T getObjCacheByKey(String key, Class<T> t) {caffeineCache.getIfPresent(key);return (T) caffeineCache.asMap().get(key);}/*** 根據(jù)key刪除緩存** @param key*/public void removeCacheByKey(String key) {// 從緩存中刪除caffeineCache.asMap().remove(key);} }

3.7. 測(cè)試案例

package com.gblfy;import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*;/*** 用戶模塊入口** @author gblfy* @date 2022-03-15*/ @RestController @RequestMapping public class UserInfoController {@Autowiredprivate UserInfoService userInfoService;@GetMapping("/userInfo/{id}")public Object getUserInfo(@PathVariable Integer id) {UserInfo userInfo = userInfoService.getByName(id);if (userInfo == null) {return "沒(méi)有該用戶";}return userInfo;}@PostMapping("/userInfo")public Object createUserInfo(@RequestBody UserInfo userInfo) {userInfoService.addUserInfo(userInfo);return "SUCCESS";}@PutMapping("/userInfo")public Object updateUserInfo(@RequestBody UserInfo userInfo) {UserInfo newUserInfo = userInfoService.updateUserInfo(userInfo);if (newUserInfo == null) {return "不存在該用戶";}return newUserInfo;}@DeleteMapping("/userInfo/{id}")public Object deleteUserInfo(@PathVariable Integer id) {userInfoService.deleteById(id);return "SUCCESS";}}

四、測(cè)試案例

4.1. 添加用戶

請(qǐng)求方式：POST content-type：application/json 測(cè)試地址:localhost:8080/userInfo

報(bào)文內(nèi)容

{'id':1,'name':"yx",'sex':"女",'age':2 }

4.2. 查詢用戶

請(qǐng)求方式：GET 測(cè)試地址:localhost:8080/userInfo/1

4.3. 更新用戶

請(qǐng)求方式：PUT content-type：application/json 測(cè)試地址:localhost:8080/userInfo

報(bào)文內(nèi)容

{'id':1,'name':"gblfy",'sex':"男",'age':22 }

4.4. 刪除用戶

請(qǐng)求方式：DELETE 測(cè)試地址:localhost:8080/userInfo/1

4.5. 效果圖

五、第二種整合方式

5.1. 依賴

上面基礎(chǔ)上添加

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-cache</artifactId></dependency>

5.2. 接口實(shí)現(xiàn)類（替換）

package com.gblfy;import lombok.extern.slf4j.Slf4j; import org.springframework.cache.annotation.CacheConfig; import org.springframework.cache.annotation.CacheEvict; import org.springframework.cache.annotation.CachePut; import org.springframework.cache.annotation.Cacheable; import org.springframework.stereotype.Service; import org.springframework.util.StringUtils;import java.util.HashMap;/*** 用戶模塊接口實(shí)現(xiàn)類** @author gblfy* @date 2022-03-15*/ @Slf4j @Service @CacheConfig(cacheNames = "caffeineCacheManager") public class UserInfoServiceImpl implements UserInfoService {/*** 模擬數(shù)據(jù)庫(kù)存儲(chǔ)數(shù)據(jù)*/private HashMap<Integer, UserInfo> userInfoMap = new HashMap<>();@Override@CachePut(key = "#userInfo.id")public void addUserInfo(UserInfo userInfo) {log.info("create");userInfoMap.put(userInfo.getId(), userInfo);}@Override@Cacheable(key = "#id")public UserInfo getByName(Integer id) {log.info("get");return userInfoMap.get(id);}@Override@CachePut(key = "#userInfo.id")public UserInfo updateUserInfo(UserInfo userInfo) {log.info("update");if (!userInfoMap.containsKey(userInfo.getId())) {return null;}// 取舊的值UserInfo oldUserInfo = userInfoMap.get(userInfo.getId());// 替換內(nèi)容if (!StringUtils.isEmpty(oldUserInfo.getAge())) {oldUserInfo.setAge(userInfo.getAge());}if (!StringUtils.isEmpty(oldUserInfo.getName())) {oldUserInfo.setName(userInfo.getName());}if (!StringUtils.isEmpty(oldUserInfo.getSex())) {oldUserInfo.setSex(userInfo.getSex());}// 將新的對(duì)象存儲(chǔ)，更新舊對(duì)象信息userInfoMap.put(oldUserInfo.getId(), oldUserInfo);// 返回新對(duì)象信息return oldUserInfo;}@Override@CacheEvict(key = "#id")public void deleteById(Integer id) {log.info("delete");userInfoMap.remove(id);}}

總結(jié)

以上是生活随笔為你收集整理的SpringBoot 使用 Caffeine 本地缓存的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。