欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

詳解redis緩存與數(shù)據(jù)庫(kù)一致性問(wèn)題解決

 更新時(shí)間:2021年03月26日 11:12:13   作者:Simba_hua  
這篇文章主要介紹了詳解redis緩存與數(shù)據(jù)庫(kù)一致性問(wèn)題解決,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧

數(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)文章希望大家以后多多支持腳本之家!

相關(guān)文章

  • Redis 的各項(xiàng)功能主要解決了什么問(wè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-10
  • Redis 緩存問(wèn)題及解決

    Redis 緩存問(wèn)題及解決

    網(wǎng)上收集的一些經(jīng)典特效,這里因?yàn)槠^長(zhǎng),不加整理了,想運(yùn)行的代碼的朋友可以點(diǎn)擊textarea中,全選復(fù)制即可。
    2010-07-07
  • Redis的5種數(shù)據(jù)類(lèi)型與常用命令講解

    Redis的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í)取消

    這篇文章主要介紹了基于Redis過(guò)期事件實(shí)現(xiàn)訂單超時(shí)取消,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧
    2021-05-05
  • Redis?SCAN命令詳解

    Redis?SCAN命令詳解

    SCAN 命令是一個(gè)基于游標(biāo)的迭代器,每次被調(diào)用之后, 都會(huì)向用戶(hù)返回一個(gè)新的游標(biāo), 用戶(hù)在下次迭代時(shí)需要使用這個(gè)新游標(biāo)作為 SCAN 命令的游標(biāo)參數(shù), 以此來(lái)延續(xù)之前的迭代過(guò)程,這篇文章給大家介紹了Redis?SCAN命令的相關(guān)知識(shí),感興趣的朋友一起看看吧
    2022-07-07
  • 你真的了解redis為什么要提供pipeline功能

    你真的了解redis為什么要提供pipeline功能

    Redis本身是一個(gè)cs模式的tcp server, client可以通過(guò)一個(gè)socket連續(xù)發(fā)起多個(gè)請(qǐng)求命令。這篇文章帶領(lǐng)大家學(xué)習(xí)redis為什么要提供pipeline功能,需要的朋友可以參考下
    2021-06-06
  • Redis教程(十):持久化詳解

    Redis教程(十):持久化詳解

    這篇文章主要介紹了Redis教程(十):持久化詳解,本文講解了Redis提供了哪些持久化機(jī)制、RDB機(jī)制的優(yōu)勢(shì)和劣勢(shì)、AOF機(jī)制的優(yōu)勢(shì)和劣勢(shì)、其它等內(nèi)容,需要的朋友可以參考下
    2015-04-04
  • 在CenOS系統(tǒng)下安裝和配置Redis數(shù)據(jù)庫(kù)的教程

    在CenOS系統(tǒng)下安裝和配置Redis數(shù)據(jù)庫(kù)的教程

    這篇文章主要介紹了在CenOS系統(tǒng)下安裝和配置Redis數(shù)據(jù)庫(kù)的教程,Redis是一個(gè)可基于內(nèi)存的高性能NoSQL數(shù)據(jù)庫(kù),需要的朋友可以參考下
    2015-11-11
  • redis簡(jiǎn)介_(kāi)動(dòng)力節(jié)點(diǎn)Java學(xué)院整理

    redis簡(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
  • 深入解析Java中Redis的20個(gè)常用方法

    深入解析Java中Redis的20個(gè)常用方法

    隨著互聯(lián)網(wǎng)技術(shù)的不斷發(fā)展,Java編程語(yǔ)言在計(jì)算機(jī)科學(xué)與技術(shù)中的應(yīng)用日益廣泛,本論文以"深入解析Java中Redis的20個(gè)常用方法"為主題,系統(tǒng)地探討了Java在Redis數(shù)據(jù)庫(kù)操作中的應(yīng)用和實(shí)現(xiàn),需要的朋友可以參考下
    2024-01-01

最新評(píng)論