本文整理了Java中redis.clients.jedis.Jedis.randomBinaryKey()
方法的一些代码示例,展示了Jedis.randomBinaryKey()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Jedis.randomBinaryKey()
方法的具体详情如下:
包路径:redis.clients.jedis.Jedis
类名称:Jedis
方法名:randomBinaryKey
暂无
代码示例来源:origin: spring-projects/spring-data-redis
public byte[] randomKey(RedisClusterNode node) {
Assert.notNull(node, "RedisClusterNode must not be null!");
return connection.getClusterCommandExecutor()
.executeCommandOnSingleNode((JedisClusterCommandCallback<byte[]>) client -> client.randomBinaryKey(), node)
.getValue();
}
代码示例来源:origin: spring-projects/spring-data-redis
@Override
public byte[] randomKey() {
try {
if (isPipelined()) {
pipeline(connection.newJedisResult(connection.getRequiredPipeline().randomKeyBinary()));
return null;
}
if (isQueueing()) {
transaction(connection.newJedisResult(connection.getRequiredTransaction().randomKeyBinary()));
return null;
}
return connection.getJedis().randomBinaryKey();
} catch (Exception ex) {
throw connection.convertJedisAccessException(ex);
}
}
代码示例来源:origin: penggle/jedis-ms-sentinel
public byte[] randomBinaryKey() {
return master.randomBinaryKey();
}
代码示例来源:origin: com.netflix.spinnaker.kork/kork-jedis
@Override
public byte[] randomBinaryKey() {
String command = "randomBinaryKey";
return instrumented(command, () -> delegated.randomBinaryKey());
}
代码示例来源:origin: org.nutz/nutz-integration-jedis
/**
* Return a randomly selected key from the currently selected DB.
* <p>
* Time complexity: O(1)
*
* @return Singe line reply, specifically the randomly selected key or an empty string is the
* database is empty
*/
public byte[] randomBinaryKey() {
Jedis jedis = getJedis();
try {
return jedis.randomBinaryKey();
} finally {Streams.safeClose(jedis);}
}
代码示例来源:origin: org.springframework.data/spring-data-redis
public byte[] randomKey(RedisClusterNode node) {
Assert.notNull(node, "RedisClusterNode must not be null!");
return connection.getClusterCommandExecutor()
.executeCommandOnSingleNode((JedisClusterCommandCallback<byte[]>) client -> client.randomBinaryKey(), node)
.getValue();
}
代码示例来源:origin: apache/servicemix-bundles
public byte[] randomKey(RedisClusterNode node) {
Assert.notNull(node, "RedisClusterNode must not be null!");
return connection.getClusterCommandExecutor()
.executeCommandOnSingleNode((JedisClusterCommandCallback<byte[]>) client -> client.randomBinaryKey(), node)
.getValue();
}
代码示例来源:origin: youtongluan/sumk
@Override
public byte[] randomBinaryKey() {
Exception e1 = null;
for (int i = 0; i < tryCount; i++) {
Jedis jedis = null;
try {
jedis = pool.getResource();
return jedis.randomBinaryKey();
} 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("randomBinaryKey - redis execute error!" + e.getMessage(), e);
SumkException.throwException(12342411, e.getMessage(), e);
} finally {
close(jedis);
}
}
handleRedisException(e1);
throw new SumkException(12342423, "未知redis异常");
}
代码示例来源:origin: apache/servicemix-bundles
@Override
public byte[] randomKey() {
try {
if (isPipelined()) {
pipeline(connection.newJedisResult(connection.getRequiredPipeline().randomKeyBinary()));
return null;
}
if (isQueueing()) {
transaction(connection.newJedisResult(connection.getRequiredTransaction().randomKeyBinary()));
return null;
}
return connection.getJedis().randomBinaryKey();
} catch (Exception ex) {
throw connection.convertJedisAccessException(ex);
}
}
代码示例来源:origin: org.springframework.data/spring-data-redis
@Override
public byte[] randomKey() {
try {
if (isPipelined()) {
pipeline(connection.newJedisResult(connection.getRequiredPipeline().randomKeyBinary()));
return null;
}
if (isQueueing()) {
transaction(connection.newJedisResult(connection.getRequiredTransaction().randomKeyBinary()));
return null;
}
return connection.getJedis().randomBinaryKey();
} catch (Exception ex) {
throw connection.convertJedisAccessException(ex);
}
}
内容来源于网络,如有侵权,请联系作者删除!