Redis中如何實(shí)現(xiàn)商品秒殺
隨著互聯(lián)網(wǎng)的發(fā)展和消費(fèi)者的需求越來(lái)越高,商品的銷售也變得越來(lái)越激烈。而對(duì)于商家來(lái)說(shuō),最直觀的解決方式即為促銷活動(dòng)。然而,促銷活動(dòng)也會(huì)引發(fā)一定的風(fēng)險(xiǎn)。
如果處理得不當(dāng),可能會(huì)出現(xiàn)“搶購(gòu)”活動(dòng)中的庫(kù)存不足等問題。本文將利用Redis實(shí)現(xiàn)商品秒殺,來(lái)避免這些問題的發(fā)生。
技術(shù)棧
本次實(shí)現(xiàn)采用的技術(shù)棧如下:
- SpringBoot
- Redis
- Mybatis-plus
- Vue
功能實(shí)現(xiàn)步驟
在實(shí)現(xiàn)商品秒殺之前,我們需要先準(zhǔn)備好基本的開發(fā)環(huán)境。本文將假定您已經(jīng)設(shè)置好了相關(guān)環(huán)境。
接下來(lái),請(qǐng)按照以下步驟進(jìn)行功能的實(shí)現(xiàn)。
步驟一:準(zhǔn)備商品庫(kù)存數(shù)據(jù)
首先,我們需要在數(shù)據(jù)庫(kù)中創(chuàng)建一個(gè)名為“goods”的表,用于存儲(chǔ)商品的庫(kù)存數(shù)據(jù)。
表結(jié)構(gòu)如下:
CREATE TABLE `goods` ( `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '秒殺商品ID', `goods_name` varchar(32) DEFAULT NULL COMMENT '商品名稱', `goods_count` int(11) DEFAULT NULL COMMENT '商品庫(kù)存數(shù)量', `start_time` datetime DEFAULT NULL COMMENT '秒殺開始時(shí)間', `end_time` datetime DEFAULT NULL COMMENT '秒殺結(jié)束時(shí)間', PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
在表中添加一些假數(shù)據(jù),用于測(cè)試秒殺功能。
步驟二:實(shí)現(xiàn)商品秒殺
接下來(lái),我們需要實(shí)現(xiàn)商品秒殺功能。這里,我們采用Redis作為秒殺的核心工具,通過前后端協(xié)作來(lái)實(shí)現(xiàn)秒殺。
1. Redis實(shí)現(xiàn)秒殺
在Redis中,我們可以使用List類型來(lái)存儲(chǔ)待秒殺的商品ID,使用Set類型來(lái)存儲(chǔ)已經(jīng)秒殺成功的商品ID。同時(shí),為了防止一個(gè)用戶重復(fù)搶購(gòu)?fù)粋€(gè)商品,我們還需要使用Hash類型來(lái)存儲(chǔ)每個(gè)用戶的秒殺訂單信息。
具體實(shí)現(xiàn)方式如下:
- 初始化Redis中的商品列表和已秒殺商品集合,將數(shù)據(jù)庫(kù)中的商品庫(kù)存數(shù)量存入Redis中。
// 商品列表名稱 String redisKey = "goods:" + seckillGoods.getId(); // 添加所有庫(kù)存商品 for (int i = 0; i < seckillGoods.getGoodsCount(); i++) { redisTemplate.opsForList().rightPush(redisKey, String.valueOf(seckillGoods.getId())); }
- 判斷用戶是否已經(jīng)秒殺成功過。
// 查詢用戶是否已經(jīng)秒殺過該商品 Object orderObj = redisTemplate.opsForHash().get("seckill_orders", seckillUser.getId() + ":" + seckillGoods.getId()); if (orderObj != null) { throw new SEckillException(ErrorCodeEnum.REPEAT_SEC_KILL_ERROR); } // 查詢用戶是否在排隊(duì)中 Object userInQueueObj = redisTemplate.opsForSet().isMember("seckill_queues:" + seckillGoods.getId(), seckillUser.getId()); if (userInQueueObj != null) { throw new SEckillException(ErrorCodeEnum.WAITING_IN_QUEUE_ERROR); }
- 利用Redis的事務(wù)實(shí)現(xiàn)處理?yè)屬?gòu)成功的邏輯。
// 開啟事務(wù) redisTemplate.setEnableTransactionSupport(true); redisTemplate.multi(); // 從商品列表中彈出一個(gè)商品 redisTemplate.opsForList().leftPop(redisKey); // 利用setValueAt等方法,獲取用戶信息和商品信息,此處略過 // 判斷是否獲取到商品信息 if (seckillGoods == null) { redisTemplate.discard(); throw new SEckillException(ErrorCodeEnum.SEC_KILL_FINISH_ERROR); } // 秒殺成功,生成秒殺訂單 redisTemplate.opsForHash().put("seckill_orders", seckillUser.getId() + ":" + seckillGoods.getId(), seckillOrder); // 秒殺成功的商品寫入Set中 redisTemplate.opsForSet().add("seckill_success:" + seckillGoods.getId(), String.valueOf(seckillGoods.getId())); // 提交事務(wù) redisTemplate.exec();
以上代碼,通過將Redis事務(wù)化實(shí)現(xiàn)了秒殺成功時(shí),商品列表從一個(gè)元素彈出、將秒殺訂單存入Hash中,以及在已秒殺商品集合中添加記錄。當(dāng)秒殺失敗時(shí),Redis將自動(dòng)回滾整個(gè)事務(wù)。
2. 前端頁(yè)面實(shí)現(xiàn)秒殺
在前端頁(yè)面中,我們需要使用Vue同時(shí)發(fā)送兩個(gè)請(qǐng)求,一個(gè)請(qǐng)求用于獲取商品詳情,另一個(gè)請(qǐng)求用于提交秒殺訂單。具體實(shí)現(xiàn)方式如下:
- 獲取商品詳情。
created() { // 發(fā)送請(qǐng)求獲取商品詳情信息 axios.get('/seckill/goods/' + this.$route.params.id) .then(res => { this.goods = res.data; }) .catch(err => { console.log(err); }) }
- 提交秒殺訂單。
seckill() { // 發(fā)送秒殺請(qǐng)求 axios.post('/seckill/order/' + this.goods.id) .then(res => { if (res.data.code == 200) { alert('秒殺成功!'); } else { alert(res.data.msg); } }) .catch(err => { console.log(err); }) }
以上代碼,通過使用Axios向后端發(fā)送商品詳情和秒殺請(qǐng)求來(lái)實(shí)現(xiàn)秒殺功能。
步驟三:優(yōu)化Redis性能
在實(shí)際的項(xiàng)目中,我們需要考慮如何優(yōu)化Redis性能。以下是一些優(yōu)化配置方案:
- 增加Redis實(shí)例的數(shù)量以提高可用性和性能。
- 設(shè)置Redis緩存的過期時(shí)間,防止內(nèi)存泄漏和Redis存儲(chǔ)空間的浪費(fèi)。
- 使用Redis的集群功能,將數(shù)據(jù)分散在多個(gè)Redis節(jié)點(diǎn)上,以提高Redis的容錯(cuò)性。
技術(shù)講解
接下來(lái),讓我們來(lái)更加詳細(xì)地講解一下這個(gè)項(xiàng)目的實(shí)現(xiàn)技術(shù)和原理。
Redis的List類型
在實(shí)現(xiàn)商品秒殺時(shí),我們需要用到Redis的List類型來(lái)存儲(chǔ)待秒殺的商品ID,以及使用左邊出隊(duì)和右邊進(jìn)隊(duì)等操作來(lái)模擬搶購(gòu)的過程。
Redis的List類型是一個(gè)雙向鏈表結(jié)構(gòu),可以在頭部、尾部、任意位置插入、刪除數(shù)據(jù)。使用List類型可以實(shí)現(xiàn)類似隊(duì)列和棧的功能。
以下是使用Redis的List類型的一些命令:
LPUSH
:在列表的左邊插入一個(gè)或多個(gè)元素。RPUSH
:在列表的右邊插入一個(gè)或多個(gè)元素。LPOP
:從列表的左邊移除并返回一個(gè)元素。RPOP
:從列表的右邊移除并返回一個(gè)元素。LINDEX
:返回列表中指定索引位置的元素。
Redis的Set類型
在實(shí)現(xiàn)商品秒殺時(shí),我們還需要使用Redis的Set類型來(lái)存儲(chǔ)已經(jīng)秒殺成功的商品ID。
Redis的Set類型是一個(gè)無(wú)序集合,可以存儲(chǔ)多個(gè)字符串類型的元素。Set類型支持去重和集合操作。
以下是使用Redis的Set類型的一些命令:
SADD
:將一個(gè)或多個(gè)元素添加到集合中。SREM
:從集合中移除給定元素。SCARD
:返回集合的元素?cái)?shù)量。SMEMBERS
:返回集合中的所有元素。SISMEMBER
:判斷元素是否在集合中。
Redis的Hash類型
在實(shí)現(xiàn)商品秒殺時(shí),我們還需要使用Redis的Hash類型來(lái)存儲(chǔ)每個(gè)用戶的秒殺訂單信息。
Redis的Hash類型是一個(gè)字典結(jié)構(gòu),可以在O(1)時(shí)間內(nèi)存儲(chǔ)、修改和查詢?cè)亍?/p>
以下是使用Redis的Hash類型的一些命令:
HSET
:設(shè)置哈希表中指定字段的值。HGET
:獲取哈希表中指定字段的值。HGETALL
:獲取哈希表中所有字段和值。HDEL
:刪除哈希表中一個(gè)或多個(gè)字段。HEXISTS
:判斷哈希表中指定字段是否存在。
Redis的事務(wù)
在實(shí)現(xiàn)商品秒殺時(shí),我們需要保證秒殺成功時(shí)商品列表中需要彈出一個(gè)元素、同時(shí)將秒殺訂單信息存入Hash中,并且在已秒殺商品集合中添加記錄。為了保證這三個(gè)操作同時(shí)完成,我們需要使用Redis的事務(wù)來(lái)保證原子性。
Redis的事務(wù)是一組命令的集合,這些命令會(huì)被一次性、按照順序地執(zhí)行。在執(zhí)行事務(wù)期間,其他客戶端的操作不會(huì)干擾該事務(wù)的執(zhí)行。
以下是使用Redis事務(wù)的一些命令:
MULTI
:開啟事務(wù)。EXEC
:提交事務(wù),執(zhí)行事務(wù)中的所有命令。DISCARD
:撤銷事務(wù)。
Mybatis-plus
在本項(xiàng)目中,我們使用了Mybatis-plus作為ORM框架來(lái)操作數(shù)據(jù)庫(kù)。Mybatis-plus是Mybatis的增強(qiáng)版本,可以大幅度提高開發(fā)效率。
Mybatis-plus的一些特點(diǎn)如下:
- 無(wú)需編寫Mapper接口,可以使用自動(dòng)生成的通用Mapper接口對(duì)數(shù)據(jù)庫(kù)進(jìn)行操作。
- 支持Lambda表達(dá)式,可改善代碼可讀性。
- 豐富的查詢條件API,支持鏈?zhǔn)秸{(diào)用。
本項(xiàng)目中用到的一些Mybatis-plus的注解如下:
@TableName
:指定實(shí)體類對(duì)應(yīng)的數(shù)據(jù)庫(kù)表名。@TableField
:指定實(shí)體類字段對(duì)應(yīng)的數(shù)據(jù)庫(kù)列名。@Autowired
:在Spring中自動(dòng)裝配需要使用的Bean。
開發(fā)流程
開發(fā)流程如下:
- 準(zhǔn)備項(xiàng)目環(huán)境,包括SpringBoot、Redis、Mybatis-plus、Vue等組件。
- 在數(shù)據(jù)庫(kù)中創(chuàng)建秒殺商品表seckill_goods,并添加一些測(cè)試數(shù)據(jù)。
- 根據(jù)實(shí)際需求,在后端代碼中實(shí)現(xiàn)商品秒殺功能,其中需要用到Redis的List、Set和Hash類型,以及使用Redis事務(wù)保證原子性。
- 在前端頁(yè)面中使用Vue,向后端發(fā)送商品詳情和秒殺請(qǐng)求,實(shí)現(xiàn)商品秒殺。
- 優(yōu)化Redis性能,增加Redis實(shí)例的數(shù)量、設(shè)置緩存過期時(shí)間和使用Redis集群等方式。
- 測(cè)試和部署項(xiàng)目。
總結(jié)
本文介紹了如何使用Redis實(shí)現(xiàn)商品秒殺,并提供了詳細(xì)的功能實(shí)現(xiàn)步驟和技術(shù)講解。
在實(shí)現(xiàn)過程中,我們了解了Redis的List、Set和Hash類型,以及使用Redis事務(wù)保證原子性的方式。同時(shí),我們也使用了Mybatis-plus作為ORM框架,有效提高了開發(fā)效率。最后,我們還介紹了如何優(yōu)化Redis性能,進(jìn)一步提升了項(xiàng)目的質(zhì)量。
這些僅為個(gè)人經(jīng)驗(yàn),希望能給大家一個(gè)參考,也希望大家多多支持腳本之家。
相關(guān)文章
解讀Redis秒殺優(yōu)化方案(阻塞隊(duì)列+基于Stream流的消息隊(duì)列)
該文章介紹了使用Redis的阻塞隊(duì)列和Stream流的消息隊(duì)列來(lái)優(yōu)化秒殺系統(tǒng)的方案,通過將秒殺流程拆分為兩條流水線,使用Redis緩存緩解數(shù)據(jù)庫(kù)壓力,并結(jié)合Lua腳本進(jìn)行原子性判斷,使用阻塞隊(duì)列和消息隊(duì)列異步處理訂單,有效提高了系統(tǒng)的并發(fā)處理能力和可用性2025-02-02Redis操作相關(guān)命令之查看、停止、啟動(dòng)命令
這篇文章主要介紹了Redis操作相關(guān)命令之查看、停止、啟動(dòng)命令,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2023-09-09Redis?抽獎(jiǎng)大轉(zhuǎn)盤的實(shí)戰(zhàn)示例
本文主要介紹了Redis?抽獎(jiǎng)大轉(zhuǎn)盤的實(shí)戰(zhàn)示例,文中通過示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2021-12-12Redis中l(wèi)ua腳本實(shí)現(xiàn)及其應(yīng)用場(chǎng)景
本文主要介紹了Redis中l(wèi)ua腳本實(shí)現(xiàn)及其應(yīng)用場(chǎng)景,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2023-04-04SpringBoot3+Redis實(shí)現(xiàn)分布式鎖的配置方法
這篇文章主要介紹了SpringBoot3+Redis實(shí)現(xiàn)分布式鎖,本文通過實(shí)例代碼給大家介紹的非常詳細(xì),感興趣的朋友跟隨小編一起看看吧2024-07-07Redis Cluster集群數(shù)據(jù)分片機(jī)制原理
這篇文章主要介紹了Redis Cluster集群數(shù)據(jù)分片機(jī)制原理,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-04-04Redis集群指定主從關(guān)系及動(dòng)態(tài)增刪節(jié)點(diǎn)方式
這篇文章主要介紹了Redis集群指定主從關(guān)系及動(dòng)態(tài)增刪節(jié)點(diǎn)方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2024-01-01redis保存AtomicInteger對(duì)象踩坑及解決
這篇文章主要介紹了redis保存AtomicInteger對(duì)象踩坑及解決方案,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2022-11-11