詳解redis緩存與數(shù)據(jù)庫(kù)一致性問(wèn)題解決
數(shù)據(jù)庫(kù)與緩存讀寫(xiě)模式策略
寫(xiě)完數(shù)據(jù)庫(kù)后是否需要馬上更新緩存還是直接刪除緩存?
(1)、如果寫(xiě)數(shù)據(jù)庫(kù)的值與更新到緩存值是一樣的,不需要經(jīng)過(guò)任何的計(jì)算,可以馬上更新緩存,但是如果對(duì)于那種寫(xiě)數(shù)據(jù)頻繁而讀數(shù)據(jù)少的場(chǎng)景并不合適這種解決方案,因?yàn)橐苍S還沒(méi)有查詢(xún)就被刪除或修改了,這樣會(huì)浪費(fèi)時(shí)間和資源
(2)、如果寫(xiě)數(shù)據(jù)庫(kù)的值與更新緩存的值不一致,寫(xiě)入緩存中的數(shù)據(jù)需要經(jīng)過(guò)幾個(gè)表的關(guān)聯(lián)計(jì)算后得到的結(jié)果插入緩存中,那就沒(méi)有必要馬上更新緩存,只有刪除緩存即可,等到查詢(xún)的時(shí)候在去把計(jì)算后得到的結(jié)果插入到緩存中即可。
所以一般的策略是當(dāng)更新數(shù)據(jù)時(shí),先刪除緩存數(shù)據(jù),然后更新數(shù)據(jù)庫(kù),而不是更新緩存,等要查詢(xún)的時(shí)候才把最新的數(shù)據(jù)更新到緩存
數(shù)據(jù)庫(kù)與緩存雙寫(xiě)情況下導(dǎo)致數(shù)據(jù)不一致問(wèn)題
場(chǎng)景一
當(dāng)更新數(shù)據(jù)時(shí),如更新某商品的庫(kù)存,當(dāng)前商品的庫(kù)存是100,現(xiàn)在要更新為99,先更新數(shù)據(jù)庫(kù)更改成99,然后刪除緩存,發(fā)現(xiàn)刪除緩存失敗了,這意味著數(shù)據(jù)庫(kù)存的是99,而緩存是100,這導(dǎo)致數(shù)據(jù)庫(kù)和緩存不一致。
場(chǎng)景一解決方案
這種情況應(yīng)該是先刪除緩存,然后在更新數(shù)據(jù)庫(kù),如果刪除緩存失敗,那就不要更新數(shù)據(jù)庫(kù),如果說(shuō)刪除緩存成功,而更新數(shù)據(jù)庫(kù)失敗,那查詢(xún)的時(shí)候只是從數(shù)據(jù)庫(kù)里查了舊的數(shù)據(jù)而已,這樣就能保持?jǐn)?shù)據(jù)庫(kù)與緩存的一致性。
場(chǎng)景二
在高并發(fā)的情況下,如果當(dāng)刪除完緩存的時(shí)候,這時(shí)去更新數(shù)據(jù)庫(kù),但還沒(méi)有更新完,另外一個(gè)請(qǐng)求來(lái)查詢(xún)數(shù)據(jù),發(fā)現(xiàn)緩存里沒(méi)有,就去數(shù)據(jù)庫(kù)里查,還是以上面商品庫(kù)存為例,如果數(shù)據(jù)庫(kù)中產(chǎn)品的庫(kù)存是100,那么查詢(xún)到的庫(kù)存是100,然后插入緩存,插入完緩存后,原來(lái)那個(gè)更新數(shù)據(jù)庫(kù)的線(xiàn)程把數(shù)據(jù)庫(kù)更新為了99,導(dǎo)致數(shù)據(jù)庫(kù)與緩存不一致的情況
場(chǎng)景二解決方案
遇到這種情況,可以用隊(duì)列的去解決這個(gè)問(wèn),創(chuàng)建幾個(gè)隊(duì)列,如20個(gè),根據(jù)商品的ID去做hash值,然后對(duì)隊(duì)列個(gè)數(shù)取摸,當(dāng)有數(shù)據(jù)更新請(qǐng)求時(shí),先把它丟到隊(duì)列里去,當(dāng)更新完后在從隊(duì)列里去除,如果在更新的過(guò)程中,遇到以上場(chǎng)景,先去緩存里看下有沒(méi)有數(shù)據(jù),如果沒(méi)有,可以先去隊(duì)列里看是否有相同商品ID在做更新,如果有也把查詢(xún)的請(qǐng)求發(fā)送到隊(duì)列里去,然后同步等待緩存更新完成。
這里有一個(gè)優(yōu)化點(diǎn),如果發(fā)現(xiàn)隊(duì)列里有一個(gè)查詢(xún)請(qǐng)求了,那么就不要放新的查詢(xún)操作進(jìn)去了,用一個(gè)while(true)循環(huán)去查詢(xún)緩存,循環(huán)個(gè)200MS左右,如果緩存里還沒(méi)有則直接取數(shù)據(jù)庫(kù)的舊數(shù)據(jù),一般情況下是可以取到的。
在高并發(fā)下解決場(chǎng)景二要注意的問(wèn)題
(1)讀請(qǐng)求時(shí)長(zhǎng)阻塞
由于讀請(qǐng)求進(jìn)行了非常輕度的異步化,所以一定要注意讀超時(shí)的問(wèn)題,每個(gè)讀請(qǐng)求必須在超時(shí)間內(nèi)返回,該解決方案最大的風(fēng)險(xiǎn)在于可能數(shù)據(jù)更新很頻繁,導(dǎo)致隊(duì)列中擠壓了大量的更新操作在里面,然后讀請(qǐng)求會(huì)發(fā)生大量的超時(shí),最后導(dǎo)致大量的請(qǐng)求直接走數(shù)據(jù)庫(kù),像遇到這種情況,一般要做好足夠的壓力測(cè)試,如果壓力過(guò)大,需要根據(jù)實(shí)際情況添加機(jī)器。
(2)請(qǐng)求并發(fā)量過(guò)高
這里還是要做好壓力測(cè)試,多模擬真實(shí)場(chǎng)景,并發(fā)量在最高的時(shí)候QPS多少,扛不住就要多加機(jī)器,還有就是做好讀寫(xiě)比例是多少
(3)多服務(wù)實(shí)例部署的請(qǐng)求路由
可能這個(gè)服務(wù)部署了多個(gè)實(shí)例,那么必須保證說(shuō),執(zhí)行數(shù)據(jù)更新操作,以及執(zhí)行緩存更新操作的請(qǐng)求,都通過(guò)nginx服務(wù)器路由到相同的服務(wù)實(shí)例上
(4)熱點(diǎn)商品的路由問(wèn)題,導(dǎo)致請(qǐng)求的傾斜
某些商品的讀請(qǐng)求特別高,全部打到了相同的機(jī)器的相同丟列里了,可能造成某臺(tái)服務(wù)器壓力過(guò)大,因?yàn)橹挥性谏唐窋?shù)據(jù)更新的時(shí)候才會(huì)清空緩存,然后才會(huì)導(dǎo)致讀寫(xiě)并發(fā),所以更新頻率不是太高的話(huà),這個(gè)問(wèn)題的影響并不是很大,但是確實(shí)有可能某些服務(wù)器的負(fù)載會(huì)高一些。
數(shù)據(jù)庫(kù)與緩存數(shù)據(jù)一致性解決方案流程圖
數(shù)據(jù)庫(kù)與緩存數(shù)據(jù)一致性解決方案對(duì)應(yīng)代碼
商品庫(kù)存實(shí)體
package com.shux.inventory.entity; /** ********************************************** * 描述: * Simba.Hua * 2017年8月30日 ********************************************** **/ public class InventoryProduct { private Integer productId; private Long InventoryCnt; public Integer getProductId() { return productId; } public void setProductId(Integer productId) { this.productId = productId; } public Long getInventoryCnt() { return InventoryCnt; } public void setInventoryCnt(Long inventoryCnt) { InventoryCnt = inventoryCnt; } }
請(qǐng)求接口
/** ********************************************** * 描述: * Simba.Hua * 2017年8月27日 ********************************************** **/ public interface Request { public void process(); public Integer getProductId(); public boolean isForceFefresh(); }
數(shù)據(jù)更新請(qǐng)求
package com.shux.inventory.request; import org.springframework.transaction.annotation.Transactional; import com.shux.inventory.biz.InventoryProductBiz; import com.shux.inventory.entity.InventoryProduct; /** ********************************************** * 描述:更新庫(kù)存信息 * 1、先刪除緩存中的數(shù)據(jù) * 2、更新數(shù)據(jù)庫(kù)中的數(shù)據(jù) * Simba.Hua * 2017年8月30日 ********************************************** **/ public class InventoryUpdateDBRequest implements Request{ private InventoryProductBiz inventoryProductBiz; private InventoryProduct inventoryProduct; public InventoryUpdateDBRequest(InventoryProduct inventoryProduct,InventoryProductBiz inventoryProductBiz){ this.inventoryProduct = inventoryProduct; this.inventoryProductBiz = inventoryProductBiz; } @Override @Transactional public void process() { inventoryProductBiz.removeInventoryProductCache(inventoryProduct.getProductId()); inventoryProductBiz.updateInventoryProduct(inventoryProduct); } @Override public Integer getProductId() { // TODO Auto-generated method stub return inventoryProduct.getProductId(); } @Override public boolean isForceFefresh() { // TODO Auto-generated method stub return false; } }
查詢(xún)請(qǐng)求
package com.shux.inventory.request; import com.shux.inventory.biz.InventoryProductBiz; import com.shux.inventory.entity.InventoryProduct; /** ********************************************** * 描述:查詢(xún)緩存數(shù)據(jù) * 1、從數(shù)據(jù)庫(kù)中查詢(xún) * 2、從數(shù)據(jù)庫(kù)中查詢(xún)后插入到緩存中 * Simba.Hua * 2017年8月30日 ********************************************** **/ public class InventoryQueryCacheRequest implements Request { private InventoryProductBiz inventoryProductBiz; private Integer productId; private boolean isForceFefresh; public InventoryQueryCacheRequest(Integer productId,InventoryProductBiz inventoryProductBiz,boolean isForceFefresh) { this.productId = productId; this.inventoryProductBiz = inventoryProductBiz; this.isForceFefresh = isForceFefresh; } @Override public void process() { InventoryProduct inventoryProduct = inventoryProductBiz.loadInventoryProductByProductId(productId); inventoryProductBiz.setInventoryProductCache(inventoryProduct); } @Override public Integer getProductId() { // TODO Auto-generated method stub return productId; } public boolean isForceFefresh() { return isForceFefresh; } public void setForceFefresh(boolean isForceFefresh) { this.isForceFefresh = isForceFefresh; } }
spring啟動(dòng)時(shí)初始化隊(duì)列線(xiàn)程池
package com.shux.inventory.thread; import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import com.shux.inventory.request.Request; import com.shux.inventory.request.RequestQueue; import com.shux.utils.other.SysConfigUtil; /** ********************************************** * 描述:請(qǐng)求處理線(xiàn)程池,初始化隊(duì)列數(shù)及每個(gè)隊(duì)列最多能處理的數(shù)量 * Simba.Hua * 2017年8月27日 ********************************************** **/ public class RequestProcessorThreadPool { private static final int blockingQueueNum = SysConfigUtil.get("request.blockingqueue.number")==null?10:Integer.valueOf(SysConfigUtil.get("request.blockingqueue.number").toString()); private static final int queueDataNum = SysConfigUtil.get("request.everyqueue.data.length")==null?100:Integer.valueOf(SysConfigUtil.get("request.everyqueue.data.length").toString()); private ExecutorService threadPool = Executors.newFixedThreadPool(blockingQueueNum); private RequestProcessorThreadPool(){ for(int i=0;i<blockingQueueNum;i++){//初始化隊(duì)列 ArrayBlockingQueue<Request> queue = new ArrayBlockingQueue<Request>(queueDataNum);//每個(gè)隊(duì)列中放100條數(shù)據(jù) RequestQueue.getInstance().addQueue(queue); threadPool.submit(new RequestProcessorThread(queue));//把每個(gè)queue交個(gè)線(xiàn)程去處理,線(xiàn)程會(huì)處理每個(gè)queue中的數(shù)據(jù) } } public static class Singleton{ private static RequestProcessorThreadPool instance; static{ instance = new RequestProcessorThreadPool(); } public static RequestProcessorThreadPool getInstance(){ return instance; } } public static RequestProcessorThreadPool getInstance(){ return Singleton.getInstance(); } /** * 初始化線(xiàn)程池 */ public static void init(){ getInstance(); } }
請(qǐng)求處理線(xiàn)程
package com.shux.inventory.thread; import java.util.Map; import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.Callable; import com.shux.inventory.request.InventoryUpdateDBRequest; import com.shux.inventory.request.Request; import com.shux.inventory.request.RequestQueue; /** ********************************************** * 描述:請(qǐng)求處理線(xiàn)程 * Simba.Hua * 2017年8月27日 ********************************************** **/ public class RequestProcessorThread implements Callable<Boolean>{ private ArrayBlockingQueue<Request> queue; public RequestProcessorThread(ArrayBlockingQueue<Request> queue){ this.queue = queue; } @Override public Boolean call() throws Exception { Request request = queue.take(); Map<Integer,Boolean> flagMap = RequestQueue.getInstance().getFlagMap(); //不需要強(qiáng)制刷新的時(shí)候,查詢(xún)請(qǐng)求去重處理 if (!request.isForceFefresh()){ if (request instanceof InventoryUpdateDBRequest) {//如果是更新請(qǐng)求,那就置為false flagMap.put(request.getProductId(), true); } else { Boolean flag = flagMap.get(request.getProductId()); /** * 標(biāo)志位為空,有三種情況 * 1、沒(méi)有過(guò)更新請(qǐng)求 * 2、沒(méi)有查詢(xún)請(qǐng)求 * 3、數(shù)據(jù)庫(kù)中根本沒(méi)有數(shù)據(jù) * 在最初情況,一旦庫(kù)存了插入了數(shù)據(jù),那就好會(huì)在緩存中也會(huì)放一份數(shù)據(jù), * 但這種情況下有可能由于redis中內(nèi)存滿(mǎn)了,redis通過(guò)LRU算法把這個(gè)商品給清除了,導(dǎo)致緩存中沒(méi)有數(shù)據(jù) * 所以當(dāng)標(biāo)志位為空的時(shí)候,需要從數(shù)據(jù)庫(kù)重查詢(xún)一次,并且把標(biāo)志位置為false,以便后面的請(qǐng)求能夠從緩存中取 */ if ( flag == null) { flagMap.put(request.getProductId(), false); } /** * 如果不為空,并且flag為true,說(shuō)明之前有一次更新請(qǐng)求,說(shuō)明緩存中沒(méi)有數(shù)據(jù)了(更新緩存會(huì)先刪除緩存), * 這個(gè)時(shí)候就要去刷新緩存,即從數(shù)據(jù)庫(kù)中查詢(xún)一次,并把標(biāo)志位設(shè)置為false */ if ( flag != null && flag) { flagMap.put(request.getProductId(), false); } /** * 這種情況說(shuō)明之前有一個(gè)查詢(xún)請(qǐng)求,并且把數(shù)據(jù)刷新到了緩存中,所以這時(shí)候就不用去刷新緩存了,直接返回就可以了 */ if (flag != null && !flag) { flagMap.put(request.getProductId(), false); return true; } } } request.process(); return true; } }
請(qǐng)求隊(duì)列
package com.shux.inventory.request; import java.util.ArrayList; import java.util.List; import java.util.Map; import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.ConcurrentHashMap; /** ********************************************** * 描述:請(qǐng)求隊(duì)列 * Simba.Hua * 2017年8月27日 ********************************************** **/ public class RequestQueue { private List<ArrayBlockingQueue<Request>> queues = new ArrayList<>(); private Map<Integer,Boolean> flagMap = new ConcurrentHashMap<>(); private RequestQueue(){ } private static class Singleton{ private static RequestQueue queue; static{ queue = new RequestQueue(); } public static RequestQueue getInstance() { return queue; } } public static RequestQueue getInstance(){ return Singleton.getInstance(); } public void addQueue(ArrayBlockingQueue<Request> queue) { queues.add(queue); } public int getQueueSize(){ return queues.size(); } public ArrayBlockingQueue<Request> getQueueByIndex(int index) { return queues.get(index); } public Map<Integer,Boolean> getFlagMap() { return this.flagMap; } }
spring 啟動(dòng)初始化線(xiàn)程池類(lèi)
package com.shux.inventory.listener; import org.springframework.context.ApplicationListener; import org.springframework.context.event.ContextRefreshedEvent; import com.shux.inventory.thread.RequestProcessorThreadPool; /** ********************************************** * 描述:spring 啟動(dòng)初始化線(xiàn)程池類(lèi) * Simba.Hua * 2017年8月27日 ********************************************** **/ public class InitListener implements ApplicationListener<ContextRefreshedEvent>{ @Override public void onApplicationEvent(ContextRefreshedEvent event) { // TODO Auto-generated method stub if(event.getApplicationContext().getParent() != null){ return; } RequestProcessorThreadPool.init(); } }
異步處理請(qǐng)求接口
package com.shux.inventory.biz; import com.shux.inventory.request.Request; /** ********************************************** * 描述:請(qǐng)求異步處理接口,用于路由隊(duì)列并把請(qǐng)求加入到隊(duì)列中 * Simba.Hua * 2017年8月30日 ********************************************** **/ public interface IRequestAsyncProcessBiz { void process(Request request); }
異步處理請(qǐng)求接口實(shí)現(xiàn)
package com.shux.inventory.biz.impl; import java.util.concurrent.ArrayBlockingQueue; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.stereotype.Service; import com.shux.inventory.biz.IRequestAsyncProcessBiz; import com.shux.inventory.request.Request; import com.shux.inventory.request.RequestQueue; /** ********************************************** * 描述:異步處理請(qǐng)求,用于路由隊(duì)列并把請(qǐng)求加入到隊(duì)列中 * Simba.Hua * 2017年8月30日 ********************************************** **/ @Service("requestAsyncProcessService") public class RequestAsyncProcessBizImpl implements IRequestAsyncProcessBiz { private Logger logger = LoggerFactory.getLogger(getClass()); @Override public void process(Request request) { // 做請(qǐng)求的路由,根據(jù)productId路由到對(duì)應(yīng)的隊(duì)列 ArrayBlockingQueue<Request> queue = getQueueByProductId(request.getProductId()); try { queue.put(request); } catch (InterruptedException e) { logger.error("產(chǎn)品ID{}加入隊(duì)列失敗",request.getProductId(),e); } } private ArrayBlockingQueue<Request> getQueueByProductId(Integer productId) { RequestQueue requestQueue = RequestQueue.getInstance(); String key = String.valueOf(productId); int hashcode; int hash = (key == null) ? 0 : (hashcode = key.hashCode())^(hashcode >>> 16); //對(duì)hashcode取摸 int index = (requestQueue.getQueueSize()-1) & hash; return requestQueue.getQueueByIndex(index); } }
package com.shux.inventory.biz.impl; import javax.annotation.Resource; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import com.shux.inventory.biz.InventoryProductBiz; import com.shux.inventory.entity.InventoryProduct; import com.shux.inventory.mapper.InventoryProductMapper; import com.shux.redis.biz.IRedisBiz; /** ********************************************** * 描述 * Simba.Hua * 2017年8月30日 ********************************************** **/ @Service("inventoryProductBiz") public class InventoryProductBizImpl implements InventoryProductBiz { private @Autowired IRedisBiz<InventoryProduct> redisBiz; private @Resource InventoryProductMapper mapper; @Override public void updateInventoryProduct(InventoryProduct inventoryProduct) { // TODO Auto-generated method stub mapper.updateInventoryProduct(inventoryProduct); } @Override public InventoryProduct loadInventoryProductByProductId(Integer productId) { // TODO Auto-generated method stub return mapper.loadInventoryProductByProductId(productId); } @Override public void setInventoryProductCache(InventoryProduct inventoryProduct) { redisBiz.set("inventoryProduct:"+inventoryProduct.getProductId(), inventoryProduct); } @Override public void removeInventoryProductCache(Integer productId) { redisBiz.delete("inventoryProduct:"+productId); } @Override public InventoryProduct loadInventoryProductCache(Integer productId) { // TODO Auto-generated method stub return redisBiz.get("inventoryProduct:"+productId); } }
數(shù)據(jù)更新請(qǐng)求controller
package com.shux.inventory.controller; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.ResponseBody; import com.shux.inventory.biz.IRequestAsyncProcessBiz; import com.shux.inventory.biz.InventoryProductBiz; import com.shux.inventory.entity.InventoryProduct; import com.shux.inventory.request.InventoryUpdateDBRequest; import com.shux.inventory.request.Request; import com.shux.utils.other.Response; /** ********************************************** * 描述:提交更新請(qǐng)求 * Simba.Hua * 2017年9月1日 ********************************************** **/ @Controller("/inventory") public class InventoryUpdateDBController { private @Autowired InventoryProductBiz inventoryProductBiz; private @Autowired IRequestAsyncProcessBiz requestAsyncProcessBiz; @RequestMapping("/updateDBInventoryProduct") @ResponseBody public Response updateDBInventoryProduct(InventoryProduct inventoryProduct){ Request request = new InventoryUpdateDBRequest(inventoryProduct,inventoryProductBiz); requestAsyncProcessBiz.process(request); return new Response(Response.SUCCESS,"更新成功"); } }
數(shù)據(jù)查詢(xún)請(qǐng)求controller
package com.shux.inventory.controller; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.RequestMapping; import com.shux.inventory.biz.IRequestAsyncProcessBiz; import com.shux.inventory.biz.InventoryProductBiz; import com.shux.inventory.entity.InventoryProduct; import com.shux.inventory.request.InventoryQueryCacheRequest; import com.shux.inventory.request.Request; /** ********************************************** * 描述:提交查詢(xún)請(qǐng)求 * 1、先從緩存中取數(shù)據(jù) * 2、如果能從緩存中取到數(shù)據(jù),則返回 * 3、如果不能從緩存取到數(shù)據(jù),則等待20毫秒,然后再次去數(shù)據(jù),直到200毫秒,如果超過(guò)200毫秒還不能取到數(shù)據(jù),則從數(shù)據(jù)庫(kù)中取,并強(qiáng)制刷新緩存數(shù)據(jù) * Simba.Hua * 2017年9月1日 ********************************************** **/ @Controller("/inventory") public class InventoryQueryCacheController { private @Autowired InventoryProductBiz inventoryProductBiz; private @Autowired IRequestAsyncProcessBiz requestAsyncProcessBiz; @RequestMapping("/queryInventoryProduct") public InventoryProduct queryInventoryProduct(Integer productId) { Request request = new InventoryQueryCacheRequest(productId,inventoryProductBiz,false); requestAsyncProcessBiz.process(request);//加入到隊(duì)列中 long startTime = System.currentTimeMillis(); long allTime = 0L; long endTime = 0L; InventoryProduct inventoryProduct = null; while (true) { if (allTime > 200){//如果超過(guò)了200ms,那就直接退出,然后從數(shù)據(jù)庫(kù)中查詢(xún) break; } try { inventoryProduct = inventoryProductBiz.loadInventoryProductCache(productId); if (inventoryProduct != null) { return inventoryProduct; } else { Thread.sleep(20);//如果查詢(xún)不到就等20毫秒 } endTime = System.currentTimeMillis(); allTime = endTime - startTime; } catch (Exception e) { } } /** * 代碼執(zhí)行到這來(lái),只有以下三種情況 * 1、緩存中本來(lái)有數(shù)據(jù),由于redis內(nèi)存滿(mǎn)了,redis通過(guò)LRU算法清除了緩存,導(dǎo)致數(shù)據(jù)沒(méi)有了 * 2、由于之前數(shù)據(jù)庫(kù)查詢(xún)比較慢或者內(nèi)存太小處理不過(guò)來(lái)隊(duì)列中的數(shù)據(jù),導(dǎo)致隊(duì)列里擠壓了很多的數(shù)據(jù),所以一直沒(méi)有從數(shù)據(jù)庫(kù)中獲取數(shù)據(jù)然后插入到緩存中 * 3、數(shù)據(jù)庫(kù)中根本沒(méi)有這樣的數(shù)據(jù),這種情況叫數(shù)據(jù)穿透,一旦別人知道這個(gè)商品沒(méi)有,如果一直執(zhí)行查詢(xún),就會(huì)一直查詢(xún)數(shù)據(jù)庫(kù),如果過(guò)多,那么有可能會(huì)導(dǎo)致數(shù)據(jù)庫(kù)癱瘓 */ inventoryProduct = inventoryProductBiz.loadInventoryProductByProductId(productId); if (inventoryProduct != null) { Request forcRrequest = new InventoryQueryCacheRequest(productId,inventoryProductBiz,true); requestAsyncProcessBiz.process(forcRrequest);//這個(gè)時(shí)候需要強(qiáng)制刷新數(shù)據(jù)庫(kù),使緩存中有數(shù)據(jù) return inventoryProduct; } return null; } }
到此這篇關(guān)于詳解redis緩存與數(shù)據(jù)庫(kù)一致性問(wèn)題解決的文章就介紹到這了,更多相關(guān)redis緩存與數(shù)據(jù)庫(kù)一致性?xún)?nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
- 面試常問(wèn):如何保證Redis緩存和數(shù)據(jù)庫(kù)的數(shù)據(jù)一致性
- redis緩存一致性延時(shí)雙刪代碼實(shí)現(xiàn)方式
- 淺談一下如何保證Redis緩存與數(shù)據(jù)庫(kù)的一致性
- MySQL數(shù)據(jù)庫(kù)和Redis緩存一致性的更新策略
- redis分布式鎖解決緩存雙寫(xiě)一致性
- redis緩存與數(shù)據(jù)庫(kù)一致性的問(wèn)題及解決
- Redis解決緩存一致性問(wèn)題
- Spring?Boot與Redis的緩存一致性問(wèn)題解決
- Redis緩存和數(shù)據(jù)庫(kù)的數(shù)據(jù)一致性的問(wèn)題解決
- Redis+Caffeine多級(jí)緩存數(shù)據(jù)一致性解決方案
- Redis 緩存雙寫(xiě)一致性的解決方案
相關(guān)文章
Redis 的各項(xiàng)功能主要解決了什么問(wèn)題
Redis是一個(gè)基于BSD開(kāi)源的項(xiàng)目,是一個(gè)把結(jié)構(gòu)化的數(shù)據(jù)放在內(nèi)存中的一個(gè)存儲(chǔ)系統(tǒng),你可以把它作為數(shù)據(jù)庫(kù),緩存和消息中間件來(lái)使用。這篇文章主要介紹了Redis 的各項(xiàng)功能主要解決了什么問(wèn)題,需要的朋友可以參考下2018-10-10Redis的5種數(shù)據(jù)類(lèi)型與常用命令講解
今天小編就為大家分享一篇關(guān)于Redis的5種數(shù)據(jù)類(lèi)型與常用命令講解,小編覺(jué)得內(nèi)容挺不錯(cuò)的,現(xiàn)在分享給大家,具有很好的參考價(jià)值,需要的朋友一起跟隨小編來(lái)看看吧2019-03-03基于Redis過(guò)期事件實(shí)現(xiàn)訂單超時(shí)取消
這篇文章主要介紹了基于Redis過(guò)期事件實(shí)現(xiàn)訂單超時(shí)取消,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2021-05-05在CenOS系統(tǒng)下安裝和配置Redis數(shù)據(jù)庫(kù)的教程
這篇文章主要介紹了在CenOS系統(tǒng)下安裝和配置Redis數(shù)據(jù)庫(kù)的教程,Redis是一個(gè)可基于內(nèi)存的高性能NoSQL數(shù)據(jù)庫(kù),需要的朋友可以參考下2015-11-11redis簡(jiǎn)介_(kāi)動(dòng)力節(jié)點(diǎn)Java學(xué)院整理
這篇文章主要介紹了redis簡(jiǎn)介,Redis是一個(gè)開(kāi)源的,先進(jìn)的 key-value 存儲(chǔ)可用于構(gòu)建高性能,可擴(kuò)展的 Web 應(yīng)用程序的解決方案,有興趣的可以了解一下2017-08-08