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

x33g5p2x  于2022-01-28 转载在 其他  
字(5.8k)|赞(0)|评价(0)|浏览(143)

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

RedisTemplate.opsForZSet介绍

暂无

代码示例

代码示例来源:origin: yu199195/Raincat

@Override
public Boolean batchRemove(final List<String> txGroupIdList) {
  if (CollectionUtils.isEmpty(txGroupIdList)) {
    return false;
  }
  try {
    for (String key : txGroupIdList) {
      redisTemplate.opsForZSet().remove(CommonConstant.REDIS_KEY_SET, key);
    }
    final List<String> keys = txGroupIdList.stream().map(txGroupId ->
        String.format(CommonConstant.REDIS_PRE_FIX, txGroupId)).collect(Collectors.toList());
    redisTemplate.delete(keys);
    return true;
  } catch (Exception e) {
    e.printStackTrace();
    return false;
  }
}

代码示例来源: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: yu199195/Raincat

} else {
  keys = redisTemplate.keys(CommonConstant.REDIS_KEYS);
  rangeKeys = redisTemplate.opsForZSet()
      .range(CommonConstant.REDIS_KEY_SET, start, end - 1);

代码示例来源:origin: yjjdick/sdb-mall

@Bean
  public ZSetOperations<String, Object> zSetOperations(RedisTemplate<String, Object> redisTemplate) {
    return redisTemplate.opsForZSet();
  }
}

代码示例来源:origin: JayTange/Jantent

/**
   * 对有序集合类型的数据操作
   *
   * @param redisTemplate
   * @return
   */
  @Bean
  public ZSetOperations<String, Object> zSetOperations(RedisTemplate<String, Object> redisTemplate) {
    return redisTemplate.opsForZSet();
  }
}

代码示例来源:origin: yzcheng90/X-SpringBoot

@Bean
  public ZSetOperations<String, Object> zSetOperations(RedisTemplate<String, Object> redisTemplate) {
    return redisTemplate.opsForZSet();
  }
}

代码示例来源:origin: JayTange/springbootRedis

/**
   * 对有序集合类型的数据操作
   *
   * @param redisTemplate
   * @return
   */
  @Bean
  public ZSetOperations<String, Object> zSetOperations(RedisTemplate<String, Object> redisTemplate) {
    return redisTemplate.opsForZSet();
  }
}

代码示例来源: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: chenerzhu/proxy-pool

@Override
  public long totalCountRt() {
    return redisCacheTemplate.opsForZSet().size(RedisKey.PROXY_IP_RT_KEY);
  }
}

代码示例来源:origin: chenerzhu/proxy-pool

@Override
public List<Serializable> findAllByPage(int pageNumber, int pageSize) {
  Set<Serializable> set = redisCacheTemplate.opsForZSet().range(RedisKey.PROXY_IP_KEY, pageNumber*pageSize, (pageNumber+1)*pageSize);
  return new ArrayList<Serializable>(set);
}

代码示例来源: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: 5-Ason/ason-spring-cloud

/**
   * 有序集合获取
   * @param key
   * @param scoure
   * @param scoure1
   * @return
   */
  public Set<Object> rangeByScore(String key,double scoure,double scoure1){
    ZSetOperations<String, Object> zset = redisTemplate.opsForZSet();
    return zset.rangeByScore(key, scoure, scoure1);
  }
}

代码示例来源:origin: chenerzhu/proxy-pool

@Override
public List<Serializable> findAllByPageRt(int pageNumber, int pageSize) {
  Set<Serializable> set = redisCacheTemplate.opsForZSet().range(RedisKey.PROXY_IP_RT_KEY, pageNumber*pageSize, (pageNumber+1)*pageSize);
  return new ArrayList<Serializable>(set);
}

代码示例来源:origin: xuyaohui/cloud-ida-cli

/**
   * 有序集合获取
   * @param key
   * @param scoure
   * @param scoure1
   * @return
   */
  public Set<Object> rangeByScore(String key,double scoure,double scoure1){
    ZSetOperations<String, Object> zset = redisTemplate.opsForZSet();
    return zset.rangeByScore(key, scoure, scoure1);
  }
}

代码示例来源:origin: chenerzhu/proxy-pool

@Override
public ProxyIp getOneRt() {
  int totalCount = (int) totalCountRt();
  int range=new Random().nextInt(totalCount);
  Set<Serializable> set = redisCacheTemplate.opsForZSet().range(RedisKey.PROXY_IP_RT_KEY, range, range);
  return (ProxyIp) new ArrayList<Serializable>(set).get(0);
}

代码示例来源:origin: chenerzhu/proxy-pool

@Override
public ProxyIp getOne() {
  int totalCount = (int) totalCountRt();
  int range=new Random().nextInt(totalCount);
  Set<Serializable> set = redisCacheTemplate.opsForZSet().range(RedisKey.PROXY_IP_KEY, range, range);
  return (ProxyIp) new ArrayList<Serializable>(set).get(0);
}

代码示例来源:origin: chenerzhu/proxy-pool

@Override
public boolean add(ProxyIp proxyIp) {
  return redisCacheTemplate.opsForZSet().add(RedisKey.PROXY_IP_KEY, proxyIp, proxyIp.getId());
}

代码示例来源:origin: chenerzhu/proxy-pool

@Override
public boolean isExist(ProxyIp proxyIp) {
  Set<Serializable> set = redisCacheTemplate.opsForZSet().rangeByScore(RedisKey.PROXY_IP_KEY, proxyIp.getId(), proxyIp.getId());
  if (set.isEmpty()) {
    return false;
  } else {
    return true;
  }
}

代码示例来源:origin: chenerzhu/proxy-pool

@Override
public boolean isExistRt(ProxyIp proxyIp) {
  Set<Serializable> set = redisCacheTemplate.opsForZSet().rangeByScore(RedisKey.PROXY_IP_RT_KEY, proxyIp.getId(), proxyIp.getId());
  if (set.isEmpty()) {
    return false;
  } else {
    return true;
  }
}

代码示例来源:origin: Alex-Jerry/Java-Poetry

@Autowired
public RedisDBHelperImpl(RedisTemplate<String, T> redisTemplate) {
  this.redisTemplate = redisTemplate;
  this.hashOperations = redisTemplate.opsForHash();
  this.listOperations = redisTemplate.opsForList();
  this.zSetOperations = redisTemplate.opsForZSet();
  this.setOperations = redisTemplate.opsForSet();
  this.valueOperations = redisTemplate.opsForValue();
}

相关文章

微信公众号

最新文章

更多