大家好我是專注于后端技術(shù)分享的博主。在構(gòu)建高并發(fā)系統(tǒng)時(shí)緩存是提升性能、保護(hù)數(shù)據(jù)庫的利器。然而如果使用不當(dāng)緩存也可能成為系統(tǒng)穩(wěn)定性的“阿喀琉斯之踵”。緩存穿透、擊穿和雪崩是三個(gè)高頻出現(xiàn)且極易混淆的故障場景很多開發(fā)者知道概念但在實(shí)際項(xiàng)目中遇到問題時(shí)卻難以快速定位和區(qū)分。本文將徹底厘清這三者的核心區(qū)別并提供從原理到實(shí)戰(zhàn)的完整解決方案涵蓋概念辨析、復(fù)現(xiàn)示例、主流框架如Spring Boot Redis下的防御策略以及生產(chǎn)環(huán)境的最佳實(shí)踐。無論你是正在面試準(zhǔn)備還是在實(shí)際開發(fā)中遇到了性能瓶頸這篇文章都能為你提供清晰的思路和可直接落地的代碼。1. 核心概念辨析穿透、擊穿與雪崩的本質(zhì)區(qū)別在深入技術(shù)細(xì)節(jié)之前我們必須先建立一個(gè)清晰的認(rèn)知框架。緩存穿透、擊穿和雪崩雖然都表現(xiàn)為“緩存失效請求打到數(shù)據(jù)庫”但其觸發(fā)原因、影響范圍和解決方案有本質(zhì)不同。我們可以用一個(gè)簡單的比喻來理解緩存穿透像是有人拿著一個(gè)根本不存在的鑰匙請求一個(gè)數(shù)據(jù)庫中也不存在的數(shù)據(jù)反復(fù)嘗試打開你家的防盜門緩存每次都失敗然后去砸你家的承重墻數(shù)據(jù)庫。問題在于“鑰匙本身是假的”。緩存擊穿像是你家防盜門上最常用的一把鎖某個(gè)熱點(diǎn)Key突然壞了緩存過期此時(shí)所有回家的人并發(fā)請求都被堵在門口然后一窩蜂地去砸承重墻數(shù)據(jù)庫。問題在于“一把關(guān)鍵的鎖在高峰期壞了”。緩存雪崩像是整棟樓的防盜門鎖芯因?yàn)槭褂昧送慌蔚牧淤|(zhì)產(chǎn)品在同一個(gè)時(shí)間點(diǎn)緩存Key大面積同時(shí)過期集體失靈。所有居民同時(shí)被鎖在門外導(dǎo)致通往承重墻的樓梯被徹底擠垮數(shù)據(jù)庫連接池耗盡。問題在于“大量鎖在同一時(shí)間失效”。下面我們從技術(shù)定義上詳細(xì)拆解1.1 緩存穿透 (Cache Penetration)定義查詢一個(gè)數(shù)據(jù)庫中根本不存在的數(shù)據(jù)。由于緩存不具備該數(shù)據(jù)請求會(huì)穿透緩存直接查詢數(shù)據(jù)庫。當(dāng)有大量此類惡意或異常的請求時(shí)數(shù)據(jù)庫將承受巨大壓力。核心特征數(shù)據(jù)不存在性請求的Key在數(shù)據(jù)庫中沒有對應(yīng)記錄。持續(xù)性攻擊可能是惡意攻擊如爬蟲掃描不存在的ID也可能是業(yè)務(wù)邏輯缺陷導(dǎo)致。對單個(gè)Key或隨機(jī)Key攻擊者可能針對某個(gè)不存在的Key也可能構(gòu)造大量隨機(jī)Key進(jìn)行攻擊。影響大量無效查詢直接落在數(shù)據(jù)庫上可能導(dǎo)致數(shù)據(jù)庫連接池被占滿CPU和IO資源耗盡進(jìn)而拖垮整個(gè)服務(wù)。1.2 緩存擊穿 (Cache Breakdown)定義某個(gè)熱點(diǎn)Key訪問量巨大的數(shù)據(jù)在緩存中過期失效的瞬間持續(xù)的高并發(fā)請求同時(shí)發(fā)現(xiàn)緩存失效從而全部涌向數(shù)據(jù)庫導(dǎo)致數(shù)據(jù)庫瞬時(shí)壓力激增。核心特征熱點(diǎn)Key該Key對應(yīng)的是數(shù)據(jù)庫中真實(shí)存在且訪問頻率極高的數(shù)據(jù)。并發(fā)性在緩存失效的瞬間有大量并發(fā)請求同時(shí)到達(dá)。瞬時(shí)性壓力是瞬時(shí)的一旦緩存被重建壓力即消失。影響數(shù)據(jù)庫在極短時(shí)間內(nèi)承受遠(yuǎn)超平時(shí)的峰值流量可能導(dǎo)致連接超時(shí)、慢查詢甚至瞬間宕機(jī)。1.3 緩存雪崩 (Cache Avalanche)定義在某一時(shí)刻緩存中大量的Key同時(shí)過期失效或者緩存服務(wù)如Redis集群整體宕機(jī)。導(dǎo)致所有原本應(yīng)該命中緩存的請求全部轉(zhuǎn)向數(shù)據(jù)庫造成數(shù)據(jù)庫壓力山崩海嘯般襲來。核心特征大規(guī)模失效不是單個(gè)Key而是成百上千甚至更多的Key同時(shí)失效。原因多樣可能是緩存服務(wù)器宕機(jī)也可能是人為設(shè)置緩存時(shí)為大量Key設(shè)置了相同或非常接近的過期時(shí)間TTL。系統(tǒng)性風(fēng)險(xiǎn)影響的是整個(gè)系統(tǒng)或大部分功能而非單個(gè)熱點(diǎn)。影響數(shù)據(jù)庫連接池在短時(shí)間內(nèi)被耗盡系統(tǒng)吞吐量驟降響應(yīng)時(shí)間飆升嚴(yán)重時(shí)會(huì)導(dǎo)致整個(gè)服務(wù)不可用且恢復(fù)時(shí)間較長。三者的核心區(qū)別總結(jié)表特征維度緩存穿透緩存擊穿緩存雪崩失效范圍單個(gè)/隨機(jī)不存在的Key單個(gè)熱點(diǎn)Key大量Key同時(shí)失效或緩存服務(wù)宕機(jī)數(shù)據(jù)狀態(tài)數(shù)據(jù)庫中不存在數(shù)據(jù)庫中存在數(shù)據(jù)庫中存在但緩存失效觸發(fā)時(shí)機(jī)查詢不存在數(shù)據(jù)的任何時(shí)候熱點(diǎn)Key緩存過期瞬間大量Key同時(shí)過期或緩存服務(wù)故障影響范圍可能影響數(shù)據(jù)庫性能影響該熱點(diǎn)數(shù)據(jù)相關(guān)功能影響系統(tǒng)全局可能導(dǎo)致服務(wù)不可用性質(zhì)多為攻擊或異常屬于高并發(fā)場景下的設(shè)計(jì)缺陷屬于系統(tǒng)性風(fēng)險(xiǎn)或運(yùn)維事故理解這三者的區(qū)別是設(shè)計(jì)有效防御方案的第一步。接下來我們將在實(shí)戰(zhàn)環(huán)境中復(fù)現(xiàn)這些問題并逐一解決。2. 環(huán)境準(zhǔn)備與項(xiàng)目搭建為了清晰地演示問題和解決方案我們搭建一個(gè)簡單的Spring Boot Web項(xiàng)目集成Redis作為緩存并使用H2內(nèi)存數(shù)據(jù)庫來模擬后端數(shù)據(jù)庫避免對環(huán)境造成依賴。2.1 技術(shù)棧與版本說明JDK: 17 (推薦8及以上)Spring Boot: 3.1.x (本文示例基于3.1.5)Spring Data Redis: 使用Lettuce客戶端Redis: 5.0 (本地或遠(yuǎn)程均可本文使用Docker運(yùn)行Redis 7)數(shù)據(jù)庫: H2 Database (內(nèi)存數(shù)據(jù)庫便于演示)構(gòu)建工具: MavenIDE: IntelliJ IDEA 或 Eclipse注意版本號僅供參考核心邏輯在不同版本間是通用的。請根據(jù)你的實(shí)際環(huán)境調(diào)整依賴版本。2.2 創(chuàng)建Spring Boot項(xiàng)目使用 Spring Initializr 或IDE創(chuàng)建項(xiàng)目選擇以下依賴Spring WebSpring Data RedisSpring Data JPAH2 DatabaseLombok (可選簡化代碼)2.3 項(xiàng)目核心配置創(chuàng)建完成后首先配置application.yml文件。# application.yml server: port: 8080 spring: # H2 數(shù)據(jù)庫配置 (內(nèi)存模式) datasource: url: jdbc:h2:mem:testdb driver-class-name: org.h2.Driver username: sa password: h2: console: enabled: true # 開啟H2控制臺(tái)方便查看數(shù)據(jù) http://localhost:8080/h2-console jpa: database-platform: org.hibernate.dialect.H2Dialect hibernate: ddl-auto: update show-sql: true # 開發(fā)時(shí)顯示SQL # Redis 配置 (假設(shè)Redis運(yùn)行在本地默認(rèn)端口) redis: host: localhost port: 6379 # password: yourpassword # 如果Redis有密碼 lettuce: pool: max-active: 8 max-idle: 8 min-idle: 0 # 自定義緩存配置例如默認(rèn)TTL app: cache: default-ttl: 300 # 默認(rèn)緩存5分鐘單位秒 hot-key-ttl: 60 # 熱點(diǎn)key緩存1分鐘用于演示擊穿2.4 實(shí)體與Repository創(chuàng)建一個(gè)簡單的商品實(shí)體和JPA Repository。// 文件路徑src/main/java/com/example/cache/model/Product.java package com.example.cache.model; import jakarta.persistence.*; import lombok.Data; Entity Data Table(name product) public class Product { Id GeneratedValue(strategy GenerationType.IDENTITY) private Long id; private String name; private Double price; // 省略構(gòu)造器、getter/setter使用了Lombok Data }// 文件路徑src/main/java/com/example/cache/repository/ProductRepository.java package com.example.cache.repository; import com.example.cache.model.Product; import org.springframework.data.jpa.repository.JpaRepository; import org.springframework.stereotype.Repository; Repository public interface ProductRepository extends JpaRepositoryProduct, Long { }2.5 啟動(dòng)Redis如果你本地沒有安裝Redis可以使用Docker快速啟動(dòng)一個(gè)docker run -d -p 6379:6379 --name my-redis redis:7-alpine環(huán)境準(zhǔn)備就緒后我們將編寫一個(gè)簡單的服務(wù)并依次復(fù)現(xiàn)三種緩存問題。3. 問題復(fù)現(xiàn)編寫存在缺陷的緩存服務(wù)我們先編寫一個(gè)基礎(chǔ)的、存在緩存缺陷的商品查詢服務(wù)以便觀察問題現(xiàn)象。3.1 基礎(chǔ)服務(wù)與控制器創(chuàng)建一個(gè)服務(wù)類ProductService和控制器ProductController。// 文件路徑src/main/java/com/example/cache/service/ProductService.java package com.example.cache.service; import com.example.cache.model.Product; import com.example.cache.repository.ProductRepository; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.cache.annotation.Cacheable; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.stereotype.Service; import java.util.concurrent.TimeUnit; Service Slf4j RequiredArgsConstructor public class ProductService { private final ProductRepository productRepository; private final RedisTemplateString, Object redisTemplate; /** * 存在緩存穿透、擊穿風(fēng)險(xiǎn)的查詢方法 * param id 商品ID * return 商品信息 */ public Product getProductByIdWithRisk(Long id) { String cacheKey product: id; // 1. 先查緩存 Product product (Product) redisTemplate.opsForValue().get(cacheKey); if (product ! null) { log.info(緩存命中商品ID: {}, id); return product; } // 2. 緩存未命中查數(shù)據(jù)庫 log.warn(緩存未命中查詢數(shù)據(jù)庫商品ID: {}, id); product productRepository.findById(id).orElse(null); if (product ! null) { // 3. 數(shù)據(jù)庫存在寫入緩存設(shè)置固定過期時(shí)間模擬擊穿場景 redisTemplate.opsForValue().set(cacheKey, product, 60, TimeUnit.SECONDS); // 固定60秒過期 log.info(數(shù)據(jù)庫查詢成功已寫入緩存商品ID: {}, id); } // 4. 如果數(shù)據(jù)庫也不存在直接返回null存在穿透風(fēng)險(xiǎn) return product; } }// 文件路徑src/main/java/com/example/cache/controller/ProductController.java package com.example.cache.controller; import com.example.cache.model.Product; import com.example.cache.service.ProductService; import lombok.RequiredArgsConstructor; import org.springframework.web.bind.annotation.*; RestController RequestMapping(/api/products) RequiredArgsConstructor public class ProductController { private final ProductService productService; GetMapping(/{id}) public Product getProduct(PathVariable Long id) { return productService.getProductByIdWithRisk(id); } }3.2 初始化測試數(shù)據(jù)在應(yīng)用啟動(dòng)時(shí)插入一些測試數(shù)據(jù)。// 文件路徑src/main/java/com/example/cache/runner/DataInitializer.java package com.example.cache.runner; import com.example.cache.model.Product; import com.example.cache.repository.ProductRepository; import lombok.RequiredArgsConstructor; import org.springframework.boot.CommandLineRunner; import org.springframework.stereotype.Component; Component RequiredArgsConstructor public class DataInitializer implements CommandLineRunner { private final ProductRepository productRepository; Override public void run(String... args) { // 清空并插入測試數(shù)據(jù) productRepository.deleteAll(); for (long i 1; i 5; i) { Product p new Product(); p.setId(i); p.setName(商品- i); p.setPrice(100.0 * i); productRepository.save(p); } System.out.println(測試數(shù)據(jù)初始化完成); } }3.3 復(fù)現(xiàn)問題啟動(dòng)應(yīng)用后我們可以通過工具如curl、Postman 或 JMeter來模擬請求。復(fù)現(xiàn)緩存穿透請求一個(gè)不存在的ID例如GET http://localhost:8080/api/products/99999。觀察日志每次請求都會(huì)打印緩存未命中查詢數(shù)據(jù)庫因?yàn)镮D為99999的商品不存在所以永遠(yuǎn)不會(huì)被緩存。使用壓測工具并發(fā)請求這個(gè)不存在的ID數(shù)據(jù)庫的select * from product where id99999查詢會(huì)持續(xù)執(zhí)行。復(fù)現(xiàn)緩存擊穿首先請求一個(gè)存在的熱點(diǎn)商品例如GET http://localhost:8080/api/products/1。第一次請求會(huì)查庫并緩存60秒。等待60秒讓緩存自然過期。使用壓測工具如JMeter設(shè)置100個(gè)線程同時(shí)啟動(dòng)在緩存過期后的瞬間并發(fā)請求GET http://localhost:8080/api/products/1。觀察日志你會(huì)看到大量緩存未命中查詢數(shù)據(jù)庫的日志幾乎同時(shí)出現(xiàn)數(shù)據(jù)庫在瞬間承受了100個(gè)相同的查詢。復(fù)現(xiàn)緩存雪崩在我們的簡單示例中可以通過批量插入大量數(shù)據(jù)并為它們設(shè)置完全相同或非常接近的過期時(shí)間來模擬。更典型的雪崩場景是Redis服務(wù)本身宕機(jī)。我們可以手動(dòng)停止Redis服務(wù)然后發(fā)起大量請求所有請求都會(huì)因連接Redis失敗而直接查詢數(shù)據(jù)庫導(dǎo)致數(shù)據(jù)庫壓力驟增。通過以上步驟我們清晰地看到了三種問題的表現(xiàn)。接下來我們將針對每個(gè)問題提供成熟的解決方案。4. 解決方案實(shí)戰(zhàn)從原理到代碼針對上述三種問題業(yè)界已有成熟的防御模式。我們將逐一實(shí)現(xiàn)并集成到Spring Boot項(xiàng)目中。4.1 防御緩存穿透布隆過濾器與空值緩存緩存穿透的核心是“查詢不存在的數(shù)據(jù)”。防御思路有兩個(gè)快速判斷數(shù)據(jù)是否存在和避免重復(fù)查詢不存在的數(shù)據(jù)。方案一布隆過濾器 (Bloom Filter)布隆過濾器是一種概率型數(shù)據(jù)結(jié)構(gòu)用于快速判斷一個(gè)元素是否可能存在于一個(gè)集合中。它的特點(diǎn)是空間效率極高但有一定的誤判率可能將不存在的元素判為存在但絕不會(huì)將存在的元素判為不存在。這正好適用于穿透防御如果過濾器說“不存在”那一定不存在可以直接返回如果過濾器說“可能存在”再去查緩存和數(shù)據(jù)庫。引入Guava的布隆過濾器單機(jī)版 在pom.xml中添加依賴。dependency groupIdcom.google.guava/groupId artifactIdguava/artifactId version31.1-jre/version !-- 請使用最新穩(wěn)定版 -- /dependency初始化布隆過濾器 在系統(tǒng)啟動(dòng)時(shí)將數(shù)據(jù)庫中所有存在的ID加載到布隆過濾器中。// 文件路徑src/main/java/com/example/cache/service/BloomFilterService.java package com.example.cache.service; import com.google.common.hash.BloomFilter; import com.google.common.hash.Funnels; import com.example.cache.repository.ProductRepository; import jakarta.annotation.PostConstruct; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Service; import java.util.List; Service Slf4j RequiredArgsConstructor public class BloomFilterService { private final ProductRepository productRepository; // 預(yù)期插入數(shù)量為100萬誤判率0.01% private BloomFilterLong bloomFilter; PostConstruct public void init() { ListLong allIds productRepository.findAllIds(); // 需要先在Repository中定義此方法 bloomFilter BloomFilter.create(Funnels.longFunnel(), 1_000_000, 0.0001); for (Long id : allIds) { bloomFilter.put(id); } log.info(布隆過濾器初始化完成已加載 {} 個(gè)元素, allIds.size()); } public boolean mightContain(Long id) { return bloomFilter.mightContain(id); } // 當(dāng)新增商品時(shí)也需要將ID放入過濾器 public void addId(Long id) { bloomFilter.put(id); } }注意需要在ProductRepository中添加Query(SELECT p.id FROM Product p) ListLong findAllIds();方法。方案二緩存空對象 (Cache Null)如果布隆過濾器判斷可能存在或者我們不想引入布隆過濾器可以采用更簡單的策略即使數(shù)據(jù)庫查詢結(jié)果為null也將其緩存起來并設(shè)置一個(gè)較短的過期時(shí)間如30-60秒。這樣在短時(shí)間內(nèi)再次請求同一個(gè)不存在的Key時(shí)會(huì)直接命中緩存中的空值從而保護(hù)數(shù)據(jù)庫。綜合防御實(shí)現(xiàn) 我們將兩種方案結(jié)合創(chuàng)建一個(gè)更健壯的查詢方法。// 在 ProductService 中添加新方法 public Product getProductByIdDefensePenetration(Long id) { String cacheKey product: id; String nullCacheKey product:null: id; // 空值緩存Key // 1. 先查正常緩存 Product product (Product) redisTemplate.opsForValue().get(cacheKey); if (product ! null) { log.info(緩存命中(正常數(shù)據(jù))商品ID: {}, id); return product; } // 2. 查空值緩存防御穿透 Object nullValue redisTemplate.opsForValue().get(nullCacheKey); if (nullValue ! null) { log.info(緩存命中(空值)商品ID: {} 不存在, id); return null; // 或返回一個(gè)特定的空對象 } // 3. (可選) 布隆過濾器校驗(yàn) // if (!bloomFilterService.mightContain(id)) { // log.warn(布隆過濾器判定商品ID: {} 不存在直接返回, id); // redisTemplate.opsForValue().set(nullCacheKey, NULL, 30, TimeUnit.SECONDS); // return null; // } // 4. 查詢數(shù)據(jù)庫 log.warn(緩存未命中查詢數(shù)據(jù)庫商品ID: {}, id); product productRepository.findById(id).orElse(null); if (product ! null) { // 5. 數(shù)據(jù)庫存在寫入正常緩存 redisTemplate.opsForValue().set(cacheKey, product, 300, TimeUnit.SECONDS); // 5分鐘 log.info(數(shù)據(jù)庫查詢成功已寫入緩存商品ID: {}, id); } else { // 6. 數(shù)據(jù)庫不存在寫入空值緩存設(shè)置較短TTL redisTemplate.opsForValue().set(nullCacheKey, NULL, 60, TimeUnit.SECONDS); // 1分鐘 log.warn(數(shù)據(jù)庫查詢無結(jié)果已緩存空值商品ID: {}, id); } return product; }4.2 防御緩存擊穿互斥鎖與邏輯過期緩存擊穿的核心是“熱點(diǎn)Key失效瞬間的并發(fā)沖擊”。防御思路是防止大量請求同時(shí)去重建緩存。方案一互斥鎖 (Mutex Lock)只允許一個(gè)線程去查詢數(shù)據(jù)庫并重建緩存其他線程等待直到緩存重建完成?？梢允褂肦edis的SETNXset if not exist命令實(shí)現(xiàn)分布式鎖。public Product getProductByIdDefenseBreakdown(Long id) { String cacheKey product: id; String lockKey lock:product: id; // 1. 先查緩存 Product product (Product) redisTemplate.opsForValue().get(cacheKey); if (product ! null) { return product; } // 2. 嘗試獲取分布式鎖 String requestId UUID.randomUUID().toString(); // 鎖的值用于安全釋放 Boolean isLocked false; try { // 使用SET命令實(shí)現(xiàn)SETNX并設(shè)置過期時(shí)間防止死鎖 isLocked redisTemplate.opsForValue().setIfAbsent(lockKey, requestId, 10, TimeUnit.SECONDS); if (Boolean.TRUE.equals(isLocked)) { // 2.1 獲取鎖成功再次檢查緩存Double Check product (Product) redisTemplate.opsForValue().get(cacheKey); if (product ! null) { return product; } // 2.2 查詢數(shù)據(jù)庫 log.info(線程 {} 獲取鎖成功查詢數(shù)據(jù)庫..., Thread.currentThread().getName()); product productRepository.findById(id).orElse(null); if (product ! null) { // 2.3 寫入緩存 redisTemplate.opsForValue().set(cacheKey, product, 300, TimeUnit.SECONDS); } else { // 處理穿透緩存空值 redisTemplate.opsForValue().set(cacheKey, NullValue.INSTANCE, 60, TimeUnit.SECONDS); } return product; } else { // 3. 未獲取到鎖等待片刻后重試 log.info(線程 {} 未獲取到鎖等待重試..., Thread.currentThread().getName()); Thread.sleep(50); // 短暫休眠避免活鎖 // 遞歸調(diào)用或循環(huán)重試這里簡單遞歸注意深度 return getProductByIdDefenseBreakdown(id); } } catch (InterruptedException e) { Thread.currentThread().interrupt(); throw new RuntimeException(獲取鎖時(shí)被中斷, e); } finally { // 4. 釋放鎖 (必須判斷是自己加的鎖) if (Boolean.TRUE.equals(isLocked)) { String currentValue (String) redisTemplate.opsForValue().get(lockKey); if (requestId.equals(currentValue)) { redisTemplate.delete(lockKey); } } } }注意生產(chǎn)環(huán)境建議使用更成熟的分布式鎖方案如Redisson。方案二邏輯過期 (Logical Expiration)不給緩存設(shè)置物理TTL而是在緩存Value中封裝一個(gè)邏輯過期時(shí)間。當(dāng)發(fā)現(xiàn)緩存過期時(shí)由一個(gè)線程去異步更新緩存其他線程直接返回舊的緩存數(shù)據(jù)。這種方式用戶體驗(yàn)好無等待但會(huì)有一段時(shí)間的數(shù)據(jù)不一致。// 封裝帶邏輯過期時(shí)間的緩存對象 Data public class RedisDataT { private T data; private Long expireTime; // 邏輯過期時(shí)間戳毫秒 } // 在Service中的使用邏輯 public Product getProductByIdLogicalExpire(Long id) { String cacheKey product: id; String lockKey lock:refresh: id; // 1. 從緩存中獲取封裝對象 RedisData redisData (RedisData) redisTemplate.opsForValue().get(cacheKey); if (redisData null) { // 緩存根本不存在按穿透處理或直接查庫 return getProductAndSetLogicalCache(id); } // 2. 判斷邏輯是否過期 Product product (Product) redisData.getData(); Long expireTime redisData.getExpireTime(); if (expireTime System.currentTimeMillis()) { // 2.1 未過期直接返回 return product; } // 2.2 已過期嘗試獲取鎖去刷新緩存 Boolean isLocked redisTemplate.opsForValue().setIfAbsent(lockKey, 1, 10, TimeUnit.SECONDS); if (Boolean.TRUE.equals(isLocked)) { // 2.2.1 獲取鎖成功開啟獨(dú)立線程異步刷新不阻塞當(dāng)前請求 CompletableFuture.runAsync(() - { try { // 重新查詢數(shù)據(jù)庫并更新緩存 Product newProduct productRepository.findById(id).orElse(null); RedisData newRedisData new RedisData(); newRedisData.setData(newProduct); newRedisData.setExpireTime(System.currentTimeMillis() 300_000); // 5分鐘后邏輯過期 redisTemplate.opsForValue().set(cacheKey, newRedisData); } finally { redisTemplate.delete(lockKey); } }); } // 2.2.2 無論是否獲取到鎖都返回舊的緩存數(shù)據(jù)可能已過期 return product; }4.3 防御緩存雪崩差異化過期與高可用架構(gòu)緩存雪崩的核心是“大量Key同時(shí)失效”。防御思路是避免集中失效和保證緩存服務(wù)高可用。方案一差異化過期時(shí)間 (Randomized TTL)這是最簡單有效的預(yù)防措施。在設(shè)置緩存過期時(shí)間時(shí)不要使用固定的TTL而是使用“基礎(chǔ)TTL 隨機(jī)偏移量”。// 在設(shè)置緩存時(shí)加入隨機(jī)時(shí)間 private long getRandomTtl(long baseTtlSeconds) { Random random new Random(); // 在基礎(chǔ)TTL上增加 -10% 到 10% 的隨機(jī)偏移 long offset (long) (baseTtlSeconds * 0.1 * (random.nextDouble() * 2 - 1)); // [-0.1*base, 0.1*base] return baseTtlSeconds offset; } // 使用 long ttl getRandomTtl(300); // 基礎(chǔ)300秒 redisTemplate.opsForValue().set(cacheKey, product, ttl, TimeUnit.SECONDS);方案二緩存永不過期后臺(tái)更新對于極其重要的熱點(diǎn)數(shù)據(jù)可以考慮設(shè)置緩存永不過期。通過后臺(tái)定時(shí)任務(wù)或消息隊(duì)列定期主動(dòng)更新緩存。這樣永遠(yuǎn)不會(huì)出現(xiàn)因過期導(dǎo)致的雪崩但需要維護(hù)數(shù)據(jù)一致性。方案三構(gòu)建高可用緩存集群防止因單點(diǎn)故障導(dǎo)致整個(gè)緩存層不可用。Redis Sentinel (哨兵)提供主從復(fù)制和自動(dòng)故障轉(zhuǎn)移。Redis Cluster (集群)提供數(shù)據(jù)分片和高可用。多級緩存本地緩存如Caffeine 分布式緩存Redis。即使Redis宕機(jī)本地緩存還能抵擋一部分流量。方案四服務(wù)降級與熔斷當(dāng)檢測到緩存服務(wù)不可用或數(shù)據(jù)庫壓力過大時(shí)快速失敗返回兜底數(shù)據(jù)如默認(rèn)值、靜態(tài)頁面避免連鎖故障。可以使用Resilience4j或Sentinel實(shí)現(xiàn)。// 使用 CircuitBreaker 注解的簡單示例 (需集成Resilience4j) CircuitBreaker(name productService, fallbackMethod getProductFallback) public Product getProductWithCircuitBreaker(Long id) { // 嘗試從緩存或數(shù)據(jù)庫獲取 // 如果失敗次數(shù)超過閾值熔斷器打開直接調(diào)用fallback方法 } public Product getProductFallback(Long id, Exception e) { log.error(熔斷降級返回兜底數(shù)據(jù)商品ID: {}, id, e); // 返回一個(gè)默認(rèn)商品或空對象 Product defaultProduct new Product(); defaultProduct.setId(id); defaultProduct.setName(默認(rèn)商品); defaultProduct.setPrice(0.0); return defaultProduct; }5. 整合方案與最佳實(shí)踐在實(shí)際項(xiàng)目中我們不會(huì)為每個(gè)查詢都手動(dòng)編寫復(fù)雜的防御代碼。通常我們會(huì)借助成熟的緩存框架如Spring Cache并對其進(jìn)行增強(qiáng)或者使用封裝好的工具類。5.1 使用Spring Cache注解增強(qiáng)Spring Cache提供了Cacheable、CachePut、CacheEvict等注解可以簡化緩存操作。我們可以通過自定義CacheManager和KeyGenerator來集成上述防御邏輯。自定義緩存管理器集成空值緩存和隨機(jī)TTLConfiguration EnableCaching public class RedisCacheConfig extends CachingConfigurerSupport { Value(${app.cache.default-ttl:300}) private long defaultTtl; Bean public CacheManager cacheManager(RedisConnectionFactory factory) { RedisCacheConfiguration config RedisCacheConfiguration.defaultCacheConfig() .entryTtl(Duration.ofSeconds(defaultTtl)) .serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(new StringRedisSerializer())) .serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(new GenericJackson2JsonRedisSerializer())) // 關(guān)鍵緩存空值防止穿透 .disableCachingNullValues(); // 默認(rèn)不緩存null我們需要改為允許不我們更希望用特定對象表示空。 // 更佳實(shí)踐在Service層處理空值緩存或使用一個(gè)特定的NullObject。 // 為不同緩存設(shè)置不同的TTL MapString, RedisCacheConfiguration cacheConfigMap new HashMap(); cacheConfigMap.put(productCache, config.entryTtl(Duration.ofSeconds(300))); cacheConfigMap.put(shortCache, config.entryTtl(Duration.ofSeconds(60))); return RedisCacheManager.builder(factory) .cacheDefaults(config) .withInitialCacheConfigurations(cacheConfigMap) .build(); } }在Service中使用注解Service public class EnhancedProductService { Cacheable(value productCache, key #id, unless #result null) public Product getProductById(Long id) { // 這里可以結(jié)合布隆過濾器進(jìn)行前置判斷 // 查詢數(shù)據(jù)庫... return productRepository.findById(id).orElse(null); } // 注意Cacheable 的 unless 條件會(huì)在方法返回后判斷如果返回null則不緩存。 // 這無法防御穿透因?yàn)閚ull不緩存需要額外處理。 }5.2 封裝通用工具類將互斥鎖、邏輯過期、空值緩存等邏輯封裝到一個(gè)通用的CacheService中供業(yè)務(wù)方調(diào)用。Component Slf4j public class CacheService { Autowired private RedisTemplateString, Object redisTemplate; Autowired private RedissonClient redissonClient; // 使用Redisson做分布式鎖 /** * 通用的防擊穿、防穿透查詢方法 * param key 緩存key * param clazz 返回值類型 * param loader 數(shù)據(jù)庫查詢函數(shù) * param ttl 緩存時(shí)間(秒) * param T 泛型 * return 數(shù)據(jù) */ public T T queryWithMutex(String key, ClassT clazz, CacheLoaderT loader, long ttl) { // 1. 查緩存 T value (T) redisTemplate.opsForValue().get(key); if (value ! null !isNullValue(value)) { return value; } // 2. 獲取分布式鎖 RLock lock redissonClient.getLock(lock: key); try { boolean isLocked lock.tryLock(10, 60, TimeUnit.SECONDS); // 等待10秒鎖持有60秒 if (isLocked) { // 2.1 Double Check value (T) redisTemplate.opsForValue().get(key); if (value ! null !isNullValue(value)) { return value; } // 2.2 執(zhí)行查詢 value loader.load(); if (value null) { // 防御穿透緩存空對象短TTL redisTemplate.opsForValue().set(key, NullObject.INSTANCE, Math.min(ttl, 60), TimeUnit.SECONDS); } else { // 設(shè)置隨機(jī)TTL防御雪崩 long randomTtl ttl new Random().nextInt(60) - 30; redisTemplate.opsForValue().set(key, value, randomTtl, TimeUnit.SECONDS); } return value; } else { // 未獲取到鎖等待后重試 Thread.sleep(50); return queryWithMutex(key, clazz, loader, ttl); } } catch (InterruptedException e) { Thread.currentThread().interrupt(); throw new RuntimeException(查詢中斷, e); } finally { if (lock.isHeldByCurrentThread()) { lock.unlock(); } } } private boolean isNullValue(Object obj) { return obj instanceof NullObject; } // 空對象標(biāo)識 private static class NullObject { private static final NullObject INSTANCE new NullObject(); } // 數(shù)據(jù)庫查詢函數(shù)式接口 FunctionalInterface public interface CacheLoaderT { T load(); } }使用方式public Product getProductSafe(Long id) { String key product: id; return cacheService.queryWithMutex(key, Product.class, () - { // 這里是數(shù)據(jù)庫查詢邏輯 return productRepository.findById(id).orElse(null); }, 300); }5.3 生產(chǎn)環(huán)境最佳實(shí)踐清單監(jiān)控與告警監(jiān)控Redis的內(nèi)存使用率、連接數(shù)、命中率、慢查詢。設(shè)置Key大量失效或緩存命中率驟降的告警。容量規(guī)劃與過期策略根據(jù)數(shù)據(jù)量合理設(shè)置Redis內(nèi)存并配置適當(dāng)?shù)奶蕴呗匀鏰llkeys-lru。避免所有Key設(shè)置相同過期時(shí)間。熱點(diǎn)Key發(fā)現(xiàn)與處理使用Redis的monitor命令或開源工具監(jiān)控?zé)狳c(diǎn)Key。對熱點(diǎn)Key采取更積極的策略如永不過期后臺(tái)更新或使用本地緩存。壓測與演練在上線前對緩存失效場景進(jìn)行壓測驗(yàn)證防御策略的有效性。定期進(jìn)行故障演練如主動(dòng)讓Redis節(jié)點(diǎn)宕機(jī)。代碼層面始終設(shè)置TTL除非有特殊設(shè)計(jì)否則不要使用永不過期的緩存?？紤]緩存更新策略是刪除后懶加載還是主動(dòng)更新注意大Value避免單個(gè)緩存Value過大如超過10KB影響網(wǎng)絡(luò)傳輸和反序列化性能。序列化選擇使用高效的序列化方式如JSONJackson、Protobuf、Msgpack。架構(gòu)層面讀寫分離使用Redis主從復(fù)制讀操作指向從節(jié)點(diǎn)。多級緩存應(yīng)用本地緩存Caffeine/Guava Cache 分布式緩存Redis。數(shù)據(jù)庫保護(hù)為數(shù)據(jù)庫配置合理的連接池、設(shè)置查詢超時(shí)、使用讀寫分離。6. 常見問題排查思路在實(shí)際運(yùn)維中即使有了防御措施也可能遇到問題。下面是一個(gè)快速排查清單。問題現(xiàn)象可能原因排查步驟與解決方案緩存命中率低1. 緩存Key設(shè)計(jì)不合理粒度太細(xì)或太粗。2. 數(shù)據(jù)變化頻繁緩存頻繁失效。3. 內(nèi)存不足Key被LRU淘汰。4. 大量請求不存在的Key穿透。1. 分析業(yè)務(wù)調(diào)整Key設(shè)計(jì)如聚合查詢。2. 評估數(shù)據(jù)一致性要求適當(dāng)延長TTL或采用異步更新。3. 使用INFO memory查看內(nèi)存擴(kuò)容或優(yōu)化數(shù)據(jù)結(jié)構(gòu)。4. 檢查是否存在惡意請求實(shí)施空值緩存或布隆過濾器。數(shù)據(jù)庫壓力大CPU飆升1. 緩存雪崩大量Key同時(shí)失效。2. 緩存擊穿熱點(diǎn)Key失效。3. 緩存穿透大量不存在的Key。4. 緩存服務(wù)宕機(jī)。1. 檢查Redis監(jiān)控確認(rèn)是否大量Key同時(shí)過期。臨時(shí)方案快速重啟應(yīng)用讓緩存重建分散開。長期方案設(shè)置隨機(jī)TTL。2. 分析慢查詢?nèi)罩菊业綗狳c(diǎn)Key。方案對該Key使用互斥鎖或邏輯過期。3. 分析訪問日志識別異常請求模式。方案實(shí)施空值緩存和請求限流。4. 檢查Redis服務(wù)狀態(tài)和網(wǎng)絡(luò)連接。方案啟用高可用架構(gòu)故障時(shí)自動(dòng)切換。應(yīng)用響應(yīng)變慢1. Redis連接池耗盡或網(wǎng)絡(luò)延遲高。2. 緩存Value過大序列化/反序列化耗時(shí)。3. 復(fù)雜的Lua腳本或阻塞命令如KEYS *執(zhí)行時(shí)間過長。1. 檢查Redis連接數(shù)監(jiān)控調(diào)整連接池配置。使用redis-cli --latency測試網(wǎng)絡(luò)延遲。2. 使用redis-memory-analyzer等工具分析大Key進(jìn)行拆分或壓縮。3. 避免在生產(chǎn)環(huán)境使用阻塞命令優(yōu)化Lua腳本。數(shù)據(jù)不一致1. 緩存更新策略不當(dāng)先更新數(shù)據(jù)庫后刪除緩存但刪除失敗。2. 主從同步延遲讀到了舊數(shù)據(jù)。1. 采用Cache-Aside模式并保證緩存刪除的重試機(jī)制如通過消息隊(duì)列。2. 對一致性要求高的數(shù)據(jù)強(qiáng)制讀主庫或使用Redisson的讀寫鎖。Redis內(nèi)存持續(xù)增長1. 沒有設(shè)置TTL或TTL過長。2. 內(nèi)存泄漏如連接未關(guān)閉。3. 存儲(chǔ)了無需緩存的數(shù)據(jù)。1. 為所有緩存Key設(shè)置合理的TTL。2. 檢查客戶端連接數(shù)確保連接正確釋放。3. 定期使用SCAN命令分析Key模式清理無用緩存。7. 總結(jié)緩存穿透、擊穿和雪崩是高并發(fā)系統(tǒng)設(shè)計(jì)中必須面對的經(jīng)典問題。通過本文的梳理我們可以清晰地把握三者的核心區(qū)別穿透針對不存在的數(shù)據(jù)防御核心是判斷存在性和緩存空值。擊穿針對熱點(diǎn)Key失效防御核心是避免并發(fā)重建互斥鎖/邏輯過期。雪崩針對大量Key同時(shí)失效防御核心是差異化過期和保證服務(wù)高可用。在實(shí)際項(xiàng)目中我們往往需要綜合運(yùn)用多種策略。一個(gè)健壯的緩存方案通常包含合理的Key設(shè)計(jì)、差異化的TTL、空值緩存、熱點(diǎn)Key探測與特殊處理、以及緩存服務(wù)本身的高可用架構(gòu)。Spring Cache等框架提供了良好的抽象但在應(yīng)對極端場景時(shí)往往需要我們在其基礎(chǔ)上進(jìn)行定制和增強(qiáng)。建議你在理解原理的基礎(chǔ)上根據(jù)自身業(yè)務(wù)的數(shù)據(jù)訪問模式、一致性要求和運(yùn)維能力選擇合適的組合方案。最好的學(xué)習(xí)方式就是動(dòng)手實(shí)踐搭建一個(gè)Demo項(xiàng)目模擬出這三種場景然后逐一實(shí)現(xiàn)防御代碼觀察效果。這將極大地加深你對緩存機(jī)制和系統(tǒng)韌性的理解。