在线观看www成人影院-在线观看www日本免费网站-在线观看www视频-在线观看操-欧美18在线-欧美1级

0
  • 聊天消息
  • 系統消息
  • 評論與回復
登錄后你可以
  • 下載海量資料
  • 學習在線課程
  • 觀看技術視頻
  • 寫文章/發帖/加入社區
會員中心
創作中心

完善資料讓更多小伙伴認識你,還能領取20積分哦,立即完善>

3天內不再提示

Redis搶紅包項目

數據分析與開發 ? 來源:數據分析與開發 ? 作者:數據分析與開發 ? 2020-09-24 15:09 ? 次閱讀

業務流程分析

功能拆解


新建紅包

在 DB、Redis 分別新增一條記錄

搶紅包(并發)

「使用技術」

Redis 中數據類型的 String 特性的原子遞減(DECR key)和減少指定值(DECRBY key decrement)

「業務」

請求 Redis ,當剩余紅包個數大于 0,紅包個數原子遞減,隨機獲取紅包

計算金額,當最后一個紅包時,最后一個紅包金額=總金額-總已搶紅包金額

更新數據庫

「查詢紅包記錄」

查詢 DB 即可

數據庫設計

紅包流水表

CREATE TABLE `red_packet_info` ( `id` int(11) NOT NULL AUTO_INCREMENT, `red_packet_id` bigint(11) NOT NULL DEFAULT 0 COMMENT '紅包id,采? timestamp+5位隨機數', `total_amount` int(11) NOT NULL DEFAULT 0 COMMENT '紅包總?額,單位分', `total_packet` int(11) NOT NULL DEFAULT 0 COMMENT '紅包總個數', `remaining_amount` int(11) NOT NULL DEFAULT 0 COMMENT '剩余紅包?額,單位 分', `remaining_packet` int(11) NOT NULL DEFAULT 0 COMMENT '剩余紅包個數', `uid` int(20) NOT NULL DEFAULT 0 COMMENT '新建紅包?戶的?戶標識', `create_time` timestamp COMMENT '創建時間', `update_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新時間', PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8mb4 COMMENT='紅包信息 表,新建?個紅包插??條記錄';

紅包記錄表

CREATE TABLE `red_packet_record` ( `id` int(11) NOT NULL AUTO_INCREMENT, `amount` int(11) NOT NULL DEFAULT '0' COMMENT '搶到紅包的?額', `nick_name` varchar(32) NOT NULL DEFAULT '0' COMMENT '搶到紅包的?戶的?戶 名', `img_url` varchar(255) NOT NULL DEFAULT '0' COMMENT '搶到紅包的?戶的頭像', `uid` int(20) NOT NULL DEFAULT '0' COMMENT '搶到紅包?戶的?戶標識', `red_packet_id` bigint(11) NOT NULL DEFAULT '0' COMMENT '紅包id,采? timestamp+5位隨機數', `create_time` timestamp COMMENT '創建時間', `update_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新時間', PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8mb4 COMMENT='搶紅包記 錄表,搶?個紅包插??條記錄';

發紅包 API

發紅包接口開發

新增一條紅包記錄

往 mysql 里面添加一條紅包記錄

往 redis 里面添加一條紅包數量記錄

往redis里面添加一條紅包金額記錄

?

往db中就單純存入一條記錄,Service層和Mapper層,就簡單的一條sql語句,主要是提供思路,下面會附案例源碼,不要慌

?

搶紅包 API

搶紅包功能屬于原子減操作

當大小小于 0 時原子減失敗

當紅包個數為0時,后面進來的用戶全部搶紅包失敗,并不會進入拆紅包環節

搶紅包功能設計

將紅包ID的請求放入請求隊列中,如果發現超過紅包的個數,直接返回

注意事項

搶到紅包不一定能拆成功

搶紅包算法拆解

img

通過上圖算法得出,靠前面的人,手氣最佳幾率小,手氣最佳,往往在后面

發 100 元,共 10 個紅包,那么平均值是 10 元一個,那么發出來的紅包金額在 0.01~20 元之間波動

當前面 4 個紅包總共被領了 30 元時,剩下 70 元,總共 6 個紅包,那么這 6 個紅包的金額在 0.01~23.3 元之間波動

搶紅包接口開發

「測試」

「發紅包」

模擬高并發搶紅包(Jmeter壓測工具)

因為我發了 10 個紅包,金額是 20000,使用壓測工具,模擬50個請求,只允許前10個請求能搶到紅包,并且金額等于20000。

布隆過濾器

介紹

布隆過濾器是1970年由布隆提出的。它實際上是一個很長的二進制向量和一系列隨機映射函數。布隆過濾器可以用于檢索一個元素是否在一個集合中。它的優點是空間效率和查詢時間都遠遠超過一般的算法,缺點是有一定的誤識別率和刪除困難。

優點

相比于其他的數據結構,布隆過濾器在空間和時間方面都有巨大的優勢。布隆過濾器存儲空間和插入/查詢時間都是常數。另外三列函數相互之間沒有關系,方便由硬件并行實現。布隆過濾器不需要存儲元素本身,在某些對保密要求非常嚴格的場合有優勢。

缺點

但是布隆過濾器的缺點和有點一樣明顯。誤算率是其中之一。隨著存入的元素數量增加,誤算率隨之增加。但是如果元素數量太少,則使用散列表足矣。

布隆過濾器有什么用

黑客流量攻擊:故意訪問不存在的數據,導致查程序不斷訪問DB的數據

黑客安全阻截:當黑客訪問不存在的緩存時迅速返回避免緩存及DB掛掉

網頁爬蟲對 URL 的去重,避免爬取相同的URL地址

反垃圾郵件,從數十億個垃圾郵件列表中判斷某郵件是否垃圾郵件(同理,垃圾短信)

緩存擊穿,將已存在的緩存放到布隆中,當黑客訪問不存在的緩存時迅速返回避免緩存及 DB 掛掉

布隆過濾器實現會員轉盤抽獎

需求

一個抽獎程序,只針對會員用戶有效

通過google布隆過濾器存儲會員數據

程序啟動時將數據放入內存中

google自動創建布隆過濾器

用戶ID進來之后判斷是否是會員

代碼實現

引入依賴

com.google.guava guava 29.0-jre

數據庫會員表

CREATE TABLE `sys_user` ( `id` int(11) unsigned NOT NULL AUTO_INCREMENT, `user_name` varchar(11) CHARACTER SET utf8mb4 DEFAULT NULL COMMENT '?戶名', `image` varchar(11) CHARACTER SET utf8mb4 DEFAULT NULL COMMENT '?戶頭像', PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=11 DEFAULT CHARSET=utf8;

初始化布隆過濾器

dao 層和 dao 映射文件,就單純的一個 sql 查詢,看核心方法,下面會附源碼滴,不要慌好嘛

控制層

測試

缺點

內存級別產部

重啟即失效

本地內存無法用在分布式場景

不支持大數據量存儲

Redis布隆過濾器

優點

可擴展性 Bloom 過濾器

不存在重啟即失效或定時任務維護的成本

缺點

需要網絡IO,性能比基于內存的過濾器低

布隆過濾器安裝

「下載」

github:https://github.com/RedisBloom/RedisBloom

鏈接:https://pan.baidu.com/s/16DlKLm8WGFzGkoPpy8y4Aw密碼:25w1

「編譯」

make

「將 Rebloom 加載到 Redis 中」

先把 Redis 給停掉!!!在 redis.conf 里面添加一行命令->加載模塊

loadmodule/usr/soft/RedisBloom-2.2.4/redisbloom.so

「測試布隆過濾器」

SpringBoot 整合 Redis 布隆過濾器

編寫兩個lua腳本

添加數據到指定名稱的布隆過濾器

從指定名稱的布隆過濾器獲取key是否存在的腳本

localbloomName=KEYS[1] localvalue=KEYS[2] --bloomFilter localresult_1=redis.call('BF.ADD',bloomName,value) returnresult_1

localbloomName=KEYS[1] localvalue=KEYS[2] --bloomFilter localresult_1=redis.call('BF.EXISTS',bloomName,value) returnresult_1

在 RedisService.java 中添加 2 個方法

驗證

秒殺

秒殺業務流程圖

數據落地存儲方案

通過分布式redis減庫存

DB存最終訂單信息數據

API性能調優

性能瓶頸在高并發秒殺

技術難題在于超賣問題

實現步驟

提前將秒殺數據緩存到 redis

setskuId_start_10_1554045087--秒殺標識 setskuId_access_112000--允許搶購數 setskuId_count_10--搶購計數 setskuId_booked_10--真實秒殺數

秒殺開始前,skuId_start為0,代表活動未開始

當skuId_start改為1時,活動開始,開始秒殺叭

當接受下單數達到sku_count*1.2后,繼續攔截所有請求,商品剩余數量為0(為啥接受搶購數為1萬2呢,看業務流程圖,涉及到“校驗訂單信息”,一般設置的值要比總數多一點,多多少自己定)

利用 Redis 緩存加速增庫存數

"skuId_booked":10000//從0開始累加,秒殺的個數只能加到1萬

將用戶訂單數據寫入 MQ(異步方式)。

另外一臺服務器監聽 mq,將訂單信息寫入到 DB。

好了,以上就是完整的開發步驟,下面我們開始編寫代碼

代碼實戰

網關瀏覽攔截層

1、先判斷秒殺是否已經開始

2、利用 Redis 緩存 incr 攔截流量

用 incr 方法原子加

通過原子加帕努單當前 skuId_access 是否達到最大值

訂單信息校驗層

1、校驗當前用戶是否已經買過這個商品

需要存儲用戶的uid

存數據庫效率太低

存Redis value方式數據太大

存布隆過濾器性能高且數據量小(推薦)

2、校驗通過直接返回搶購成功

開發lua腳本實現庫存扣除

1、庫存扣除成功,獲取當前最新庫存

2、如果庫存大于0,即馬上進行庫存扣除,并且訪問搶購成功給用戶

3、考慮原子性問題

保證原子性的方式,采用 lua 腳本

采用lua腳本方式保證原子性帶來缺點,性能有所下降

不保證原子性缺點,放入請求量可能大于預期

當前扣除庫存場景必須保證原子性,否則會導致超賣

4、返回搶購結果

搶購成功

庫存沒了,搶購失敗

控制層

Service 層

布隆過濾器

初始化redis緩存

setskuId_start_10_1554045087--秒殺標識 setskuId_access_112000--允許搶購數 setskuId_count_10--搶購計數 setskuId_booked_10--真實秒殺數

秒殺驗證

jmeter 配置

壓測秒殺驗證原子性

項目下載

鏈接:https://pan.baidu.com/s/1hZUPRAljkqO05fYluqJBhQ密碼:1iwr

尾聲

演示的時候,我使用的 Redis 單機的,吞吐量不是很大,感興趣的,可以自己搭建個 Redis 主從復制+哨兵+集群,然后再測試。

最近比較忙,沒時間完善微信搶紅包秒殺的原子性。下面那個完整案例搶庫存的,親自使用 Jmeter 壓測幾次,是原子性的,可以拿來借鑒,感興趣的同學,可以借鑒下面搶庫存的代碼,把微信搶紅包的功能在完善下,我就不修改啦。

原文標題:Redis 秒殺實戰

文章出處:【微信公眾號:數據分析與開發】歡迎添加關注!文章轉載請注明出處。

聲明:本文內容及配圖由入駐作者撰寫或者入駐合作網站授權轉載。文章觀點僅代表作者本人,不代表電子發燒友網立場。文章及其配圖僅供工程師學習之用,如有內容侵權或者其他違規問題,請聯系本站處理。 舉報投訴
  • C語言
    +關注

    關注

    180

    文章

    7628

    瀏覽量

    139953
  • Redis
    +關注

    關注

    0

    文章

    382

    瀏覽量

    11271

原文標題:Redis 秒殺實戰

文章出處:【微信號:DBDevs,微信公眾號:數據分析與開發】歡迎添加關注!文章轉載請注明出處。

收藏 人收藏

    評論

    相關推薦
    熱點推薦

    Redis 再次開源!

    “ ?Redis 現已采用 AGPLv3 開源許可證。? ” Redis CEO 的 Blog 以下是 Redis CEO Rowan Trollope 的 Blog: 像 AWS 和 GCP 這樣
    的頭像 發表于 05-06 18:26 ?190次閱讀

    redis三種集群方案詳解

    Redis中提供的集群方案總共有三種(一般一個redis節點不超過10G內存)。
    的頭像 發表于 03-31 10:46 ?431次閱讀
    <b class='flag-5'>redis</b>三種集群方案詳解

    Redis實戰筆記

    在目前的技術選型中,Redis 儼然已經成為了系統高性能緩存方案的事實標準,因此現在?Redis 也成為了后端開發的基本技能樹之一。 ? 基于上述情況,今天給大家分享一份?杰哥?親筆撰寫的內部
    的頭像 發表于 02-09 09:12 ?272次閱讀
    <b class='flag-5'>Redis</b>實戰筆記

    華為云 Flexus X 加速 Redis 案例實踐與詳解

    Redis 加速鏡像,更是為開發者提供了極大的便利。本文將詳細介紹如何利用華為云 Flexus X 實例自帶的 Redis 鏡像,快速部署并配置 Redis,以及通過實際案例展示其便捷性和高效性。 一、華為云 Flexus
    的頭像 發表于 01-23 17:52 ?239次閱讀
    華為云 Flexus X 加速 <b class='flag-5'>Redis</b> 案例實踐與詳解

    Redis Cluster之故障轉移

    1. Redis Cluster 簡介 Redis Cluster 是 Redis 官方提供的 Redis 集群功能。 為什么要實現 Redis
    的頭像 發表于 01-20 09:21 ?686次閱讀
    <b class='flag-5'>Redis</b> Cluster之故障轉移

    云服務器 Flexus X 實例,Docker 集成搭建 Redis 集群

    Redis 集群是一種分布式的 Redis 解決方案,能夠在多個節點之間分片存儲數據,實現水平擴展和高可用性。與傳統的主從架構不同,Redis 集群支持數據自動分片、主節點故障自動切換,并可以在多臺
    的頭像 發表于 01-13 13:37 ?275次閱讀
    云服務器 Flexus X 實例,Docker 集成搭建 <b class='flag-5'>Redis</b> 集群

    性能與可靠性并重,Flexus X 實例助力 Redis 三主三從集群高效運行

    前言 在追求極致性能與可靠性的道路上,Flexus X 實例以卓越的算力與智能調度,為 Redis 三主三從集群的高效運行保駕護航。此架構不僅實現了數據的高可用性,還通過負載均衡提升了整體性
    的頭像 發表于 01-07 17:21 ?315次閱讀
    性能與可靠性并重,Flexus X 實例助力 <b class='flag-5'>Redis</b> 三主三從集群高效運行

    華為云Flexus X實例,Redis性能加速評測及對比

    隨著云計算技術的飛速發展,Redis 作為一種高性能的內存數據庫,在各種應用場景中發揮著越來越重要的作用。為了滿足不同用戶對 Redis 性能的高要求,華為云推出了 Flexus X 實例,并提供了
    的頭像 發表于 12-29 15:47 ?389次閱讀
    華為云Flexus X實例,<b class='flag-5'>Redis</b>性能加速評測及對比

    華為云 Flexus X 輕松實現 Redis 一主多從高效部署

    前言 ????????華為云 Flexus?X 是一款專為高性能計算設計的云服務器實例,其搭載的 X-Turbo 加速技術和智能應用調優算法,能夠大幅提升 Redis 的處理能力和響應速度。此外
    的頭像 發表于 12-27 13:45 ?410次閱讀
    華為云 Flexus X 輕松實現 <b class='flag-5'>Redis</b> 一主多從高效部署

    Redis使用重要的兩個機制:Reids持久化和主從復制

    今天這篇文章,我們一起了解 Redis 使用中非常重要的兩個機制:Reids 持久化和主從復制。 我們都知道Redis是一個內存數據庫,在學習主從同步之前,我們首先要想到 Redis 是如何做數據
    的頭像 發表于 12-18 10:33 ?316次閱讀
    <b class='flag-5'>Redis</b>使用重要的兩個機制:Reids持久化和主從復制

    Redis緩存與Memcached的比較

    Redis和Memcached都是廣泛使用的內存數據存儲系統,它們主要用于提高應用程序的性能,通過減少對數據庫的直接訪問來加速數據檢索。以下是對Redis和Memcached的比較,涵蓋了它們的一些
    的頭像 發表于 12-18 09:33 ?458次閱讀

    nginx+lua+redis實現灰度發布

    作者:馬仁喜 前言: 授人以魚不如授人以漁 .先學會用,在學原理,在學創造,可能一輩子用不到這種能力,但是不能不具備這種能力。這篇文章主要是沉淀使用nginx+lua+redis實現灰度,當我們具備
    的頭像 發表于 12-17 10:01 ?327次閱讀

    【畢設項目參考】物聯網10+項目推薦,附項目文檔/源碼/視頻

    又是一年畢設季,針對即將開始畢業設計的大學生,我們匯總了10+物聯網項目,供同學們參考。這些項目覆蓋了多個領域,希望可以為同學們提供豐富的靈感來源。我們鼓勵同學們根據自己的興趣和專業方向,選擇適合
    的頭像 發表于 11-26 15:26 ?1390次閱讀
    【畢設<b class='flag-5'>項目</b>參考】物聯網10+<b class='flag-5'>項目</b>推薦,附<b class='flag-5'>項目</b>文檔/源碼/視頻

    恒訊科技分析:云數據庫rds和redis區別是什么如何選擇?

    云數據庫RDS(Relational Database Service)和Redis是兩種不同類型的數據庫服務,它們有各自的特點和適用場景: 1、數據模型:RDS是一種關系型數據庫服務,通常用于存儲
    的頭像 發表于 08-19 15:31 ?674次閱讀

    K8S學習教程(二):在 PetaExpress KubeSphere容器平臺部署高可用 Redis 集群

    前言 Redis 是在開發過程中經常用到的緩存中間件,為了考慮在生產環境中穩定性和高可用,Redis通常采用集群模式的部署方式。 在制定Redis集群的部署策略時,常規部署在虛擬機上的方式配置繁瑣
    的頭像 發表于 07-03 15:30 ?1066次閱讀
    K8S學習教程(二):在 PetaExpress KubeSphere容器平臺部署高可用 <b class='flag-5'>Redis</b> 集群
    主站蜘蛛池模板: 色婷婷激婷婷深爱五月老司机 | 久久天天干 | 国产精品久久久精品三级 | 国产一级特黄毛片 | 久久天天躁综合夜夜黑人鲁色 | 婷婷资源| 亚洲理论视频 | 福利视频免费观看 | 青草午夜精品视频在线观看 | 丁香狠狠| 亚洲综合视频一区 | 亚洲系列中文字幕一区二区 | 91久久澡人人爽人人添 | 国产乱码免费卡1卡二卡3卡四 | 国产精品久久久久久久午夜片 | 天天干天天曰 | 欧美美女福利视频 | 天堂网在线新版www 天堂网在线资源 | 青草午夜精品视频在线观看 | 国产呦在线观看视频 | 亚洲综合啪啪 | 狠狠色丁香婷婷 | 91色爱| 亚洲综合区图片小说区 | 高颜值露脸极品在线播放 | 久久久夜夜夜 | 欧美日韩不卡码一区二区三区 | 欧美极品bbbbⅹxxxx | 婷婷六月丁 | 免费爱爱小视频 | 美女露出尿囗 | 又黑又长黑人欧美三级 | 好大好硬好爽免费视频 | 伊人网99 | 日韩三级久久 | 四虎国产精品视频免费看 | 亚洲精品91香蕉综合区 | 站长工具天天爽视频 | 狠狠五月天| 亚洲成人在线免费 | 69堂在线观看国产成人 |