本文整理了Java中org.springframework.data.redis.core.ZSetOperations.add()
方法的一些代码示例,展示了ZSetOperations.add()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZSetOperations.add()
方法的具体详情如下:
包路径:org.springframework.data.redis.core.ZSetOperations
类名称:ZSetOperations
方法名:add
[英]Add value to a sorted set at key, or update its score if it already exists.
[中]
代码示例来源:origin: spring-projects/spring-data-redis
@Override
public Long add(Set<TypedTuple<V>> tuples) {
return ops.add(getKey(), tuples);
}
代码示例来源:origin: spring-projects/spring-data-redis
@Override
public Boolean add(V value, double score) {
return ops.add(getKey(), value, score);
}
代码示例来源:origin: yu199195/Raincat
@Override
public Boolean saveTxTransactionGroup(final TxTransactionGroup txTransactionGroup) {
try {
final String groupId = txTransactionGroup.getId();
//保存数据 到sortSet
redisTemplate.opsForZSet().add(CommonConstant.REDIS_KEY_SET, groupId, CommonConstant.REDIS_SCOPE);
final List<TxTransactionItem> itemList = txTransactionGroup.getItemList();
if (CollectionUtils.isNotEmpty(itemList)) {
for (TxTransactionItem item : itemList) {
redisTemplate.opsForHash().put(cacheKey(groupId), item.getTaskKey(), item);
}
}
} catch (Exception e) {
return false;
}
return true;
}
代码示例来源:origin: whvcse/EasyWeb
/**
* 添加元素,有序集合是按照元素的score值由小到大排列
*
* @param key
* @param value
* @param score
* @return
*/
public Boolean zAdd(String key, String value, double score) {
return redisTemplate.opsForZSet().add(key, value, score);
}
代码示例来源:origin: xuyaohui/cloud-ida-cli
/**
* 有序集合添加
* @param key
* @param value
* @param scoure
*/
public void zAdd(String key,Object value,double scoure){
ZSetOperations<String, Object> zset = redisTemplate.opsForZSet();
zset.add(key,value,scoure);
}
代码示例来源:origin: whvcse/EasyWeb
/**
* @param key
* @param values
* @return
*/
public Long zAdd(String key, Set<TypedTuple<String>> values) {
return redisTemplate.opsForZSet().add(key, values);
}
代码示例来源:origin: apache/servicemix-bundles
@Override
public Long add(Set<TypedTuple<V>> tuples) {
return ops.add(getKey(), tuples);
}
代码示例来源:origin: davidmarquis/redis-scheduler
@Override
public void addToSetWithScore(String key, String taskId, long score) {
ops.opsForZSet().add(key, taskId, score);
}
代码示例来源:origin: apache/servicemix-bundles
@Override
public Boolean add(V value, double score) {
return ops.add(getKey(), value, score);
}
代码示例来源:origin: org.springframework.data/spring-data-redis
@Override
public Boolean add(V value, double score) {
return ops.add(getKey(), value, score);
}
代码示例来源:origin: org.springframework.data/spring-data-redis
@Override
public Long add(Set<TypedTuple<V>> tuples) {
return ops.add(getKey(), tuples);
}
代码示例来源:origin: 5-Ason/ason-spring-cloud
/**
* 有序集合添加
* @param key
* @param value
* @param scoure
*/
public void zAdd(String key,Object value,double scoure){
ZSetOperations<String, Object> zset = redisTemplate.opsForZSet();
zset.add(key,value,scoure);
}
代码示例来源:origin: code4wt/short-url
public void addInUseCache(Long initialCode) {
template.opsForZSet().add(IN_USE_INITIAL_CODES, initialCode.toString(), System.currentTimeMillis());
}
代码示例来源:origin: eventuate-examples/eventuate-examples-restaurant-management
private void addAvailabilityIndexEntries(String id, RestaurantInfo restaurant) {
getEntries(id, restaurant).forEach(entry -> redisTemplate.opsForZSet().add(entry.key, entry.value, entry.score));
}
代码示例来源:origin: vakinge/jeesuite-libs
@Override
public void putGroup(String cacheGroupKey, String key, long expireSeconds) {
long score = calcScoreInRegionKeysSet(expireSeconds);
stringRedisTemplate.opsForZSet().add(cacheGroupKey, key, score);
}
代码示例来源:origin: sentilo/sentilo
@Override
public void save(final List<NotificationRetryEvent> notifications) {
// The difference between this method and the previous is that it save notifications that don't
// have been processed by the retry job (for example due to an error while running job). These
// events are pulling again with a new score of 1 minute
final double newScore = System.currentTimeMillis() + 60 * 1000;
for (final NotificationRetryEvent notification : notifications) {
redisTemplate.opsForZSet().add(SORTED_SET_KEY, eventParser.marshall(notification), newScore);
LOGGER.debug("Message {} saved to be processed after {} millisecods.", notification.getMessage(), newScore);
}
}
代码示例来源:origin: chenerzhu/proxy-pool
@Override
public boolean addRt(ProxyIp proxyIp) {
return redisCacheTemplate.opsForZSet().add(RedisKey.PROXY_IP_RT_KEY, proxyIp, proxyIp.getId());
}
代码示例来源:origin: chenerzhu/proxy-pool
@Override
public boolean add(ProxyIp proxyIp) {
return redisCacheTemplate.opsForZSet().add(RedisKey.PROXY_IP_KEY, proxyIp, proxyIp.getId());
}
代码示例来源:origin: sentilo/sentilo
private void updateFrozenTimeout(final InternalAlert frozenAlert) {
final long currentTimestamp = System.currentTimeMillis();
try {
final String value = AlertUtils.buildFrozenAlertMember(frozenAlert);
LOGGER.debug("Updating frozen timeout for member {}", value);
final double maxFrozenMinutes = AlertUtils.transformNumber(frozenAlert.getExpression()).doubleValue();
final double score = currentTimestamp + maxFrozenMinutes * 60 * 1000;
redisTemplate.opsForZSet().add(SORTED_SET_KEY, value, score);
LOGGER.debug("Frozen timeout for member {} updated to {}", value, score);
} catch (final ParseException e) {
LOGGER.warn("Cannot update frozen timeout for alert {}", frozenAlert.getId(), e);
}
}
代码示例来源:origin: ihaolin/antares
@Override
public Boolean addDependence(JobDependence dependence) {
String jobNextJobsKey = RedisKeys.keyOfJobNextJobs(dependence.getJobId());
Long nextJobId = dependence.getNextJobId();
redis.opsForZSet().add(jobNextJobsKey, nextJobId + "", nextJobId.doubleValue());
return Boolean.TRUE;
}
内容来源于网络,如有侵权,请联系作者删除!