本文整理了Java中redis.clients.jedis.JedisCommands.zadd()
方法的一些代码示例,展示了JedisCommands.zadd()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。JedisCommands.zadd()
方法的具体详情如下:
包路径:redis.clients.jedis.JedisCommands
类名称:JedisCommands
方法名:zadd
暂无
代码示例来源:origin: Netflix/conductor
public Long zadd(String key, double score, String member) {
Long retVal = dynoClient.zadd(key, score, member);
return retVal;
}
代码示例来源:origin: mpusher/mpush
/**
* @param key
* @param value
*/
public void zAdd(String key, String value) {
call(jedis -> jedis.zadd(key, 0, value));
}
代码示例来源:origin: Netflix/conductor
public Long zaddnx(String key, double score, String member) {
ZAddParams params = ZAddParams.zAddParams().nx();
Long retVal = dynoClient.zadd(key, score, member, params);
return retVal;
}
代码示例来源:origin: brianfrankcooper/YCSB
@Override
public Status insert(String table, String key,
Map<String, ByteIterator> values) {
if (jedis.hmset(key, StringByteIterator.getStringMap(values))
.equals("OK")) {
jedis.zadd(INDEX_KEY, hash(key), key);
return Status.OK;
}
return Status.ERROR;
}
代码示例来源:origin: apache/storm
jedisCommand.zadd(additionalKey, Double.valueOf(value), key);
break;
代码示例来源:origin: com.netflix.conductor/conductor-redis-persistence
public Long zadd(String key, double score, String member) {
Long retVal = dynoClient.zadd(key, score, member);
return retVal;
}
代码示例来源:origin: com.github.mpusher/mpush-cache
/**
* @param key
* @param value
*/
public void zAdd(String key, String value) {
call(jedis -> jedis.zadd(key, 0, value));
}
代码示例来源:origin: com.netflix.conductor/conductor-redis-persistence
public Long zaddnx(String key, double score, String member) {
ZAddParams params = ZAddParams.zAddParams().nx();
Long retVal = dynoClient.zadd(key, score, member, params);
return retVal;
}
代码示例来源:origin: Netflix/dyno-queues
long added = quorumConn.zadd(unackQueueName, unackScore, msgId, zParams);
if(added == 0){
if (logger.isDebugEnabled()) {
代码示例来源:origin: Netflix/dyno-queues
@Override
public boolean setUnackTimeout(String messageId, long timeout) {
Stopwatch sw = monitor.ack.start();
try {
return execute("setUnackTimeout", "(a shard in) " + queueName, () -> {
double unackScore = Long.valueOf(clock.millis() + timeout).doubleValue();
for (String shard : allShards) {
String unackShardKey = getUnackKey(queueName, shard);
Double score = quorumConn.zscore(unackShardKey, messageId);
if(score != null) {
quorumConn.zadd(unackShardKey, unackScore, messageId);
return true;
}
}
return false;
});
} finally {
sw.stop();
}
}
代码示例来源:origin: Netflix/dyno-queues
@Override
public List<String> push(final List<Message> messages) {
Stopwatch sw = monitor.start(monitor.push, messages.size());
try {
execute("push", "(a shard in) " + queueName, () -> {
for (Message message : messages) {
String json = om.writeValueAsString(message);
quorumConn.hset(messageStoreKey, message.getId(), json);
double priority = message.getPriority() / 100.0;
double score = Long.valueOf(clock.millis() + message.getTimeout()).doubleValue() + priority;
String shard = shardingStrategy.getNextShard(allShards, message);
String queueShard = getQueueShardKey(queueName, shard);
quorumConn.zadd(queueShard, score, message.getId());
}
return messages;
});
return messages.stream().map(msg -> msg.getId()).collect(Collectors.toList());
} finally {
sw.stop();
}
}
代码示例来源:origin: vakinge/jeesuite-libs
/**
* 新增元素
* @param score 权重
* @param value 元素
* @return
*/
public boolean add(double score, String value){
try {
boolean result = getJedisCommands(groupName).zadd(key, score, value) >= 1;
//设置超时时间
if(result)setExpireIfNot(expireTime);
return result;
} finally{
getJedisProvider(groupName).release();
}
}
代码示例来源:origin: vakinge/jeesuite-libs
@Override
public void putGroup(String cacheGroupKey, String key,long expireSeconds) {
long score = calcScoreInRegionKeysSet(expireSeconds);
JedisCommands commands = JedisProviderFactory.getJedisCommands(null);
try {
commands.zadd(cacheGroupKey, score, key);
commands.pexpire(cacheGroupKey, expireSeconds * 1000);
} finally{
JedisProviderFactory.getJedisProvider(null).release();
}
}
代码示例来源:origin: com.netflix.spinnaker.orca/orca-redis
@Override
public void store(@Nonnull Execution execution) {
RedisClientDelegate delegate = getRedisDelegate(execution);
storeExecutionInternal(delegate, execution);
if (execution.getType() == PIPELINE) {
delegate.withCommandsClient(c -> {
c.zadd(executionsByPipelineKey(execution.getPipelineConfigId()),
execution.getBuildTime() != null ? execution.getBuildTime() : currentTimeMillis(),
execution.getId()
);
});
}
}
代码示例来源:origin: Netflix/dyno-queues
@Override
public boolean setTimeout(String messageId, long timeout) {
return execute("setTimeout", "(a shard in) " + queueName, () -> {
String json = nonQuorumConn.hget(messageStoreKey, messageId);
if(json == null) {
return false;
}
Message message = om.readValue(json, Message.class);
message.setTimeout(timeout);
for (String shard : allShards) {
String queueShard = getQueueShardKey(queueName, shard);
Double score = quorumConn.zscore(queueShard, messageId);
if(score != null) {
double priorityd = message.getPriority() / 100;
double newScore = Long.valueOf(clock.millis() + timeout).doubleValue() + priorityd;
ZAddParams params = ZAddParams.zAddParams().xx();
quorumConn.zadd(queueShard, newScore, messageId, params);
json = om.writeValueAsString(message);
quorumConn.hset(messageStoreKey, message.getId(), json);
return true;
}
}
return false;
});
}
内容来源于网络,如有侵权,请联系作者删除!