org.springframework.data.redis.core.ZSetOperations.add()方法的使用及代码示例

x33g5p2x  于2022-02-05 转载在 其他  
字(5.4k)|赞(0)|评价(0)|浏览(93)

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

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;
}

相关文章