首頁  >  文章  >  資料庫  >  Redis分散式鎖如何防止快取擊穿

Redis分散式鎖如何防止快取擊穿

王林
王林轉載
2023-06-03 19:04:371406瀏覽

快取擊穿

和快取穿透不同的是,快取擊穿是指:快取中沒有,但是資料庫中存在的熱點資料。

例如:首頁的熱點新聞,並發訪問量非常大的熱點數據,如果緩存過期失效,伺服器會去查詢DB,這時候如果大量的並發去查詢DB,可能會瞬間壓垮DB。

畫了個簡圖,如下所示:

Redis分散式鎖如何防止快取擊穿

解決方案:DB查詢加上分散式鎖定

未加鎖的情況

解決問題之前,先看一下不做處理的程式碼和運行情況。

根據商品ID查詢商品詳情代碼

Redis分散式鎖如何防止快取擊穿

#清空Redis緩存,開啟5個執行緒去並發存取測試,測試程式碼如下:

Redis分散式鎖如何防止快取擊穿


我們預期希望DB只查詢一次,後面4個查詢從Redis快取中取就行,但是結果:
Redis分散式鎖如何防止快取擊穿
沒有加分散式鎖,結果也在意料之中,但是這樣容器會對DB造成很大壓力。

如果是單一伺服器,直接使用Java的同步鎖定即可

Redis分散式鎖如何防止快取擊穿

很遺憾的是,通常後端是會部署叢集的,Java的同步鎖可沒辦法實作分散式鎖。

Redis分散式鎖定解決快取擊穿

Java的內建鎖定只能應用在單一機器上,無法實現分散式,可以巧用Redis來實現分散式鎖

加上了分散式鎖定後的程式碼

//根据ID查询商品
@GetMapping("/{id}")
public R id(@PathVariable String id){
	//先查Redis缓存
	Object o = redisTemplate.opsForValue().get(id);
	if (o != null) {
		//命中缓存
		System.err.println("id:"+id+",命中redis缓存...");
		return R.success(o);
	}

	//缓存未命中 查询数据库
	String lockKey = "lock" + id;
	//加锁,10s后过期
	for (;;) {
		if (redisTemplate.opsForValue().setIfAbsent(lockKey, System.currentTimeMillis(), 10L, TimeUnit.SECONDS)) {
			//加锁成功的线程,再次检查
			o = redisTemplate.opsForValue().get(id);
			if (o != null) {
				//命中缓存
				System.err.println("Thread:" + Thread.currentThread().getName() + ",id:"+id+",命中redis缓存...");
				//释放锁
				redisTemplate.delete(lockKey);
				return R.success(o);
			}

			//仍未命中
			System.err.println("Thread:" + Thread.currentThread().getName() + ",id:" + id + ",查询DB...");
			Goods goods = goodsMapper.selectById(id);
			//结果存入Redis
			redisTemplate.opsForValue().set(id, goods);
			//释放锁
			redisTemplate.delete(lockKey);
			return R.success(goods);
		}
		//竞争不到锁,暂时让出CPU资源
		Thread.yield();
	}
}

#啟動5個線程,並發訪問,結果如下圖:

Redis分散式鎖如何防止快取擊穿

以上是Redis分散式鎖如何防止快取擊穿的詳細內容。更多資訊請關注PHP中文網其他相關文章!

陳述:
本文轉載於:yisu.com。如有侵權,請聯絡admin@php.cn刪除