redis.clients.jedis.Jedis.unwatch()方法的使用及代码示例

x33g5p2x  于2022-01-21 转载在 其他  
字(3.4k)|赞(0)|评价(0)|浏览(209)

本文整理了Java中redis.clients.jedis.Jedis.unwatch()方法的一些代码示例,展示了Jedis.unwatch()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Jedis.unwatch()方法的具体详情如下:
包路径:redis.clients.jedis.Jedis
类名称:Jedis
方法名:unwatch

Jedis.unwatch介绍

暂无

代码示例

代码示例来源:origin: spring-projects/spring-data-redis

@Override
public void unwatch() {
  try {
    jedis.unwatch();
  } catch (Exception ex) {
    throw convertJedisAccessException(ex);
  }
}

代码示例来源:origin: qiurunze123/miaosha

/**
 * watch 监控多个key 一防止其他地方调用释放锁的时候对这个key进行修改 那么事务里面的代码就不会被执行 !
 */
  public boolean releaseLock(String key , String value){
    try {
      Jedis jedis = RedisManager.getJedis();
      while (true){
        jedis.watch(key);
        if(value.equals(jedis.get(key))){
          Transaction transaction = jedis.multi();
          transaction.del(key);
          List<Object> list = transaction.exec();
          if(list ==null){
            continue;
          }
          jedis.unwatch();
        }
      }
    } catch (Exception e) {
      e.printStackTrace();
    }
    return false;
  }
}

代码示例来源:origin: davidmarquis/redis-scheduler

@Override
public void unwatch() {
  jedis.unwatch();
}

代码示例来源:origin: penggle/jedis-ms-sentinel

public String unwatch() {
  return master.unwatch();
}

代码示例来源:origin: org.springframework.data/spring-data-redis

@Override
public void unwatch() {
  try {
    jedis.unwatch();
  } catch (Exception ex) {
    throw convertJedisAccessException(ex);
  }
}

代码示例来源:origin: com.netflix.spinnaker.kork/kork-jedis

@Override
public String unwatch() {
 String command = "unwatch";
 return instrumented(command, () -> delegated.unwatch());
}

代码示例来源:origin: apache/servicemix-bundles

@Override
public void unwatch() {
  try {
    jedis.unwatch();
  } catch (Exception ex) {
    throw convertJedisAccessException(ex);
  }
}

代码示例来源:origin: mindwind/craft-atom

private String unwatch0(Jedis j) {
  try {
    return j.unwatch();
  } finally {
    unbind();
  }
}

代码示例来源:origin: io.enoa/nosql-redis

default String unwatch() {
 return this.run((jedis, serializer) -> jedis.unwatch());
}

代码示例来源:origin: org.nutz/nutz-integration-jedis

public String unwatch() {
  Jedis jedis = getJedis();
  try {
    return jedis.unwatch();
  } finally {Streams.safeClose(jedis);}
}

代码示例来源:origin: appleappleapple/DistributeLearning

e.printStackTrace();
} finally {
  jedis.unwatch();
  RedisUtil.returnResource(jedis);

代码示例来源:origin: io.github.rcarlosdasilva/weixin

@Override
public boolean unlock(String key, String identifier) {
 Preconditions.checkNotNull(key);
 Preconditions.checkNotNull(identifier);
 String fullKey = RedisKey.fullKey(group, key) + LOCKER_NAME_SUFFIX;
 Jedis jedis = RedisHandler.getJedis();
 while (true) {
  // 监视lock,准备开始事务
  jedis.watch(fullKey);
  // 看看是不是自己的锁
  if (identifier.equals(jedis.get(fullKey))) {
   Transaction transaction = jedis.multi();
   transaction.del(fullKey);
   List<Object> results = transaction.exec();
   if (results == null) {
    continue;
   }
   jedis.close();
   return true;
  }
  jedis.unwatch();
  break;
 }
 jedis.close();
 return false;
}

代码示例来源:origin: youtongluan/sumk

@Override
public java.lang.String unwatch() {
  Exception e1 = null;
  for (int i = 0; i < tryCount; i++) {
    Jedis jedis = null;
    try {
      jedis = pool.getResource();
      return jedis.unwatch();
    } catch (Exception e) {
      if (isConnectException(e)) {
        Log.get(LOG_NAME).error(this.hosts + " - redis connection failed,idle=" + pool.getNumIdle()
            + ",active=" + pool.getNumActive(), e);
        e1 = e;
        continue;
      }
      Log.get(LOG_NAME).error("unwatch - redis execute error!" + e.getMessage(), e);
      SumkException.throwException(12342411, e.getMessage(), e);
    } finally {
      close(jedis);
    }
  }
  handleRedisException(e1);
  throw new SumkException(12342423, "未知redis异常");
}

代码示例来源:origin: Comcast/cmb

j.unwatch();
return false;

代码示例来源:origin: SkyScraperTwc/SecKillDesign

jedis.unwatch();

代码示例来源:origin: Comcast/cmb

j.unwatch();
throw new SetFailedException();

代码示例来源:origin: Comcast/cmb

j.unwatch();
throw new SetFailedException();

相关文章

Jedis类方法