1. 基于Redis实现的发号机

使用RedisTemplate操作Redis，基于Redis的integer类型，使用自增方法来获取对应的流水号。

1.1 Redis相关操作封装

1.1.1 操作接口

  1. public interface RedisDao {
  2.     /**
  3.     * 指定key是否存在
  4.     *
  5.     * @param key
  6.     * @return
  7.     */
  8.     Boolean isExist(String key);
  10.     /**
  11.     * 自增,+1,返回增长后的值
  12.     *
  13.     * @param key
  14.     * @return
  15.     */
  16.     long incr(String key);
  18.     /**
  19.     * 配置过期时间
  20.     *
  21.     * @param key
  22.     */
  23.     void expireKey(String key);
  24. }

1.1.2 操作接口实现

  1. @Service
  2. public class RedisDaoImpl implements RedisDao {
  4.     @Autowired
  5.     private RedisTemplate redisTemplate;
  7.     @Override
  8.     public Boolean isExist(String key) {
  9.         return redisTemplate.hasKey(key);
  10.     }
  12.     /**
  13.     * 自增,+1,返回增长后的值
  14.     *
  15.     * @param key
  16.     * @return
  17.     */
  18.     @Override
  19.     public long incr(String key) {
  20.         return redisTemplate.opsForValue().increment(key);
  21.     }
  23.     /**
  24.     * 设置过期时间
  25.     *
  26.     * @param key
  27.     */
  28.     @Override
  29.     public void expireKey(String key) {
  30.         redisTemplate.expire(key, 36, TimeUnit.HOURS);
  31.     }
  32. }

1.2 相关工具

1.2.1 补位工具

通过此工具来根据业务需要，填充流水号位数，未占用的位进行补“0”操作。

  1. @Component
  2. public class ApplyCodeUtil {
  4.     public ApplyCodeUtil() {
  5.     }
  7.     @Value("${applyCode.length}")
  8.     int DEFAULT_LENGTH;
  10.     /**
  11.      * 获得 DEFAULT_LENGTH 位的序列号,长度不足 DEFAULT_LENGTH 位,前面补0
  12.      *
  13.      * @param seq
  14.      * @return
  15.      */
  16.     public String getSequence(long seq) {
  17.         String str = String.valueOf(seq);
  18.         int len = str.length();
  19.         if (len >= DEFAULT_LENGTH) {// 取决于业务规模,目前要求设置为3位流水号
  20.             return str;
  21.         }
  22.         int rest = DEFAULT_LENGTH - len;
  23.         StringBuilder sb = new StringBuilder();
  24.         for (int i = 0; i < rest; i++) {
  25.             sb.append('0');
  26.         }
  27.         sb.append(str);
  28.         return sb.toString();
  29.     }
  31. }

可以通过在配置文件中对applyCode.length进行配置，来决定流水号占位长度。

1.2.2 日期处理工具

  1. import cn.hutool.core.date.DateUtil;
  3. public class TimeUtil {
  4.     /**
  5.      * 获取今日日期
  6.      *
  7.      * @return
  8.      */
  9.     public static String getToday() {
  10.         return DateUtil.format(DateUtil.date(), "yyyyMMdd");
  11.     }
  12. }

1.3 流水号生成

1.3.1 生成接口

  1. public interface SerialNumberService {
  2.     /** 
  3.       * redis中的业务前缀key 
  4.       */
  5.     String SERIAL_NUMBER = "bussiness:applyCode:";
  7.     /**
  8.      * 根据两位业务码字符串,生成一个流水号,格式按照:<br/>
  9.      * yyyyMMdd{自增序列号}
  10.      * 两位,00-99
  11.      * @return 序列号
  12.      * @throws LJBaseException
  13.      */
  14.     String generate() throws LJBaseException;
  15. }

1.3.2 生成接口实现

  1. @Service
  2. public class SerialNumberServiceImpl implements SerialNumberService {
  3.     @Autowired
  4.     private RedisDao redisDao;
  6.     @Autowired
  7.     private ApplyCodeUtil applyCodeUtil;
  9.     @Override
  10.     public String generate() throws LJBaseException {
  11.         /** 获取今天的日期:yyyyMMdd */
  12.         String date = TimeUtil.getToday();
  13.         /** 构造redis的key */
  14.         String key = SERIAL_NUMBER + date;
  15.         /** 自增 */
  16.         Boolean exist = redisDao.isExist(key);
  17.         long sequence = redisDao.incr(key);
  18.         if (exist == null || !exist) {
  19.             redisDao.expireKey(key);
  20.         }
  21.         String seq = applyCodeUtil.getSequence(sequence);
  22.         StringBuilder sb = new StringBuilder();
  23.         sb.append(date).append(seq);
  24.         String serial = sb.toString();
  25.         return serial;
  26.     }
  27. }
  1. <br />至此，我们的简单流水号生成器就完成了，调用`SerialNumberService`中的`generate()`方法即可生成对应的流水号。