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

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

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

JedisCluster.eval介绍

暂无

代码示例

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

public Object eval(String script, List<String> keys, List<String> args) {
  return jedisCluster.eval(script, keys, args);
}

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

public Object eval(byte[] script, int keyCount, byte[]... params) {
  return jedisCluster.eval(script, keyCount, params);
}

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

public Object eval(String script, int keyCount, String... params) {
  return jedisCluster.eval(script, keyCount, params);
}

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

public Object eval(byte[] script, List<byte[]> keys, List<byte[]> args) {
  return jedisCluster.eval(script, keys, args);
}

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

public Object eval(byte[] script, byte[] keyCount, byte[]... params) {
  return jedisCluster.eval(script, keyCount, params);
}

代码示例来源:origin: liuht777/Taroco

private Object limitRequest(Object connection) {
  Object result;
  String key = String.valueOf(System.currentTimeMillis() / 1000);
  if (connection instanceof Jedis) {
    result = ((Jedis) connection).eval(script, Collections.singletonList(key), Collections.singletonList(String.valueOf(limit)));
    ((Jedis) connection).close();
  } else {
    result = ((JedisCluster) connection).eval(script, Collections.singletonList(key), Collections.singletonList(String.valueOf(limit)));
    try {
      ((JedisCluster) connection).close();
    } catch (IOException e) {
      log.error("limit IOException", e);
    }
  }
  return result;
}

代码示例来源:origin: crossoverJie/distributed-redis-tool

private Object limitRequest(Object connection) {
  Object result = null;
  String key = String.valueOf(System.currentTimeMillis() / 1000);
  if (connection instanceof Jedis){
    result = ((Jedis)connection).eval(script, Collections.singletonList(key), Collections.singletonList(String.valueOf(limit)));
    ((Jedis) connection).close();
  }else {
    result = ((JedisCluster) connection).eval(script, Collections.singletonList(key), Collections.singletonList(String.valueOf(limit)));
    try {
      ((JedisCluster) connection).close();
    } catch (IOException e) {
      logger.error("IOException",e);
    }
  }
  return result;
}

代码示例来源:origin: lfz757077613/MyBlog

public boolean unlock(String key, String uuid) {
    if (StringUtils.isAnyBlank(key, uuid)) {
      return false;
    }
    key = RedisKey.getKey(RedisKey.DISTRIBUTED_LOCK_PRE, key);
    try {
      Object result = cluster.eval(UNLOCK_SCRIPT, Collections.singletonList(key), Collections.singletonList(uuid));
      if (UNLOCK_SUCC.equals(result)) {
        return true;
      }
      return false;
    } catch (Exception e) {
      log.error("unlock error, key:{}, uuid:{}", key, uuid, e);
      return false;
    }
  }
}

代码示例来源:origin: liuht777/Taroco

return (Long) ((JedisCluster) nativeConnection).eval(UNLOCK_LUA, keys, args);

代码示例来源:origin: com.github.ddth/ddth-dlock-core

/**
   * {@inheritDoc}
   */
  @Override
  public LockResult unlock(String clientId) {
    if (StringUtils.isBlank(clientId)) {
      throw new IllegalArgumentException("Invalid ClientID!");
    }

    JedisCluster jedis = getJedis();
    String key = getName();
    Object response = jedis.eval(getScriptUnlock(), 0, key, clientId);
    if (response == null) {
      return LockResult.HOLD_BY_ANOTHER_CLIENT;
    } else if ("0".equals(response.toString())) {
      return LockResult.NOT_FOUND;
    } else {
      return LockResult.SUCCESSFUL;
    }
  }
}

代码示例来源:origin: crossoverJie/distributed-redis-tool

/**
 * unlock
 *
 * @param key
 * @param request request must be the same as lock request
 * @return
 */
public boolean unlock(String key, String request) {
  //get connection
  Object connection = getConnection();
  //lua script
  Object result = null;
  if (connection instanceof Jedis) {
    result = ((Jedis) connection).eval(script, Collections.singletonList(lockPrefix + key), Collections.singletonList(request));
    ((Jedis) connection).close();
  } else if (connection instanceof JedisCluster) {
    result = ((JedisCluster) connection).eval(script, Collections.singletonList(lockPrefix + key), Collections.singletonList(request));
  } else {
    //throw new RuntimeException("instance is error") ;
    return false;
  }
  if (UNLOCK_MSG.equals(result)) {
    return true;
  } else {
    return false;
  }
}

代码示例来源:origin: com.y3tu/y3tu-tool-web

return (Long) ((JedisCluster) nativeConnection).eval(UNLOCK_LUA, keys, args);

代码示例来源:origin: wyh-spring-ecosystem-student/spring-boot-student

result = (Long) ((JedisCluster) nativeConnection).eval(UNLOCK_LUA, keys, values);

代码示例来源:origin: daijiejay/daijie

return (Long) jedisCluster.eval(script, keys, args);
}finally {
  if(jedisCluster!=null){

代码示例来源:origin: com.y3tu/y3tu-tool-web

result = (Long) ((JedisCluster) nativeConnection).eval(UNLOCK_LUA, keys, values);

代码示例来源:origin: com.github.ddth/ddth-dlock-core

Object response = jedis.eval(getScriptLock(), 0, key, clientId,
    String.valueOf(lockDurationMs));
if (response == null) {

相关文章

微信公众号

最新文章

更多

JedisCluster类方法