本文整理了Java中redis.clients.jedis.JedisCluster.eval()
方法的一些代码示例,展示了JedisCluster.eval()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。JedisCluster.eval()
方法的具体详情如下:
包路径:redis.clients.jedis.JedisCluster
类名称: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) {
内容来源于网络,如有侵权,请联系作者删除!