1. CREATE TABLE `crl_serial_number_rule` (
    2.   `id` bigint NOT NULL AUTO_INCREMENT COMMENT '主键',
    3.   `rule_code` varchar(30)  NOT NULL COMMENT '规则编码',
    4.   `rule_desc` varchar(60)  NOT NULL COMMENT '规则描述',
    5.   `prefix` varchar(10)  NULL COMMENT '前缀',
    6.   `date_formatter` varchar(20) NULL COMMENT '日期格式',
    7.   `random_mark` varchar(10)  NOT NULL COMMENT '随机位',
    8.   `number_type` varchar(10)  NOT NULL COMMENT '序号类型，numberTypeEnum:RANDOM 随机;ORDER 顺序',
    9.   `number_length` varchar(2)  NOT NULL COMMENT '序号位数',  
    10.   `number_start` varchar(10)  DEFAULT NULL COMMENT '序号起始位',
    11.   `number_end` varchar(10)  DEFAULT NULL COMMENT '序号结束位',
    12.   `current_number` varchar(10)  DEFAULT NULL COMMENT '当前序号',
    13.   `created_date` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
    14.   `modified_date` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
    15.   PRIMARY KEY (`id`),
    16.   UNIQUE INDEX `uniq_idx_rule_code` (`rule_code`)
    17. ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT='流水号规则表';

    1、首先获取一次缓存中的序列号，不要直接加分布式锁，毕竟遇到查不到的情况约1000分之一
    2、流水号大约1秒多生成，建议超时时长设置为2-3秒，重试次数可以多次，每次间隔500ms即可。间隔过大，会导致撞锁。间隔太小会导致无用的重试次数太多。
    3、一次操作时间《加锁的重试次数间隔时间<两次操作时间。理由是：若重试的次数间隔时间比一次操作时间短，则会导致加锁失败。若大于两次操作时间，则造成浪费。
    4、入队的方式，除了执行一个个命令外，rpush是支持把数组一次性存入缓存的

    1. import org.apache.commons.lang3.StringUtils;
    2. import org.springframework.stereotype.Service;
    3. import javax.annotation.Resource;
    4. import java.text.SimpleDateFormat;
    5. import java.util.Date;
    6. import java.util.Random;
    7. import java.util.concurrent.TimeUnit;
    9. /**
    10.  * @description:
    11.  * @author: wzh
    12.  * @date: 2019-01-21 上午10:44
    13.  */
    14. @Service("dubheSerialNumberCenterServiceImpl")
    15. public class DubheSerialNumberCenterServiceImpl implements DubheSerialNumberCenterService {
    16.     private static final Logger logger = LoggerFactory.getLogger(DubheSerialNumberCenterServiceImpl.class);
    18.     /*超时时间：代码中与TimeUnit.SECONDS共用*/
    19.     private static long expireTime = 3;
    20.     /*重试次数*/
    21.     private static int retryCount = 10;
    22.     @Resource
    23.     private DubheSerialNumberRuleService dubheSerialNumberRuleService;
    25.     @Resource
    26.     private DistributedLocker distributedLocker;
    28.     @Resource
    29.     private R2mClusterClient r2mClusterClient;
    31.     @Override
    32.     public CommonResponse<String> generateSerialNumber(CommonRequest<SerialNumberRequest> req) {
    33.         String methodDesc = "DubheSerialNumberCenterServiceImpl|generateSerialNumber|按规则编码生成流水号|";
    34.         SerialNumberRequest serialNumberRequest = req.getRequestData();
    35.         String ruleCode = serialNumberRequest.getRuleCode();
    36.         StringBuilder crlSerialNumber = new StringBuilder();
    37.         logger.info(methodDesc + "查询流水号规则开始" + "|ruleCode:" + ruleCode);
    38.         DubheSerialNumberRule dubheSerialNumberRule = dubheSerialNumberRuleService.getSerialNumberRuleByParams(serialNumberRequest.getRuleCode());
    39.         if (null == dubheSerialNumberRule) {
    40.             logger.warn(methodDesc + "查询流水号规则为空，请检查流水号规则配置" + "|ruleCode:" + ruleCode);
    41.             crlSerialNumber.append("ERR").append(new SimpleDateFormat(DateFormatterEnum.yyMMddHHmmss.getCode()).format(new Date())).append(String.valueOf(new Random().nextInt(9))).append(new Random().nextInt(getMaxValueString(8))).toString();
    42.             return CommonResponse.buildResponse(req, RespCodeEnum.SERIAL_NO_RULE_NOT_EXIST, crlSerialNumber.toString());
    43.         }
    44.         logger.info(methodDesc +"查询流水号规则结束" + "|ruleCode:" + ruleCode + "|dubheSerialNumberRule:" + dubheSerialNumberRule);
    46.         String dateFormatter = dubheSerialNumberRule.getDateFormatter();
    48.         String dateString = "";
    49.         if (StringUtils.isNotBlank(dateFormatter)) {
    50.             dateString = new SimpleDateFormat(dateFormatter).format(new Date());
    51.         }
    52.         String randomMark = "";
    53.         if (0<dubheSerialNumberRule.getRandomMark()) {
    54.             int maxNumber=getMaxValueString(dubheSerialNumberRule.getRandomMark());
    55.             randomMark = format(dubheSerialNumberRule.getRandomMark(),new Random().nextInt(maxNumber));
    56.         }
    58.         int random = new Random().nextInt(getMaxValueString(dubheSerialNumberRule.getNumberLength()));
    59.         if (NumberTypeEnum.RANDOM.getCode().equals(dubheSerialNumberRule.getNumberType())) {
    60.             crlSerialNumber.append(dubheSerialNumberRule.getPrefix()).append(dateString).append(randomMark).append(format(dubheSerialNumberRule.getNumberLength(), random)).toString();
    61.             return CommonResponse.buildResponse(req, RespCodeEnum.SUCCESS, crlSerialNumber.toString());
    62.         } else if (NumberTypeEnum.ORDER.getCode().equals(dubheSerialNumberRule.getNumberType())) {
    63.             /*拼接前缀+时间长度+随机位数*/
    64.             crlSerialNumber.append(dubheSerialNumberRule.getPrefix()).append(dateString).append(randomMark);
    66.             int increase = dubheSerialNumberRule.getQueueNumber();
    68.             String cacheKey=dubheSerialNumberRule.getPrefix() + dateFormatter + dubheSerialNumberRule.getNumberLength();
    70.             String redisKey="";
    71.             try {
    73.                 logger.info(methodDesc + "|获取当前key的value值开始" + "|ruleCode:" + ruleCode + "|cacheKey:" + cacheKey);
    74.                 String cacheCurrentValue = r2mClusterClient.rpop(cacheKey);
    75.                 if(StringUtils.isNotBlank(cacheCurrentValue)){
    76.                     logger.info(methodDesc + "|获取当前key的value值|出参|cacheCurrentValue：",cacheCurrentValue,"|入参|cacheKey:" + cacheKey + "|ruleCode:" + ruleCode);
    77.                     crlSerialNumber.append(format(dubheSerialNumberRule.getNumberLength(), Integer.parseInt(cacheCurrentValue))).toString();
    78.                     logger.info(methodDesc + "|返回流水号|出参|crlSerialNumber：",crlSerialNumber.toString(),"|入参|ruleCode:" + ruleCode);
    79.                     return CommonResponse.buildResponse(req, RespCodeEnum.SUCCESS, crlSerialNumber.toString());
    80.                 }
    81.                 logger.info(methodDesc + "|获取当前key的value值不存在|出参|cacheCurrentValue：",cacheCurrentValue,"|入参|cacheKey:" + cacheKey + "|ruleCode:" + ruleCode);
    83.                 /*1 未能从缓存查询,先加锁*/
    84.                 logger.info(methodDesc + "|加分布式锁开始" + "|ruleCode:" + ruleCode);
    85.                 CommonResponse<String> crlCommonResponse = distributedLocker.lockRetry(ruleCode, expireTime, TimeUnit.SECONDS, retryCount);
    86.                 if (!crlCommonResponse.isSuccess()) {
    87.                     throw new BizException(RespCodeEnum.SERIAL_NO_LOCK_FAIL);
    88.                 }
    89.                 redisKey=crlCommonResponse.getResponseData();
    90.                 logger.info(methodDesc + "|加分布式锁结束" + "|ruleCode:" + ruleCode + "|crlCommonResponse:" + crlCommonResponse);
    91.                 /*2 再获取一次缓存*/
    92.                 logger.info(methodDesc + "|获取当前key的value值开始" + "|ruleCode:" + ruleCode + "|cacheKey:" + cacheKey);
    93.                 cacheCurrentValue = r2mClusterClient.rpop(cacheKey);
    94.                 if (StringUtils.isNotBlank(cacheCurrentValue)) {
    95.                     logger.info(methodDesc + "|获取当前key的value值|出参|cacheCurrentValue：", cacheCurrentValue, "|入参|cacheKey:" + cacheKey + "|ruleCode:" + ruleCode);
    96.                     crlSerialNumber.append(format(dubheSerialNumberRule.getNumberLength(), Integer.parseInt(cacheCurrentValue))).toString();
    97.                     logger.info(methodDesc + "|返回流水号|出参|crlSerialNumber：", crlSerialNumber.toString(), "|入参|ruleCode:" + ruleCode);
    98.                     return CommonResponse.buildResponse(req, RespCodeEnum.SUCCESS, crlSerialNumber.toString());
    99.                 }
    100.                 logger.info(methodDesc + "|获取当前key的value值不存在|出参|cacheCurrentValue：",cacheCurrentValue,"|入参|cacheKey:" + cacheKey + "|ruleCode:" + ruleCode);
    101.                 /*3 处理起始值与结束值*/
    103.                 int numberStart;
    104.                 int numberEnd;
    105.                 if (StringUtils.isBlank(dubheSerialNumberRule.getCurrentNumber())) {
    106.                     logger.info(methodDesc + "|当前缓存值不存在|数据库当前值不存在|ruleCode:" + ruleCode + "|prefix：" + dubheSerialNumberRule.getPrefix() + "|length:" + dubheSerialNumberRule.getNumberLength() + "|cacheCurrentValue:" + cacheCurrentValue + "|currentNumber:" + dubheSerialNumberRule.getCurrentNumber());
    107.                     /*3.1 数据库当前值不存在处理*/
    108.                     numberStart = dubheSerialNumberRule.getNumberStart();
    109.                     numberEnd = numberStart + increase;
    110.                     /*3.1.1 结束值处理*/
    111.                     if (numberEnd > dubheSerialNumberRule.getNumberEnd()) {
    112.                         logger.info(methodDesc + "|当前缓存值不存在|流水号限制了结束值，比队列结束值小，设置为队列结束值|ruleCode:" + ruleCode + "|prefix：" + dubheSerialNumberRule.getPrefix() + "|length:" + dubheSerialNumberRule.getNumberLength() + "|cacheCurrentValue:" + cacheCurrentValue + "|currentNumber:" + dubheSerialNumberRule.getCurrentNumber());
    113.                         numberEnd = dubheSerialNumberRule.getNumberEnd();
    114.                     } else {
    115.                         logger.info(methodDesc + "|当前缓存值不存在|流水号未限制结束值，比队列结束值大，设置队列起始值+99为队列结束值|ruleCode:" + ruleCode + "|prefix：" + dubheSerialNumberRule.getPrefix() + "|length:" + dubheSerialNumberRule.getNumberLength() + "|cacheCurrentValue:" + cacheCurrentValue + "|currentNumber:" + dubheSerialNumberRule.getCurrentNumber());
    116.                     }
    118.                 } else {
    119.                     logger.info(methodDesc + "|当前缓存值不存在|数据库当前值存在|ruleCode:" + "|prefix：" + dubheSerialNumberRule.getPrefix() + "|length:" + dubheSerialNumberRule.getNumberLength() + "|cacheCurrentValue:" + cacheCurrentValue + "|currentNumber:" + dubheSerialNumberRule.getCurrentNumber());
    120.                     Integer currentNumber = Integer.valueOf(dubheSerialNumberRule.getCurrentNumber());
    121.                     /*3.2 数据库当前值存在处理*/
    122.                     numberStart = 1 + currentNumber;
    123.                     numberEnd = 1 + currentNumber + increase;
    125.                     /*3.2.1 当前值与流水号起始值*/
    126.                     if (currentNumber < dubheSerialNumberRule.getNumberStart()) {
    127.                         logger.info(methodDesc + "|当前缓存值不存在|配置了流水号区间|可能由于修改了规则导致数据库当前值比左区间小,缓存按起始值set|ruleCode:" + ruleCode + "|prefix：" + dubheSerialNumberRule.getPrefix() + "|length:" + dubheSerialNumberRule.getNumberLength() + "|currentNumber:" + currentNumber + "|numberStart:" + dubheSerialNumberRule.getNumberStart());
    128.                         numberStart = dubheSerialNumberRule.getNumberStart();
    129.                         numberEnd = numberStart + increase;
    130.                     }
    131.                     /*3.2.2 当前值与流水号结束值*/
    132.                     else if (currentNumber >= dubheSerialNumberRule.getNumberEnd()) {
    133.                         logger.info(methodDesc + "|当前缓存值不存在|流水号限制了结束值|数据库当前值达到位数最大值，设置1为队列起始值|ruleCode:" + ruleCode + "|prefix：" + dubheSerialNumberRule.getPrefix() + "|length:" + dubheSerialNumberRule.getNumberLength() + "|currentNumber:" + currentNumber);
    134.                         numberStart = dubheSerialNumberRule.getNumberStart();
    135.                         numberEnd = numberStart + increase;
    136.                     }
    138.                     /*3.2.3 队列结束值与流水号结束值*/
    139.                     if (numberEnd > dubheSerialNumberRule.getNumberEnd()) {
    140.                         logger.info(methodDesc + "|当前缓存值不存在|配置了流水号区间，比队列结束值小，则设置为队列结束值|ruleCode:" + ruleCode + "|prefix：" + dubheSerialNumberRule.getPrefix() + "|length:" + dubheSerialNumberRule.getNumberLength() + "|cacheCurrentValue:" + cacheCurrentValue + "|currentNumber:" + dubheSerialNumberRule.getCurrentNumber());
    141.                         numberEnd = dubheSerialNumberRule.getNumberEnd();
    142.                     } else {
    143.                         logger.info(methodDesc + "|当前缓存值不存在|配置了流水号区间，比队列结束值大，设置队列起始值+99为队列结束值|ruleCode:" + ruleCode + "|prefix：" + dubheSerialNumberRule.getPrefix() + "|length:" + dubheSerialNumberRule.getNumberLength() + "|cacheCurrentValue:" + cacheCurrentValue + "|currentNumber:" + dubheSerialNumberRule.getCurrentNumber());
    144.                     }
    145.                 }
    146.                 /*4 入队列并更新数据库*/
    147.                 cacheCurrentValue = updateAndPushAndPop(dubheSerialNumberRule, cacheKey, cacheCurrentValue, numberStart, numberEnd);
    148.                 crlSerialNumber.append(format(dubheSerialNumberRule.getNumberLength(), Integer.parseInt(cacheCurrentValue))).toString();
    149.                 /*5 返回流水号*/
    150.                 logger.info(methodDesc + "|返回流水号|出参|crlSerialNumber：", crlSerialNumber.toString(), "|入参|ruleCode:" + ruleCode);
    151.                 return CommonResponse.buildResponse(req, RespCodeEnum.SUCCESS, crlSerialNumber.toString());
    153.             } catch (Exception e) {
    154.                 logger.error(methodDesc + "异常|入参|ruleCode:" + ruleCode,"|exception:",e);
    155.                 crlSerialNumber.append(dubheSerialNumberRule.getPrefix()).append(dateString).append(9).append(format(dubheSerialNumberRule.getNumberLength(),random)).toString();
    156.                 return CommonResponse.buildResponse(req, RespCodeEnum.SUCCESS, crlSerialNumber.toString());
    157.             }finally {
    158.                 if(StringUtils.isNotBlank(redisKey)){
    159.                     logger.info(methodDesc + "|释放分布式锁开始" + "|ruleCode:" + ruleCode + "|redisKey:" + redisKey);
    160.                     distributedLocker.unlock(ruleCode, redisKey);
    161.                     logger.info(methodDesc + "|释放分布式锁结束" + "|ruleCode:" + ruleCode + "|redisKey:" + redisKey);
    162.                 }
    163.             }
    164.         }
    165.         return CommonResponse.buildResponse(req, RespCodeEnum.SUCCESS, crlSerialNumber.toString());
    166.     }
    168.     /**
    169.      * String.format效率较低
    170.      * @param length
    171.      * @param data
    172.      * @return
    173.      */
    174.     private String format(int length, int data) {
    175.         char[] result = new char[length];
    176.         for(int i=result.length-1;i>=0;i--) {
    177.             result[i] = (char) (data % 10 + 48);
    178.             data/=10;
    179.         }
    180.         return new String(result);
    181.     }
    183.     /**
    184.      * 更新数据库当前值、队列入队处理、队列出队获取
    185.      *
    186.      * @param dubheSerialNumberRule
    187.      * @param cacheKey
    188.      * @param cacheCurrentValue
    189.      * @param numberStart
    190.      * @param numberEnd
    191.      * @return
    192.      * @throws Exception
    193.      */
    194.     private String updateAndPushAndPop(DubheSerialNumberRule dubheSerialNumberRule, String cacheKey, String cacheCurrentValue, Integer numberStart, Integer numberEnd) throws Exception {
    195.         String methodDesc = "按规则编码生成流水号";
    196.         /*2.1 更新数据库当前值为队列结束值*/
    197.         logger.info("CrlSerialNumberRuleServiceImpl|getSerialNumberRuleByRuleCode|" + methodDesc + "|更新流水号规则中当前值开始" + "|ruleCode:" + dubheSerialNumberRule.getRuleCode() + "|numberEnd:" + numberEnd);
    198.         int updateNum = dubheSerialNumberRuleService.updateCurrentNumberByParams(String.valueOf(numberEnd), dubheSerialNumberRule.getRuleCode());
    199.         if (updateNum <= 0) {
    200.             throw new Exception(methodDesc + "更新流水号规则中当前值失败");
    201.         }
    202.         logger.info("CrlSerialNumberRuleServiceImpl|getSerialNumberRuleByRuleCode|" + methodDesc + "|更新流水号规则中当前值结束" + "|ruleCode:" + dubheSerialNumberRule.getRuleCode() + "|numberEnd:" + numberEnd + "|updateNum:" + updateNum);
    204.         /*2.2 队列入队开始*/
    205.         logger.info("CrlSerialNumberRuleServiceImpl|getSerialNumberRuleByRuleCode|" + methodDesc + "|当前缓存值不存在|流水号限制了起始值，入队队列开始|ruleCode:" + dubheSerialNumberRule.getRuleCode() + "|prefix：" + dubheSerialNumberRule.getPrefix() + "|length:" + dubheSerialNumberRule.getNumberLength() + "|cacheCurrentValue:" + cacheCurrentValue + "|currentNumber:" + dubheSerialNumberRule.getCurrentNumber() + "|numberStart:" + numberStart + "|numberEnd:" + numberEnd);
    206.         String[] info = new String[numberEnd - numberStart];
    207.         logger.info("缓存入队：start{},end{}",numberStart+1,numberEnd);
    208.         for (int i = 0; i < info.length; i++) {
    209.             info[i] =format(dubheSerialNumberRule.getNumberLength(), i + numberStart + 1);
    210.         }
    211.         r2mClusterClient.lpush(cacheKey, info);
    212.         logger.info("CrlSerialNumberRuleServiceImpl|getSerialNumberRuleByRuleCode|" + methodDesc + "|当前缓存值不存在|流水号限制了起始值，入队队列结束|ruleCode:" + dubheSerialNumberRule.getRuleCode() + "|prefix：" + dubheSerialNumberRule.getPrefix() + "|length:" + dubheSerialNumberRule.getNumberLength() + "|cacheCurrentValue:" + cacheCurrentValue + "|currentNumber:" + dubheSerialNumberRule.getCurrentNumber() + "|numberStart:" + numberStart + "|numberEnd:" + numberEnd);
    214.         /*2.3 起始值直接返回*/
    215.         if (StringUtils.isBlank(cacheCurrentValue)) {
    216.             return String.valueOf(numberStart);
    217.         }
    218.         return cacheCurrentValue;
    219.     }
    221.     /**
    222.      * 字符串最大值
    223.      *
    224.      * @param length
    225.      * @return
    226.      */
    227.     private int getMaxValueString(int length) {
    228.         String value = "";
    229.         for (int i = 0; i < length; i++) {
    230.             value = "9" + value;
    231.         }
    232.         return Integer.parseInt(value);
    233.     }
    234. }