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

Tuple.getScore介绍

暂无

代码示例

代码示例来源：origin: sohutv/cachecloud

public int compareTo(Tuple other) {
 if (this.score == other.getScore() || Arrays.equals(this.element, other.element)) return 0;
 else return this.score < other.getScore() ? -1 : 1;
}

代码示例来源：origin: caoxinyu/RedisClient

@Override
public String[] getText(int row) {
  String[] values = new String[]{"", ""};
  
  int index = row-start;
  if(index == -1)
    return new String[]{"", ""};
  if(index < page.length){
    Tuple tuple = (Tuple) page[index];
    values = new String[]{String.valueOf(tuple.getScore()), tuple.getElement()};
  }
  
  return values;
}

代码示例来源：origin: spring-projects/spring-data-redis

/**
 * Deprecated. Use #{@link JedisConverters#toTupleSet(Set)}
 */
@Deprecated
static Set<Tuple> convertJedisTuple(Set<redis.clients.jedis.Tuple> tuples) {
  Set<Tuple> value = new LinkedHashSet<>(tuples.size());
  for (redis.clients.jedis.Tuple tuple : tuples) {
    value.add(new DefaultTuple(tuple.getBinaryElement(), tuple.getScore()));
  }
  return value;
}

代码示例来源：origin: signalapp/Signal-Server

private void persistQueue(ReplicatedJedisPool jedisPool, Key key) throws IOException {
 Timer.Context timer = persistQueueTimer.time();
 int messagesPersistedCount = 0;
 try (Jedis jedis = jedisPool.getWriteResource()) {
  while (true) {
   jedis.setex(key.getUserMessageQueuePersistInProgress(), 30, "1".getBytes());
   Set<Tuple> messages = jedis.zrangeWithScores(key.getUserMessageQueue(), 0, CHUNK_SIZE);
   for (Tuple message : messages) {
    persistMessage(key, (long)message.getScore(), message.getBinaryElement());
    messagesPersistedCount++;
   }
   if (messages.size() < CHUNK_SIZE) {
    jedis.del(key.getUserMessageQueuePersistInProgress());
    return;
   }
  }
 } finally {
  timer.stop();
  queueSizeHistogram.update(messagesPersistedCount);
 }
}

代码示例来源：origin: io.leopard/leopard-redis

/**
 * 将有序集中元素对应的score转成Double，保存到集合中.
 * 
 * @param set
 * @return
 */
public static Set<Double> tupleToScores(Set<Tuple> set) {
  Set<Double> result = new LinkedHashSet<Double>();
  for (Tuple tuple : set) {
    Double score = tuple.getScore();
    result.add(score);
  }
  return result;
}

代码示例来源：origin: io.leopard/leopard-redis

/**
 * 获取第一个元素的score.
 * 
 * @param set
 * @return
 */
public static Double getFirstScore(Set<Tuple> set) {
  if (set == null || set.isEmpty()) {
    return null;
  }
  Tuple tuple = set.iterator().next();
  Double score = tuple.getScore();
  return score;
}

代码示例来源：origin: mindwind/craft-atom

private Map<String, Double> convert4zrangewithscores(Set<Tuple> set) {
  Map<String, Double> map = new LinkedHashMap<String, Double>(set.size());
  for (Tuple tuple : set) {
    map.put(tuple.getElement(), tuple.getScore());
  }
  return map;
}

代码示例来源：origin: mindwind/craft-atom

private List<Map.Entry<String, Double>> convert(List<Tuple> list) {
  if (list == null || list.isEmpty()) return Collections.emptyList();
  
  List<Map.Entry<String, Double>> l = new ArrayList<Map.Entry<String,Double>>(list.size());
  for (Tuple tuple : list) {
    Map.Entry<String, Double> entry = new AbstractMap.SimpleEntry<String, Double>(tuple.getElement(), tuple.getScore());
    l.add(entry);
  }
  return l;
}

代码示例来源：origin: org.springframework.data/spring-data-redis

/**
 * Deprecated. Use #{@link JedisConverters#toTupleSet(Set)}
 */
@Deprecated
static Set<Tuple> convertJedisTuple(Set<redis.clients.jedis.Tuple> tuples) {
  Set<Tuple> value = new LinkedHashSet<>(tuples.size());
  for (redis.clients.jedis.Tuple tuple : tuples) {
    value.add(new DefaultTuple(tuple.getBinaryElement(), tuple.getScore()));
  }
  return value;
}

代码示例来源：origin: io.leopard/leopard-redis

/**
 * 将有序集转成List.
 * 
 * @param set 有序集
 * @return
 */
public static List<Entry<String, Double>> toEntryList(Set<Tuple> set) {
  if (set == null || set.isEmpty()) {
    return null;
  }
  List<Entry<String, Double>> result = new ArrayList<Entry<String, Double>>();
  for (Tuple tuple : set) {
    String element = tuple.getElement();
    Double score = tuple.getScore();
    Entry<String, Double> entry = new SimpleEntry<String, Double>(element, score);
    result.add(entry);
  }
  return result;
}

代码示例来源：origin: apache/servicemix-bundles

/**
 * Deprecated. Use #{@link JedisConverters#toTupleSet(Set)}
 */
