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

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

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

項目背景：

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

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

解決思路：

1、首先樂觀的認為redis不會宕機，對應的緩存不會被清除（除非人為操作，人為操作會有獨立的補救辦法）

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

對應的key為：key標識+yyyyMMdd，即每天一個key

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

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

需要設置此key的生命周期為24小時

5、每個key只會存活24小時

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

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

7、請自行配置redisClient客戶端并實例化

代碼：

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說明是第一次設置，那么設置key的存活時間為24小時
  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、宕機時，調(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ù)庫中的客戶服務類工單的最大編碼
  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是不存在時才set， XX是存在時才set， EX是秒，PX是毫秒
  if (keyExist) {
  jedisCluster.del(redisKey + nowDateStr);
  }
  //設置緩存值，并設置為24小時后自動失效
  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連接被占用的會越來越多，可用的連接數(shù)會越來越少，最終會導致redis宕機，最終項目宕機。

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

補充知識：redis在高并發(fā)下導致鎖失效問題