基于redis setIfAbsent的使用說(shuō)明

更新時(shí)間：2021年01月22日 10:07:41 作者：chushiyunen

這篇文章主要介紹了基于redis setIfAbsent的使用說(shuō)明，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧

如果為空就set值，并返回1

如果存在(不為空)不進(jìn)行操作，并返回0

很明顯，比get和set要好。因?yàn)橄扰袛鄃et，再set的用法，有可能會(huì)重復(fù)set值。

setIfAbsent 和 setnx

setIfAbsent 是java中的方法

setnx 是 redis命令中的方法

setnx 例子

redis> SETNX mykey "Hello"
(integer) 1
redis> SETNX mykey "World"
(integer) 0
redis> GET mykey
"Hello"

setIfAbsent 例子

代碼：

BoundValueOperations boundValueOperations = this.redisTemplate.boundValueOps(redisKey);
flag = boundValueOperations.setIfAbsent(value); // flag 表示的是否set
boundValueOperations.expire(seconds, TimeUnit.SECONDS);
if(!flag){ // 重復(fù)
  repeatSerial.add(serialNo);
  continue;
}else{// 沒(méi)有重復(fù)
  norepeatSerial.add(serialNo);
}

補(bǔ)充：使用redis事物解決stringRedisTemplate.setIfAbsent()并設(shè)置過(guò)期時(shí)間遇到的問(wèn)題

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成功之后斷開(kāi)連接，下面設(shè)置過(guò)期時(shí)間的代碼stringRedisTemplate.expire(key,timeout); 是無(wú)法執(zhí)行的，這時(shí)候就會(huì)有大量沒(méi)有過(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，這樣就沒(méi)辦法再進(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í)寫(xiě)入臟數(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<Boolean> sessionCallback = new SessionCallback<Boolean>() {
      List<Object> 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);
  }

以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教。

您可能感興趣的文章: