使用Redis incr解決并發(fā)問題的操作

更新時(shí)間：2020年11月24日 09:37:53 作者：chen_lay

這篇文章主要介紹了使用Redis incr解決并發(fā)問題的操作，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過來看看吧

項(xiàng)目背景：

1、新增問題件工單，工單中有工單編碼字段，工單編碼字段的規(guī)則為 “WT”+yyyyMMdd+0000001。

2、每天的工單生成量是30W，所以會(huì)存在并發(fā)問題

解決思路：

1、首先樂觀的認(rèn)為redis不會(huì)宕機(jī)，對(duì)應(yīng)的緩存不會(huì)被清除（除非人為操作，人為操作會(huì)有獨(dú)立的補(bǔ)救辦法）

2、將工單編碼存到緩存中（redis）,其值只存“WT”+yyyyMMdd后面的數(shù)字部分；

對(duì)應(yīng)的key為：key標(biāo)識(shí)+yyyyMMdd，即每天一個(gè)key

3、每次生成工單編碼時(shí)，先調(diào)用redis的incr方法，使其在原來編碼的基礎(chǔ)上加1，并返回結(jié)果

4、判斷返回的結(jié)果，如果返回的是1，說明當(dāng)前key之前不存在，為生成的新的一天的key，

需要設(shè)置此key的生命周期為24小時(shí)

5、每個(gè)key只會(huì)存活24小時(shí)

6、如果redis宕機(jī)，或者key被刪除，調(diào)用指定的接口，接口會(huì)去數(shù)據(jù)庫查詢今天最大的工單編碼，

解析后，將其存在redis中，后面的工單編碼再在此基礎(chǔ)上自增

7、請(qǐng)自行配置redisClient客戶端并實(shí)例化

代碼：

1、編碼獲取核心方法

/**
 * 通過自定義的方法查詢問題件緩存
 * @param redisKey
 * @param codePre
   * @return
   */
 public static String getCodeBySelfRedis(String redisKey,String codePre){
 String nowDateStr = DateTimeUtil.getDateTimeStr(new Date(),DateTimeUtil.DATE_PATTERN_YYYYMMDD);
 Long value = 1L;
 RedisClient uceClient = null;
 Jedis jedis=null;
 try {
  uceClient = SpringContextUtil.getBean("uceClient");
  jedis = uceClient.getResource();
  value = jedis.incr(redisKey+nowDateStr);
  if(value != null){
  //如果值為1說明是第一次設(shè)置，那么設(shè)置key的存活時(shí)間為24小時(shí)
  if (value == 1){
   jedis.expire(redisKey+nowDateStr,(24*60*60+1000));
  }
  }else{
  //如指為空，重置緩存
  value = resetCodeRedis(redisKey);
  }
 }catch (Exception e){
  logger.error("獲取問題件編碼的自定義緩存異常：",e);
  value = resetCodeRedis(redisKey);
 }finally {
  if (uceClient != null){
  uceClient.returnResource(jedis);
  }
 }
 String problemCode = String.valueOf(value);
 for(int i = 0;i < 7;i++){
  if (problemCode.length() < 7){
  problemCode = "0"+problemCode;
  }else{
  break;
  }
 }
 return codePre + nowDateStr + problemCode;
 }

2、宕機(jī)時(shí)，調(diào)用的核心接口方法

/**
 * 重置編碼緩存
 * @param redisKey
 * @return
 */
 public static Long resetCodeRedis(String redisKey){
 String oldDateStr = null;
 String nowDateStr = DateTimeUtil.getDateTimeStr(new Date(),DateTimeUtil.DATE_PATTERN_YYYYMMDD);
 //編碼的最大字符串
 String databaseMaxCode = null;
 //問題件
 if(StringUtil.isNotEmpty(redisKey) && redisKey.equals(WO_PROBLEM_CODE_KEY)){
  CsWoProblemService csWoProblemService = SpringContextUtil.getBean("csWoProblemService");
  //獲取數(shù)據(jù)庫中的問題件的最大編碼
  databaseMaxCode = csWoProblemService.getMaxCode(WO_PROBLEM_CODE_PRE);
  //獲取編碼的日期部分
  if(StringUtil.isNotEmpty(databaseMaxCode)){
  oldDateStr = databaseMaxCode.substring(2,10);
  databaseMaxCode = databaseMaxCode.substring(10);
  }
 }else if(StringUtil.isNotEmpty(redisKey) && redisKey.equals(WO_CUST_SER_CODE_KEY)){
  CsWoCustSerService csWoCustSerService = SpringContextUtil.getBean("csWoCustSerService");
  //獲取數(shù)據(jù)庫中的客戶服務(wù)類工單的最大編碼
  databaseMaxCode = csWoCustSerService.getMaxCode("");
  //獲取編碼的日期部分
  if(StringUtil.isNotEmpty(databaseMaxCode)){
  oldDateStr = databaseMaxCode.substring(0,8);
  databaseMaxCode = databaseMaxCode.substring(8);
  }
 }
 Long value = getRedisValue(oldDateStr,nowDateStr,databaseMaxCode);
 RedisClient uceClient = null;
 Jedis jedisCluster = null;
 try {
  uceClient = SpringContextUtil.getBean("uceClient");
  jedisCluster = uceClient.getResource();
  boolean keyExist = jedisCluster.exists(redisKey + nowDateStr);
  // NX是不存在時(shí)才set， XX是存在時(shí)才set， EX是秒，PX是毫秒
  if (keyExist) {
  jedisCluster.del(redisKey + nowDateStr);
  }
  //設(shè)置緩存值，并設(shè)置為24小時(shí)后自動(dòng)失效
  jedisCluster.set(redisKey + nowDateStr, String.valueOf((value + 1)), "NX","EX", (24*60*60+1000));
 }catch (Exception e){
  logger.error((redisKey + "編碼重置異常："),e);
 }finally {
  if(uceClient != null){
  uceClient.returnResource(jedisCluster);
  }
 }
 return value + 1;
 }
 
 /**
 * 解析redis的值
 * @param oldDateStr
 * @param nowDateStr
 * @param databaseMaxCode
 * @return
 */
 public static Long getRedisValue(String oldDateStr,String nowDateStr,String databaseMaxCode){
 Long value = 0L;
 String firstCodeZero = "0";
 //如果日期相同，解析編碼數(shù)據(jù)存到緩存中
 if(StringUtil.isNotEmpty(oldDateStr) && StringUtil.isNotEmpty(nowDateStr) && oldDateStr.equals(nowDateStr) && StringUtil.isNotEmpty(databaseMaxCode)){
  for(int i = 0;i < 7;i++){
  String firstCode = databaseMaxCode.substring(0,1);
  if (StringUtil.isNotEmpty(firstCode) && firstCodeZero.equals(firstCode)){
   databaseMaxCode = databaseMaxCode.substring(1);
  }else{
   break;
  }
  }
  if (StringUtil.isNotEmpty(databaseMaxCode)){
  value = Long.parseLong(databaseMaxCode);
  }
 }
 return value;
 }

注意：

jedis使用后一定要close，否則jedis連接被占用的會(huì)越來越多，可用的連接數(shù)會(huì)越來越少，最終會(huì)導(dǎo)致redis宕機(jī)，最終項(xiàng)目宕機(jī)。

本項(xiàng)目是在finally中調(diào)用的自己封裝的returnResource()方法，此方法中會(huì)進(jìn)行關(guān)閉操作

補(bǔ)充知識(shí)：redis在高并發(fā)下導(dǎo)致鎖失效問題