概述

本文講述如何使用redis生成流水號医吊。本文是在Springboot中實現(xiàn)的。知道原理之后其他框架也可以輕松實現(xiàn)逮京。

原理介紹

本文主要是使用redis的incr方法進行自增補零卿堂。然后結(jié)合時間、隨機數(shù)懒棉、前綴組成唯一的流水號草描。

在這里插入圖片描述

下面是流水號的結(jié)構(gòu)。

在這里插入圖片描述

在文章的最后還是簡單介紹一下redis的持久化策严。防止redis宕機導(dǎo)致自增數(shù)重置穗慕。從而導(dǎo)致流水號重復(fù)。

流程圖

本次實現(xiàn)分為
1妻导、初始化流水號信息進入緩存
2逛绵、生成流水號

下面是分別的大致流程圖

1、初始化流水號信息進入緩存

在這里插入圖片描述

2倔韭、生成流水號

在這里插入圖片描述

代碼實現(xiàn)

1术浪、流水號實體類

用于存儲流水號信息

@Data
public class YuSnGenCode {
    // 流水號生成依賴的類，會使用類的名稱作為redis的key 
    private Class entity;
    // 前綴
    private String prefix;
    // 自增數(shù)位數(shù) 自增數(shù)達(dá)不到此位數(shù)自動補零
    private Integer num;

    public YuSnGenCode(Class entity, String prefix, Integer num) {
        this.entity = entity;
        this.prefix = prefix;
        this.num = num;
    }
}

2寿酌、初始化流水號進入緩存

在程序啟動之后初始化流水號

@Component
@Slf4j
public class YuSnGenStart implements ApplicationRunner {
    @Autowired
    YuSnGenUtil yuSnGenUtil;

    @Override
    public void run(ApplicationArguments args) throws Exception {
        log.info("=====開始初始化流水號=====");
        List<YuSnGenCode> yuSnGenCodeList = new ArrayList<>();
        yuSnGenCodeList.add(new YuSnGenCode(Account.class, "AC", 6));
        yuSnGenCodeList.add(new YuSnGenCode(Shop.class, "DP", 6));
        yuSnGenCodeList.add(new YuSnGenCode(Order.class, "OR", 6));
        yuSnGenCodeList.add(new YuSnGenCode(Dispatch.class, "DL", 6));
        yuSnGenCodeList.add(new YuSnGenCode(Refund.class, "RF", 6));
        yuSnGenCodeList.add(new YuSnGenCode(PayLog.class, "PL", 6));
        yuSnGenCodeList.add(new YuSnGenCode(Withdrawal.class, "WR", 6));
        yuSnGenCodeList.add(new YuSnGenCode(Aftermarket.class, "AS", 6));
        yuSnGenCodeList.add(new YuSnGenCode(Coupon.class, "CO", 6));
        yuSnGenCodeList.add(new YuSnGenCode(CouponGen.class, "CG", 10));
        yuSnGenCodeList.add(new YuSnGenCode(Draw.class, "DP", 6));
        yuSnGenUtil.init(yuSnGenCodeList);
        log.info("=====初始化流水號完畢=====");
    }
}

  public void init(List<YuSnGenCode> yuSnGenCodes) {
        // 流水號初始化入緩存
        for (YuSnGenCode yuSnGenCode : yuSnGenCodes) {
            String redisKey = yuSnGenCode.getEntity().getName();
            // 存入緩存 key：key：實體類名稱 value：流水號數(shù)據(jù)（前綴胰苏、自增數(shù)位數(shù)）
            redisTemplate.opsForValue().set(yuSnGenCode.getEntity().getName(), FastJsonUtils.toJsonStr(yuSnGenCode));
            log.info(yuSnGenCode.getEntity().getName() + "已初始化");

        }
    }

初始化之后的流水號如下圖所示

在這里插入圖片描述

