欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Java實(shí)現(xiàn)高并發(fā)秒殺的幾種方式

 更新時(shí)間:2023年05月23日 15:51:50   作者:fking86  
高并發(fā)場(chǎng)景在現(xiàn)場(chǎng)的日常工作中很常見(jiàn),本文主要介紹了Java實(shí)現(xiàn)高并發(fā)秒殺的幾種方式,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧

引言

高并發(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)建詳解

    這篇文章主要介紹了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-08
  • Mybatis-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)

    這篇文章主要為大家介紹了Mybatis-Plus集成Sharding-JDBC與Flyway實(shí)現(xiàn)多租戶(hù)分庫(kù)分表實(shí)戰(zhàn),有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪
    2023-11-11
  • 深入理解spring boot異步調(diào)用方式@Async

    深入理解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-07
  • java中不同版本JSONObject區(qū)別小結(jié)

    java中不同版本JSONObject區(qū)別小結(jié)

    本文主要介紹了java中不同版本JSONObject區(qū)別小結(jié),文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧
    2025-02-02
  • Java commons io包實(shí)現(xiàn)多線(xiàn)程同步圖片下載入門(mén)教程

    Java 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-04
  • 10個(gè)實(shí)現(xiàn)Java集合,Map類(lèi)型自由轉(zhuǎn)換的實(shí)用工具方法

    10個(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-09
  • spring Profile如何為不同環(huán)境提供不同的配置支持

    spring Profile如何為不同環(huán)境提供不同的配置支持

    這篇文章主要介紹了spring Profile如何為不同環(huán)境提供不同的配置支持,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下
    2019-08-08
  • SpringCache之 @CachePut的使用

    SpringCache之 @CachePut的使用

    這篇文章主要介紹了SpringCache之 @CachePut的使用,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧
    2021-02-02
  • Java多線(xiàn)程中關(guān)于join方法的使用實(shí)例解析

    Java多線(xiàn)程中關(guān)于join方法的使用實(shí)例解析

    本文通過(guò)實(shí)例代碼給大家實(shí)例介紹了Java多線(xiàn)程中關(guān)于join方法的使用,非常不錯(cuò),具有參考借鑒價(jià)值,需要的朋友參考下
    2017-01-01
  • Java中BigDecimal使用注意避坑指南

    Java中BigDecimal使用注意避坑指南

    Java在java.math包中提供的API類(lèi)BigDecimal,用來(lái)對(duì)超過(guò)16位有效位的數(shù)進(jìn)行精確的運(yùn)算,下面這篇文章主要給大家介紹了關(guān)于Java中BigDecimal使用注意避坑的相關(guān)資料,需要的朋友可以參考下
    2023-02-02

最新評(píng)論