使用Redis incr解決併發問題的操作

阿新 • • 發佈：2020-11-24

專案背景：

1、新增問題件工單，工單中有工單編碼欄位，工單編碼欄位的規則為 “WT”+yyyyMMdd+0000001。

2、每天的工單生成量是30W，所以會存在併發問題

解決思路：

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

2、將工單編碼存到快取中（redis）,其值只存“WT”+yyyyMMdd後面的數字部分；

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

3、每次生成工單編碼時，先呼叫redis的incr方法，使其在原來編碼的基礎上加1，並返回結果

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

需要設定此key的生命週期為24小時

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

6、如果redis宕機，或者key被刪除，呼叫指定的介面，介面會去資料庫查詢今天最大的工單編碼，

解析後，將其存在redis中，後面的工單編碼再在此基礎上自增

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、宕機時，呼叫的核心介面方法

/**
 * 重置編碼快取
 * @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");
  //獲取資料庫中的問題件的最大編碼
  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");
  //獲取資料庫中的客戶服務類工單的最大編碼
  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";
 //如果日期相同，解析編碼資料存到快取中
 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連線被佔用的會越來越多，可用的連線數會越來越少，最終會導致redis宕機，最終專案宕機。

本專案是在finally中呼叫的自己封裝的returnResource()方法，此方法中會進行關閉操作

補充知識：redis在高併發下導致鎖失效問題

使用Redis incr解決併發問題的操作