3、生成流水號

   public Optional<String> gen(Class c) {
   // 獲取實體類的名稱
        String redisKey = c.getName();
        // 判斷是不是有初始化此實體類
        if (null != redisTemplate.opsForValue().get(redisKey)) {
        // 從緩存獲取流水號的生成信息
            YuSnGenCode yuSnGenCode = FastJsonUtils.toBean(redisTemplate.opsForValue().get(redisKey).toString(), YuSnGenCode.class);
         // 根據(jù)流水號的前綴判斷今天是否有生成過流水號
            if (redisTemplate.opsForValue().get(yuSnGenCode.getPrefix()) == null) {
                // 沒有則新建一個存入緩存 格式（key:OR  value:0）
                // 設(shè)置到第二天早上00：00：01過期
                Long todayTime = LocalDate.now().plusDays(1).atTime(0, 0, 0, 1).atOffset(ZoneOffset.ofHours(8)).toEpochSecond();
                Long nowTime = LocalDateTime.now().atOffset(ZoneOffset.ofHours(8)).toEpochSecond();
                Long expireTime = todayTime - nowTime;
                redisTemplate.opsForValue().set(yuSnGenCode.getPrefix(), 0, expireTime*1000, TimeUnit.MILLISECONDS);
            }
            // 進行自增操作
            StringBuffer sn = new StringBuffer();
            // 和前綴醇疼、時間硕并、隨機數(shù)進行組合
            sn.append(yuSnGenCode.getPrefix());
            String date = LocalDate.now().format(DateTimeFormatter.ofPattern("yyyyMMdd"));
            sn.append(date);
            Long num = redisTemplate.opsForValue().increment(yuSnGenCode.getPrefix());
            sn.append(addZero(String.valueOf(num), yuSnGenCode.getNum()));
            String random = String.valueOf(new Random().nextInt(1000));
            sn.append(random);
            // 生成最終的流水號返回
            return Optional.ofNullable(sn.toString());
        }
        return Optional.ofNullable(null);
    }

 // 自動補零
 public String addZero(String numStr, Integer maxNum) {
        int addNum = maxNum - numStr.length();
        StringBuffer rStr = new StringBuffer();
        for (int i = 0; i < addNum; i++) {
            rStr.append("0");
        }
        rStr.append(numStr);
        return rStr.toString();
    }

第一次生成流水號之后redis中會有一個以此流水號的前綴作為key的數(shù)據(jù)，后續(xù)直接進行自增僵腺。無需新增

在這里插入圖片描述

代碼測試

普通測試

   public Response test2() {
        return Response.success(yuSnGenUtil.gen(Order.class).get());
    }

結(jié)果如下

在這里插入圖片描述

并發(fā)測試

這里我們使用ab進行壓力并發(fā)測試
測試前我們流水號數(shù)據(jù)為0

在這里插入圖片描述

進行5000請求100并發(fā)的測試

在這里插入圖片描述

在這里插入圖片描述

redis 持久化

redis持久化指redis意外退出之后重啟仍然能夠恢復(fù)之前數(shù)據(jù)壶栋。我們這里使用redis持久化防止redis意外退出重啟導(dǎo)致流水號數(shù)據(jù)重置辰如，從而導(dǎo)致我們的流水號生成重復(fù)。

Redis 提供了不同級別的持久化方式:

RDB

RDB持久化方式能夠在指定的時間間隔能對你的數(shù)據(jù)進行快照存儲.

AOF

AOF持久化方式記錄每次對服務(wù)器寫的操作,當(dāng)服務(wù)器重啟的時候會重新執(zhí)行這些命令來恢復(fù)原始的數(shù)據(jù)

我們本次使用的是AOF的方式

在這里插入圖片描述

在這里插入圖片描述

注意

因為AOF的默認(rèn)備份方式有三種

1豌蟋、always每次有新命令追加到 AOF 文件時就執(zhí)行一次 fsync ：非常慢，也非常安全
2桑滩、everysec每秒 fsync 一次：足夠快（和使用 RDB 持久化差不多）梧疲，并且在故障時只會丟失 1 秒鐘的數(shù)據(jù)。
3、no從不 fsync ：將數(shù)據(jù)交給操作系統(tǒng)來處理幌氮。更快缭受，也更不安全的選擇。
==而我們采用的是第二種该互。也是AOF默認(rèn)的的米者。但是這樣故障時可能會損失1s的數(shù)據(jù)，所以如果對數(shù)據(jù)要求十分嚴(yán)格的同學(xué)可以采用第一種方式只需要修改redis.config文件的appendfsync屬性即可宇智。==

在這里插入圖片描述

以上就是今天介紹的利用redis的incr自增方法編寫生成流水號蔓搞。如果有什么問題歡迎評論區(qū)指出。謝謝??