成人国产在线小视频_日韩寡妇人妻调教在线播放_色成人www永久在线观看_2018国产精品久久_亚洲欧美高清在线30p_亚洲少妇综合一区_黄色在线播放国产_亚洲另类技巧小说校园_国产主播xx日韩_a级毛片在线免费

資訊專欄INFORMATION COLUMN

使用redis事物解決stringRedisTemplate.setIfAbsent()并設(shè)置過(guò)期時(shí)

ixlei / 2610人閱讀

摘要:本因?yàn)檫@樣就可以了,可是事實(shí)總是不盡人意,因?yàn)槲以谖臋n中發(fā)現(xiàn)了以下內(nèi)容加了事務(wù)管理之后,的返回值竟然是,這樣就沒辦法再進(jìn)行之后的判斷了。最終解決方法使用的返回值判斷是否成功這里會(huì)返回事務(wù)內(nèi)每一個(gè)操作的結(jié)果,如果操作失敗后,會(huì)為。

spring-date-redis版本:1.6.2
場(chǎng)景:在使用setIfAbsent(key,value)時(shí),想對(duì)key設(shè)置一個(gè)過(guò)期時(shí)間,同時(shí)需要用到setIfAbsent的返回值來(lái)指定之后的流程,所以使用了以下代碼:

boolean store = stringRedisTemplate.opsForValue().setIfAbsent(key,value);
if(store){
  stringRedisTemplate.expire(key,timeout); 
  // todo something...  
}

這段代碼是有問(wèn)題的:當(dāng)setIfAbsent成功之后斷開連接,下面設(shè)置過(guò)期時(shí)間的代碼 stringRedisTemplate.expire(key,timeout); 是無(wú)法執(zhí)行的,這時(shí)候就會(huì)有大量沒有過(guò)期時(shí)間的數(shù)據(jù)存在數(shù)據(jù)庫(kù)。想到一個(gè)辦法就是添加事務(wù)管理,修改后的代碼如下:

stringRedisTemplate.setEnableTransactionSupport(true);
stringRedisTemplate.multi();
boolean store = stringRedisTemplate.opsForValue().setIfAbsent(key,value);
if(store){
  stringRedisTemplate.expire(key,timeout);   
}
stringRedisTemplate.exec();
if(store){
    // todo something...
}

這樣就保證了整個(gè)流程的一致性。本因?yàn)檫@樣就可以了,可是事實(shí)總是不盡人意,因?yàn)槲以谖臋n中發(fā)現(xiàn)了以下內(nèi)容:

加了事務(wù)管理之后,setIfAbsent的返回值竟然是null,這樣就沒辦法再進(jìn)行之后的判斷了。

好吧,繼續(xù)解決:

stringRedisTemplate.setEnableTransactionSupport(true);
stringRedisTemplate.multi();
String result = stringRedisTemplate.opsForValue().get(key);
if(StringUtils.isNotBlank(result)){
    return false;
}
// 鎖的過(guò)期時(shí)間為1小時(shí)
stringRedisTemplate.opsForValue().set(key, value,timeout);
stringRedisTemplate.exec();

// todo something...

上邊的代碼其實(shí)還是有問(wèn)題的,當(dāng)出現(xiàn)并發(fā)時(shí),String result = stringRedisTemplate.opsForValue().get(key); 這里就會(huì)有多個(gè)線程同時(shí)拿到為空的key,然后同時(shí)寫入臟數(shù)據(jù)。

最終解決方法:

使用stringRedisTemplate.exec();的返回值判斷setIfAbsent是否成功

stringRedisTemplate.setEnableTransactionSupport(true);
stringRedisTemplate.multi();
stringRedisTemplate.opsForValue().setIfAbsent(lockKey,JSON.toJSONString(event));
stringRedisTemplate.expire(lockKey,Constants.REDIS_KEY_EXPIRE_SECOND_1_HOUR, TimeUnit.SECONDS);
List result = stringRedisTemplate.exec(); // 這里result會(huì)返回事務(wù)內(nèi)每一個(gè)操作的結(jié)果,如果setIfAbsent操作失敗后,result[0]會(huì)為false。
if(true == result[0]){
  // todo something...
}

將redis版本升級(jí)到2.1以上,然后使用


直接在setIfAbsent中設(shè)置過(guò)期時(shí)間

update :
java 使用redis的事務(wù)時(shí)不能直接用Api中的multi()和exec(),這樣multi()和exec()兩次使用的stringRedisTemplate不是一個(gè)connect,會(huì)導(dǎo)致死鎖,正確方式如下:

    private Boolean setLock(RecordEventModel event) {
        String lockKey = event.getModel() + ":" + event.getAction() + ":" + event.getId() + ":" + event.getMessage_id();
        log.info("lockKey : {}" , lockKey);
        SessionCallback sessionCallback = new SessionCallback() {
            List exec = null;
            @Override
            @SuppressWarnings("unchecked")
            public Boolean execute(RedisOperations operations) throws DataAccessException {
                operations.multi();
                stringRedisTemplate.opsForValue().setIfAbsent(lockKey,JSON.toJSONString(event));
                stringRedisTemplate.expire(lockKey,Constants.REDIS_KEY_EXPIRE_SECOND_1_HOUR, TimeUnit.SECONDS);
                exec = operations.exec();
                if(exec.size() > 0) {
                    return (Boolean) exec.get(0);
                }
                return false;
            }
        };
        return stringRedisTemplate.execute(sessionCallback);
    }           
               
                                           
                       
                 
            
                     
             
               

文章版權(quán)歸作者所有,未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為,您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請(qǐng)注明本文地址:http://systransis.cn/yun/73071.html

相關(guān)文章

  • 五個(gè)步驟教你理清Redis與Memcached的區(qū)別

    摘要:它們都使用來(lái)做事件循環(huán),不過(guò)是單線程的服務(wù)器也是多線程的,只不過(guò)除了主線程以外,其他線程沒有,只是會(huì)進(jìn)行一些后臺(tái)存儲(chǔ)工作,而是多線程的。支持設(shè)置過(guò)期時(shí)間,即,但是內(nèi)部并不定期檢查數(shù)據(jù)是否過(guò)期,而是客戶進(jìn)程使用該數(shù)據(jù)的時(shí)候,會(huì) 歡迎大家前往騰訊云+社區(qū),獲取更多騰訊海量技術(shù)實(shí)踐干貨哦~ 本文由Super發(fā)表于云+社區(qū)專欄 memcached和redis,作為近些年最常用的緩存服務(wù)器,相...

    waterc 評(píng)論0 收藏0

發(fā)表評(píng)論

0條評(píng)論

最新活動(dòng)
閱讀需要支付1元查看
<