摘要:本因為這樣就可以了,可是事實總是不盡人意,因為我在文檔中發現了以下內容加了事務管理之后,的返回值竟然是,這樣就沒辦法再進行之后的判斷了。最終解決方法使用的返回值判斷是否成功這里會返回事務內每一個操作的結果,如果操作失敗后,會為。
spring-date-redis版本:1.6.2
場景:在使用setIfAbsent(key,value)時,想對key設置一個過期時間,同時需要用到setIfAbsent的返回值來指定之后的流程,所以使用了以下代碼:
boolean store = stringRedisTemplate.opsForValue().setIfAbsent(key,value); if(store){ stringRedisTemplate.expire(key,timeout); // todo something... }
這段代碼是有問題的:當setIfAbsent成功之后斷開連接,下面設置過期時間的代碼 stringRedisTemplate.expire(key,timeout); 是無法執行的,這時候就會有大量沒有過期時間的數據存在數據庫。想到一個辦法就是添加事務管理,修改后的代碼如下:
stringRedisTemplate.setEnableTransactionSupport(true); stringRedisTemplate.multi(); boolean store = stringRedisTemplate.opsForValue().setIfAbsent(key,value); if(store){ stringRedisTemplate.expire(key,timeout); } stringRedisTemplate.exec(); if(store){ // todo something... }
這樣就保證了整個流程的一致性。本因為這樣就可以了,可是事實總是不盡人意,因為我在文檔中發現了以下內容:
加了事務管理之后,setIfAbsent的返回值竟然是null,這樣就沒辦法再進行之后的判斷了。
好吧,繼續解決:
stringRedisTemplate.setEnableTransactionSupport(true); stringRedisTemplate.multi(); String result = stringRedisTemplate.opsForValue().get(key); if(StringUtils.isNotBlank(result)){ return false; } // 鎖的過期時間為1小時 stringRedisTemplate.opsForValue().set(key, value,timeout); stringRedisTemplate.exec(); // todo something...
上邊的代碼其實還是有問題的,當出現并發時,String result = stringRedisTemplate.opsForValue().get(key); 這里就會有多個線程同時拿到為空的key,然后同時寫入臟數據。
最終解決方法:
使用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會返回事務內每一個操作的結果,如果setIfAbsent操作失敗后,result[0]會為false。 if(true == result[0]){ // todo something... }
將redis版本升級到2.1以上,然后使用
直接在setIfAbsent中設置過期時間
update :
java 使用redis的事務時不能直接用Api中的multi()和exec(),這樣multi()和exec()兩次使用的stringRedisTemplate不是一個connect,會導致死鎖,正確方式如下:
private Boolean setLock(RecordEventModel event) { String lockKey = event.getModel() + ":" + event.getAction() + ":" + event.getId() + ":" + event.getMessage_id(); log.info("lockKey : {}" , lockKey); SessionCallbacksessionCallback = new SessionCallback () { List
文章版權歸作者所有,未經允許請勿轉載,若此文章存在違規行為,您可以聯系管理員刪除。
轉載請注明本文地址:http://specialneedsforspecialkids.com/yun/73071.html
摘要:它們都使用來做事件循環,不過是單線程的服務器也是多線程的,只不過除了主線程以外,其他線程沒有,只是會進行一些后臺存儲工作,而是多線程的。支持設置過期時間,即,但是內部并不定期檢查數據是否過期,而是客戶進程使用該數據的時候,會 歡迎大家前往騰訊云+社區,獲取更多騰訊海量技術實踐干貨哦~ 本文由Super發表于云+社區專欄 memcached和redis,作為近些年最常用的緩存服務器,相...
閱讀 1084·2021-10-08 10:04
閱讀 3523·2021-08-05 10:01
閱讀 2278·2019-08-30 11:04
閱讀 1794·2019-08-29 15:29
閱讀 836·2019-08-29 15:12
閱讀 1670·2019-08-26 12:11
閱讀 3115·2019-08-26 11:33
閱讀 1163·2019-08-26 10:23