Java實(shí)現(xiàn)高并發(fā)秒殺的幾種方式
引言
高并發(fā)場(chǎng)景在現(xiàn)場(chǎng)的日常工作中很常見(jiàn),特別是在互聯(lián)網(wǎng)公司中,這篇文章就來(lái)介紹如何實(shí)現(xiàn)高并發(fā)秒殺的幾種方式。
實(shí)現(xiàn)方式
1.緩存
使用緩存可以減少數(shù)據(jù)庫(kù)的訪(fǎng)問(wèn)量,提高系統(tǒng)吞吐量??梢跃彺鏌狳c(diǎn)數(shù)據(jù)、查詢(xún)結(jié)果等。
@Cacheable(value = "goods", key = "#goodsId") public Goods getGoods(Integer goodsId) { // 查詢(xún)數(shù)據(jù)庫(kù) }
2.前端實(shí)現(xiàn)方式
通過(guò)前端 JS 代碼限制用戶(hù)請(qǐng)求頻率,避免過(guò)大流量涌入,導(dǎo)致系統(tǒng)崩潰。比如可以實(shí)現(xiàn)每秒鐘限制請(qǐng)求次數(shù)等。
var requestTimes = 0; var lastRequestTime = 0; function requestSecKill() { var now = new Date(); if (now - lastRequestTime < 1000 && requestTimes > 5) { alert('請(qǐng)求過(guò)于頻繁,請(qǐng)稍后再試!'); return; } lastRequestTime = now; requestTimes++; // 發(fā)送秒殺請(qǐng)求 }
3.隊(duì)列削峰
當(dāng)請(qǐng)求流量超過(guò)系統(tǒng)容量時(shí),暫存多余請(qǐng)求到消息隊(duì)列,然后逐漸削峰處理。比如定時(shí)從隊(duì)列中取出一定數(shù)量請(qǐng)求處理。
BlockingQueue<Runnable> queue = new ArrayBlockingQueue<>(1000); ? public void addTask(Runnable task) { boolean offered = queue.offer(task); if (!offered) { // 隊(duì)列滿(mǎn)了,請(qǐng)求太多,返回限流提示 } } ? public void handleTasks() { Runnable task = queue.poll(); if (task != null) { executor.execute(task); } }
4.限流
使用令牌桶或者漏桶算法根據(jù)系統(tǒng)容量限制請(qǐng)求通過(guò)速率。超過(guò)速率的請(qǐng)求被拒絕或進(jìn)入隊(duì)列等待。
RateLimiter rateLimiter = RateLimiter.create(10); // 每秒不超過(guò)10個(gè)請(qǐng)求 if (rateLimiter.tryAcquire()) { // 請(qǐng)求通過(guò) } else { // 請(qǐng)求超過(guò)限流頻率 }
5.數(shù)據(jù)庫(kù)讀寫(xiě)分離
將數(shù)據(jù)庫(kù)分成主庫(kù)和從庫(kù),秒殺相關(guān)讀操作從從庫(kù)讀取,防止主庫(kù)壓力過(guò)大。
@Autowired private GoodsRepository goodsRepository; ? public Goods getGoods(Integer goodsId) { // 讀取從庫(kù) return goodsRepository.read(goodsId); } ? public void reduceStock(Integer goodsId) { // 寫(xiě)入主庫(kù) goodsRepository.write(goodsId); }
6.緩存失效時(shí)間
可以根據(jù)系統(tǒng)負(fù)載動(dòng)態(tài)調(diào)整緩存失效時(shí)間,在高流量期間縮短失效時(shí)間,避免緩存相同數(shù)據(jù)長(zhǎng)時(shí)間。
@Cacheable(value = "goods", key = "#goodsId", expire = "#expireTime") public Goods getGoods(Integer goodsId, Integer expireTime) { // 查詢(xún)數(shù)據(jù)庫(kù) } ? // 調(diào)整失效時(shí)間 cacheManager.setCacheExpired(cacheName, expireTime);
7.版本控制
對(duì)緩存或商品數(shù)據(jù)設(shè)置版本號(hào),當(dāng)數(shù)據(jù)修改時(shí)版本號(hào)遞增。請(qǐng)求帶上版本號(hào),如果緩存版本低,則從數(shù)據(jù)庫(kù)重新加載數(shù)據(jù)??梢源_保用戶(hù)獲取最新數(shù)據(jù)。
后端:
@Cacheable(value = "goods", key = "#goodsId + #version") public Goods getGoods(Integer goodsId, Integer version) { // 查詢(xún)數(shù)據(jù)庫(kù),帶版本號(hào)校驗(yàn) } ? public void updateGoods(Integer goodsId, Integer version) { goods.setVersion(version + 1); // 更新數(shù)據(jù)庫(kù) }
前端:
$.get("/goods/" + goodsId + "?v=" + version, function(data) { // 處理返回結(jié)果 });
總結(jié)
如果要完美解決高并發(fā)場(chǎng)景,需要 從緩存、限流、消息隊(duì)列、數(shù)據(jù)庫(kù)擴(kuò)展多方面考慮,而不僅僅是一兩個(gè)技術(shù)就可以。還需要注意系統(tǒng)的穩(wěn)定性、擴(kuò)展性,要足夠靈活與健壯。
到此這篇關(guān)于Java實(shí)現(xiàn)高并發(fā)秒殺的幾種方式的文章就介紹到這了,更多相關(guān)Java 高并發(fā)秒殺內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
Java微服務(wù)實(shí)戰(zhàn)項(xiàng)目尚融寶接口創(chuàng)建詳解
這篇文章主要介紹了Java微服務(wù)實(shí)戰(zhàn)項(xiàng)目尚融寶的接口創(chuàng)建流程,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2022-08-08Mybatis-Plus集成Sharding-JDBC與Flyway實(shí)現(xiàn)多租戶(hù)分庫(kù)分表實(shí)戰(zhàn)
這篇文章主要為大家介紹了Mybatis-Plus集成Sharding-JDBC與Flyway實(shí)現(xiàn)多租戶(hù)分庫(kù)分表實(shí)戰(zhàn),有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2023-11-11深入理解spring boot異步調(diào)用方式@Async
Spring為任務(wù)調(diào)度與異步方法執(zhí)行提供了注解支持。通過(guò)在方法上設(shè)置@Async注解,可使得方法被異步調(diào)用。下面這篇文章主要給大家介紹了關(guān)于spring boot異步調(diào)用方式@Async的相關(guān)資料,需要的朋友可以參考下。2017-07-07java中不同版本JSONObject區(qū)別小結(jié)
本文主要介紹了java中不同版本JSONObject區(qū)別小結(jié),文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2025-02-02Java commons io包實(shí)現(xiàn)多線(xiàn)程同步圖片下載入門(mén)教程
這篇文章主要介紹了Java commons io包實(shí)現(xiàn)多線(xiàn)程同步圖片下載入門(mén),commons io: 是針對(duì)開(kāi)發(fā)IO流功能的工具類(lèi)庫(kù),其中包含了許多可調(diào)用的函數(shù),感興趣的朋友跟隨小編一起看看吧2021-04-0410個(gè)實(shí)現(xiàn)Java集合,Map類(lèi)型自由轉(zhuǎn)換的實(shí)用工具方法
這篇文章主要為大家整理了整理了10個(gè)實(shí)用工具方法,可以滿(mǎn)足?Collection、List、Set、Map?之間各種類(lèi)型轉(zhuǎn)化,文中的示例代碼講解詳細(xì),需要的可以參考下2023-09-09spring Profile如何為不同環(huán)境提供不同的配置支持
這篇文章主要介紹了spring Profile如何為不同環(huán)境提供不同的配置支持,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2019-08-08Java多線(xiàn)程中關(guān)于join方法的使用實(shí)例解析
本文通過(guò)實(shí)例代碼給大家實(shí)例介紹了Java多線(xiàn)程中關(guān)于join方法的使用,非常不錯(cuò),具有參考借鑒價(jià)值,需要的朋友參考下2017-01-01