jlzzjlzz亚洲乱熟在线播放

系統城裝機大師 - 唯一官網:www.farandoo.com!

當前位置:首頁 > 數據庫 > Redis > 詳細頁面

腳本之家分享Redis分布式緩存:微信搶紅包解決方案

時間:2021-12-10來源:www.farandoo.com作者:電腦系統城

一、場景分析

微信搶紅包已經在我們生活中很常見的場景了,特別是年底公司開年會和春節2個時間段,長輩領導都發紅包,手都點抽筋了,也沒搶到多少。

在這段時間里,對于單個群里的單個紅包,qps也是上千的,對于整個微信紅包系統,高峰的并發量是上億的。

高峰的搶紅包有3大特點:

  1. 包紅包的人多:也就是創建紅包的任務比較多,即紅包系統是以單個紅包的任務來區分,特點就是在高峰期紅包任務多。
  2. 搶紅包的人更多:當你發紅包出去后,是幾十甚至幾百人來搶你的紅包,即單紅包的請求并發量大。
  3. 低延遲:當你發現紅包時,要越快搶到越開心,所以要求搶紅包的響應速度要快,一般1秒響應。

 

二、技術方案

1.包紅包

先把金額拆解為小金額的紅包,例如 總金額1000元,發10個,用戶在點保存的時候,就自動拆解為10個隨機小紅包。

這里的存儲就是個難題,多個金額(例如10個小金額的紅包)如何存儲?

2.搶紅包

高并發的搶紅包時核心的關鍵技術,就是控制各個小紅包的操作的原子性。

例如 10個紅包在100人的群里被搶,10個紅包被搶走一個的同時要紅包的庫存減1,即剩下19個。在整個過程中搶走一個和紅包庫存減1個是一個原子操作。

list的pop操作彈出一個元素的同時會自動從隊列里面剔除該元素,它是一個原子性操作。

 

三、案例實戰

包紅包

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
/**
 * 包紅包的接口
 */
@GetMapping(value = "/set")
public long setRedpacket(int total, int count) {
    //拆解紅包
    Integer[] packet= this.splitRedPacket(total,count);
    //為紅包生成全局唯一id
    long n=this.incrementId();
    //采用list存儲紅包
    String key=RED_PACKET_KEY+n;
    this.redisTemplate.opsForList().leftPushAll(key,packet);
    //設置3天過期
    this.redisTemplate.expire(key,3, TimeUnit.DAYS);
    log.info("拆解紅包{}={}",key,packet);
    return n;
}

拆解紅包

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
/**
 * 拆解紅包
 * 1.紅包金額要被全部拆解完
 * 2.紅包金額不能差太離譜
 * total 紅包金額
 * count 紅包數量
 */
public  Integer[] splitRedPacket(int total, int count) {
    int use = 0;
    Integer[] array = new Integer[count];
    Random random = new Random();
    for (int i = 0; i < count; i++) {
        if (i == count - 1)
            array[i] = total - use;
        else {
            // 紅包隨機金額浮動系數
            int avg = (total - use) * 2 / (count - i);
            array[i] = 1 + random.nextInt(avg - 1);
        }
        use = use + array[i];
    }
    return array;
}

搶紅包 

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
    /**
     * 搶紅包接口
     */
    @GetMapping(value = "/rob")
    public int rob(long redid,long userid) {
        //第一步:驗證該用戶是否搶過
        Object packet=this.redisTemplate.opsForHash().get(RED_PACKET_CONSUME_KEY+redid,String.valueOf(userid));
        if(packet==null){
            //第二步:從list隊列,彈出一個紅包
            Object obj=this.redisTemplate.opsForList().leftPop(RED_PACKET_KEY+redid);
            if(obj!=null){
                //第三步:搶到紅包存起來
                this.redisTemplate.opsForHash().put(RED_PACKET_CONSUME_KEY+redid,String.valueOf(userid),obj);
                log.info("用戶={}搶到{}",userid,obj);
                //TODO 異步把數據落地到數據庫上
                 
                return (Integer) obj;
            }
            //-1 代表搶完
            return -1;
        }
        //-2 代表已搶
        return -2;
    }
<font face="Arial, Verdana, sans-serif"><span style="white-space: normal;"> </span></font>

到此這篇關于Redis分布式緩存:微信搶紅包解決方案的文章就介紹到這了,

分享到:

相關信息

系統教程欄目

欄目熱門教程

人氣教程排行

站長推薦

熱門系統下載