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

非常全面的Java?SpringBoot點贊功能實現(xiàn)

 更新時間:2022年01月23日 11:02:28   作者:JoeyHua  
但是這些功能再項目中是高頻出現(xiàn)的,如果直接操作數(shù)據(jù)庫的話,對數(shù)據(jù)庫壓力太大。那遇到這個問題怎么解決?這篇文章主要給大家介紹了關(guān)于Java?SpringBoot點贊功能實現(xiàn)?的相關(guān)資料,需要的朋友可以參考下

前言

最近公司在做一個NFT商城的項目,大致就是一個只買賣數(shù)字產(chǎn)品的平臺,項目中有個需求是用戶可以給商品點贊,還需要獲取商品的點贊總數(shù),類似下圖

起初感覺這功能很好實現(xiàn),無非就是加個點贊表嘛,后來發(fā)現(xiàn)事情并沒有這么簡單。

一開始的設(shè)計是這樣的,一共有三張表:商品表、用戶表、點贊表,用戶點贊的時候把用戶id和商品id加到點贊表中,并給對應(yīng)的商品點贊數(shù)+1??雌饋頉]什么問題,邏輯也比較簡單,但是測試的時候缺發(fā)現(xiàn)了奇怪的bug,點贊數(shù)量有時候會不正確,結(jié)果會比預(yù)期的大。

下面貼下關(guān)鍵代碼(項目使用了Mybatis-Plus):

public boolean like(Integer userId, Integer productId) {
        // 查詢是否有記錄,如果有記錄直接返回
        Like like = getOne(new QueryWrapper<Like>().lambda()
                .eq(Like::getUserId, userId)
                .eq(Like::getProductId, productId));
        if(like != null) {
            return true;
        }

        // 保存并商品點贊數(shù)加1
        save(Like.builder()
                .userId(userId)
                .productId(productId)
                .build());
        return productService.update(new UpdateWrapper<Product>().lambda()
                .setSql("like_count = like_count + 1")
                .eq(Product::getId, productId));
}

看上去沒什么問題,但是測試后數(shù)據(jù)卻不正確,為什么呢?

實際上這是一個并發(fā)問題,只要在并發(fā)的情況下就會出現(xiàn)問題,我們知道Spring Mvc是基于servlet的,servlet在接收到用戶請求后會從線程池中拿一個線程分配給它,每個請求都是一個單獨的線程。試想一下,如果A線程在執(zhí)行完查詢操作后,發(fā)現(xiàn)沒有記錄,隨后由于CPU調(diào)度,把控制權(quán)讓了出去,然后B線程執(zhí)行查詢,也發(fā)現(xiàn)沒有記錄,這時候A和B線程都會執(zhí)行保存并商品點贊數(shù)加1這個操作,導(dǎo)致數(shù)據(jù)不正確。

CPU操作順序:A線程查詢 -> B線程查詢 -> A線程保存 -> B線程保存

下面使用JMeter模擬一下并發(fā)的情況,模擬用戶在1秒內(nèi)對商品執(zhí)行100次點贊請求,結(jié)果應(yīng)該是1,但得到的結(jié)果卻是28(實際結(jié)果不一定是28,可能是任何數(shù)字)。

解決方案

青銅版

使用synchronized關(guān)鍵字鎖住讀寫操作,操作完成后釋放鎖

public boolean like(Integer userId, Integer productId) {
        String lock = buildLock(userId, productId);
        synchronized (lock) {
            // 查詢是否有記錄,如果有記錄直接返回
            Like like = getOne(new QueryWrapper<Like>().lambda()
                    .eq(Like::getUserId, userId)
                    .eq(Like::getProductId, productId), false);
            if(like != null) {
                return true;
            }

            // 保存并商品點贊數(shù)加1
            save(Like.builder()
                    .userId(userId)
                    .productId(productId)
                    .build());
            return productService.update(new UpdateWrapper<Product>().lambda()
                    .setSql("like_count = like_count + 1")
                    .eq(Product::getId, productId));
        }
}

private String buildLock(Integer userId, Integer productId) {
        StringBuilder sb = new StringBuilder();
        sb.append(userId);
        sb.append("::");
        sb.append(productId);
        String lock = sb.toString().intern();

        return lock;
}

這里要注意一點,使用String作為鎖時一定要調(diào)用intern()方法,intern()會先從常量池中查找有沒有相同的String,如果有就直接返回,沒有的話會把當(dāng)前String加入常量池,然后再返回。如果不調(diào)用這個方法鎖會失效。

JMeter性能數(shù)據(jù)

優(yōu)點:

保證了正確性

缺點:

性能太差,并發(fā)低的情況下還可以應(yīng)付,并發(fā)高時用戶體驗極差

白銀版

點贊表user_id和product_id加上聯(lián)合索引,并使用try catch捕獲異常,防止報錯。由于使用了聯(lián)合索引,所以不需要在新增前查詢了,mysql會幫我們做這件事。

public boolean like(Integer userId, Integer productId) {
        try {
            // 保存并商品點贊數(shù)加1
            save(Like.builder()
                    .userId(userId)
                    .productId(productId)
                    .build());
            return productService.update(new UpdateWrapper<Product>().lambda()
                    .setSql("like_count = like_count + 1")
                    .eq(Product::getId, productId));
        }catch (DuplicateKeyException exception) {

        }

        return true;
}

JMeter性能數(shù)據(jù)

優(yōu)點:

性能比上一個方案好

缺點:

中規(guī)中矩,沒什么大的缺點

黃金版