@Deprecated
static Set<Tuple> convertJedisTuple(Set<redis.clients.jedis.Tuple> tuples) {
  Set<Tuple> value = new LinkedHashSet<>(tuples.size());
  for (redis.clients.jedis.Tuple tuple : tuples) {
    value.add(new DefaultTuple(tuple.getBinaryElement(), tuple.getScore()));
  }
  return value;
}

代码示例来源：origin: xetorthio/rmq

private int getLastReadMessage() {
  Double lastMessageRead = subscriber.zscore(id);
  if (lastMessageRead == null) {
    Set<Tuple> zrangeWithScores = subscriber.zrangeWithScores(0, 1);
    if (zrangeWithScores.iterator().hasNext()) {
      Tuple next = zrangeWithScores.iterator().next();
      Integer lowest = (int) next.getScore() - 1;
      subscriber.zadd(lowest, id);
      return lowest;
    } else {
      return 0;
    }
  }
  return lastMessageRead.intValue();
}

代码示例来源：origin: yrain/smart-cache

public Set<Tuple> convertTupleToTupl(final Set<redis.clients.jedis.Tuple> tuples) {
  Set<Tuple> tupls = Sets.newHashSet();
  for (redis.clients.jedis.Tuple tuple : tuples) {
    Object element = deserializeVal(tuple.getBinaryElement());
    Double score = tuple.getScore();
    tupls.add(new Tuple(element, score));
  }
  return tupls;
}

代码示例来源：origin: io.leopard/leopard-biz

protected void load() {
  Set<Tuple> set = this.sortedSetBizRedisImpl.listAll();
  // System.err.println("load set:" + set);
  if (set == null || set.isEmpty()) {
    return;
  }
  for (Tuple tuple : set) {
    String element = tuple.getElement();
    double score = tuple.getScore();
    this.sortedSetBizMemoryImpl.zadd(element, score);
  }
}

代码示例来源：origin: xetorthio/rmq

public void clean() {
  Set<Tuple> zrangeWithScores = subscriber.zrangeWithScores(0, 1);
  Tuple next = zrangeWithScores.iterator().next();
  Integer lowest = (int) next.getScore();
  topic.cat("message").cat(lowest).del();
}

代码示例来源：origin: Baqend/Orestes-Bloomfilter

@Override
public TimeMap<String> getExpirationMap() {
  try (Jedis jedis = pool.getResource()) {
    return jedis.zrangeWithScores(keys.EXPIRATION_QUEUE_KEY.getBytes(), 0, -1)
      .stream()
      .collect(TimeMap.collectMillis(
        tuple -> msgPack.decodeItem(tuple.getBinaryElement()),
        tuple -> (long) tuple.getScore()
      ));
  }
}

代码示例来源：origin: com.github.sogyf/goja-mvt

private int getLastReadMessage() {
  Double lastMessageRead = JedisKit.zscore(subscriber.key(), id);
  if (lastMessageRead == null) {
    Set<Tuple> zrangeWithScores = JedisKit.zrangeWithScores(subscriber.key(), 0, 1);
    if (zrangeWithScores.iterator().hasNext()) {
      Tuple next = zrangeWithScores.iterator().next();
      Integer lowest = (int) next.getScore() - 1;
      JedisKit.zadd(subscriber.key(), lowest, id);
      return lowest;
    } else {
      return 0;
    }
  }
  return lastMessageRead.intValue();
}

代码示例来源：origin: Baqend/Orestes-Bloomfilter

@Override
public TimeMap<T> getTimeToLiveMap() {
  try (Jedis jedis = pool.getResource()) {
    Set<Tuple> tuples = jedis.zrangeByScoreWithScores(keys.TTL_KEY, now() - config.gracePeriod(), Double.POSITIVE_INFINITY);
    return tuples.stream().collect(TimeMap.collectMillis(t -> (T) t.getElement(), t -> (long) t.getScore()));
  }
}

代码示例来源：origin: org.nanoframework/nano-orm-jedis

@Override
  public ScanResult<Entry<String, Double>> zscan(final String key, final long cursor, final ScanParams params) {
    Assert.hasText(key);
    Assert.notNull(params);

    try {
      final ScanResult<Tuple> res = cluster.zscan(key, String.valueOf(cursor), params);
      final List<Tuple> tuples = res.getResult();
      if (CollectionUtils.isEmpty(tuples)) {
        return new ScanResult<>(res.getStringCursor(), Collections.emptyList());
      }

      final List<Entry<String, Double>> newTuples = Lists.newArrayList();
      tuples.forEach(tuple -> newTuples.add(new AbstractMap.SimpleEntry<>(tuple.getElement(), tuple.getScore())));
      return new ScanResult<>(res.getStringCursor(), newTuples);
    } catch (final Throwable e) {
      throw new RedisClientException(e.getMessage(), e);
    }
  }
}

代码示例来源：origin: com.github.sogyf/goja-mvt

/** 删除最近消费的消息 */
public void clean() {
  Set<Tuple> zrangeWithScores = JedisKit.zrangeWithScores(subscriber.key(), 0, 1);
  Tuple next = zrangeWithScores.iterator().next();
  Integer lowest = (int) next.getScore();
  String key = topic.cat("message").cat(lowest).key();
  Logger.debug("clean key " + key);
  JedisKit.del(key);
}