使用Redis緩存點贊數(shù)據(jù)(點贊操作使用lua腳本實現(xiàn),保證操作的原子性),然后定時同步到mysql。

注意:Redis需要開啟持久化,最好aof和rdb都開啟,不然重啟數(shù)據(jù)就丟失了

public boolean like(Integer userId, Integer productId) {
        List<String> keys = new ArrayList<>();
        keys.add(buildUserRedisKey(userId));
        keys.add(buildProductRedisKey(productId));

        int value1 = 1;

        redisUtil.execute("lua-script/like.lua", keys, value1);

        return true;
}

private String buildUserRedisKey(Integer userId) {
        return "userId_" + userId;
}

private String buildProductRedisKey(Integer productId) {
        return "productId_" + productId;
}

lua腳本

local userId = KEYS[1]
local productId = KEYS[2]
local flag = ARGV[1] -- 1:點贊 0:取消點贊


if flag == '1' then
  -- 用戶set添加商品并商品點贊數(shù)加1
  if redis.call('SISMEMBER', userId, productId) == 0 then
    redis.call('SADD', userId, productId)
    redis.call('INCR', productId)
  end
else
  -- 用戶set刪除商品并商品點贊數(shù)減1
  redis.call('SREM', userId, productId)
  local oldValue = tonumber(redis.call('GET', productId))
  if oldValue and oldValue > 0 then
    redis.call('DECR', productId)
  end
end

return 1

JMeter性能數(shù)據(jù)

優(yōu)點:

  • 性能非常好

缺點:

  • 數(shù)據(jù)量多了內(nèi)存占用較高總結(jié)

如果對性能沒有要求,可以使用白銀版的實現(xiàn)方式,如果有要求,就使用黃金版的方式,內(nèi)存占用大的問題也可以通過一些手段來解決,比如可以根據(jù)業(yè)務(wù)需求定期刪除一些不常用的緩存數(shù)據(jù),但是相對應(yīng)的,查詢的時候就需要在查詢失敗時再去查數(shù)據(jù)庫。

源碼

源碼地址:https://github.com/huajiayi/like-demo

源碼里有一些功能沒有實現(xiàn),比如定時同步功能,需要根據(jù)業(yè)務(wù)需求自行實現(xiàn)

總結(jié)

到此這篇關(guān)于Java SpringBoot點贊功能實現(xiàn)的文章就介紹到這了,更多相關(guān)Java SpringBoot點贊功能內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!

相關(guān)文章

  • C++和Java命令行繪制心形圖案

    C++和Java命令行繪制心形圖案

    這篇文章主要為大家詳細(xì)介紹了C++和Java命令行繪制心形圖案,文中示例代碼介紹的非常詳細(xì),具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2019-04-04
  • 細(xì)品Java8中hashCode方法的使用

    細(xì)品Java8中hashCode方法的使用

    這篇文章主要介紹了細(xì)品Java8中hashCode方法的使用,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2020-12-12
  • Maven添加Tomcat插件實現(xiàn)熱部署代碼實例

    Maven添加Tomcat插件實現(xiàn)熱部署代碼實例

    這篇文章主要介紹了Maven添加Tomcat插件實現(xiàn)熱部署代碼實例,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下
    2020-04-04
  • java通過jni調(diào)用opencv處理圖像的方法

    java通過jni調(diào)用opencv處理圖像的方法

    今天小編就為大家分享一篇java通過jni調(diào)用opencv處理圖像的方法,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧
    2018-08-08
  • SpringBoot實現(xiàn)人臉識別等多種登錄方式

    SpringBoot實現(xiàn)人臉識別等多種登錄方式

    本文主要介紹了SpringBoot實現(xiàn)人臉識別等多種登錄方式,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2022-05-05
  • Java多線程并發(fā)編程和鎖原理解析

    Java多線程并發(fā)編程和鎖原理解析

    這篇文章主要介紹了Java多線程并發(fā)編程和鎖原理解析,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下
    2019-12-12
  • spring boot如何基于JWT實現(xiàn)單點登錄詳解

    spring boot如何基于JWT實現(xiàn)單點登錄詳解

    這篇文章主要介紹了spring boot如何基于JWT實現(xiàn)單點登錄詳解,用戶只需登錄一次就能夠在這兩個系統(tǒng)中進(jìn)行操作。很明顯這就是單點登錄(Single Sign-On)達(dá)到的效果,需要的朋友可以參考下
    2019-06-06
  • Java RMI詳細(xì)介紹及簡單實例

    Java RMI詳細(xì)介紹及簡單實例

    這篇文章主要介紹了Java RMI詳細(xì)介紹及簡單實例的相關(guān)資料,需要的朋友可以參考下
    2017-02-02
  • SpringBoot如何使用Scala進(jìn)行開發(fā)的實現(xiàn)

    SpringBoot如何使用Scala進(jìn)行開發(fā)的實現(xiàn)

    這篇文章主要介紹了SpringBoot如何使用Scala進(jìn)行開發(fā)的實現(xiàn),文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2019-12-12
  • MyBatis中的SQL映射文件配置結(jié)果映射的操作指南

    MyBatis中的SQL映射文件配置結(jié)果映射的操作指南

    MyBatis?是一款優(yōu)秀的?ORM?框架,它提供了多種配置方式來定義?SQL?語句以及結(jié)果映射規(guī)則,本文將介紹?MyBatis?中的?SQL?映射文件如何配置結(jié)果映射,包括常規(guī)類型、集合類型等多種情況,需要的朋友可以參考下
    2023-07-07

最新評論