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

Tuple介绍

暂无

代码示例

代码示例来源：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: Netflix/conductor

private Set<Tuple> toTupleSet(Set<ZsetPair> pairs) {
  Set<Tuple> set = new HashSet<Tuple>();
  for (ZsetPair pair : pairs) {
    set.add(new Tuple(pair.member, pair.score));
  }
  return set;
}

代码示例来源：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: 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: io.leopard/leopard-redis

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

代码示例来源：origin: com.intoverflow.booster/booster-core

@Override
public Set<Object> keys() {
  return redisContext.call(jedis -> {
    Set<Object> set = new LinkedHashSet<>();
    while (true) {
      ScanResult<Tuple> zscan = jedis.zscan(keysetBytes, ScanParams.SCAN_POINTER_START_BINARY);
      List<Tuple> result = zscan.getResult();
      for (Tuple tuple : result) {
        byte[] key = tuple.getBinaryElement();
        Object oKey = fromKeyBytes(key);
        set.add(oKey);
      }
      String stringCursor = zscan.getStringCursor();
      if (stringCursor.equals(ScanParams.SCAN_POINTER_START)) {
        break;
      }
    }
    return set;
  });
}

代码示例来源：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: kingston-csj/jforgame

public List<CrossRank> queryRank(int rankType, int start, int end) {
  List<CrossRank> ranks = new ArrayList<>();
  Set<Tuple> tupleSet = cluster.zrevrangeWithScores("CrossRank_"  + rankType, start , end );
  
  Class<? extends AbstractCrossRank> rankClazz = rank2Class.get(rankType);
  for (Tuple record:tupleSet) {
    try{
      String element = record.getElement();
      AbstractCrossRank rankProto = rankClazz.newInstance();
      String resultKey = rankProto.buildResultKey();
      String data = cluster.hget(resultKey, element);
      CrossRank rank = unserialize(data, rankClazz);
      ranks.add(rank);
    }catch(Exception e) {
      e.printStackTrace();
    }
  }
  return ranks;
}

代码示例来源：origin: com.intoverflow.booster/booster-core

@Override
public Map<Object, Object> toMap() {
  return redisContext.call(jedis -> {
    Map<Object, Object> map = new LinkedHashMap<>();
    while (true) {
      ScanResult<Tuple> zscan = jedis.zscan(keysetBytes, ScanParams.SCAN_POINTER_START_BINARY);
      List<Tuple> result = zscan.getResult();
      for (Tuple tuple : result) {
        byte[] key = tuple.getBinaryElement();
        byte[] val = jedis.get(key);
        if (val != null) {
          Object oKey = fromKeyBytes(key);
          map.put(oKey, deserialize(val));
        }
      }
      String stringCursor = zscan.getStringCursor();
      if (stringCursor.equals(ScanParams.SCAN_POINTER_START)) {
        break;
      }
    }
    return map;
  });
}

代码示例来源：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: 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.
 * 
 * @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: sohutv/cachecloud

@Override
@SuppressWarnings("unchecked")
public Set<Tuple> build(Object data) {
 if (null == data) {
  return null;
 }
 List<byte[]> l = (List<byte[]>) data;
 final Set<Tuple> result = new LinkedHashSet<Tuple>(l.size());
 Iterator<byte[]> iterator = l.iterator();
 while (iterator.hasNext()) {
  result.add(new Tuple(iterator.next(), Double.valueOf(SafeEncoder.encode(iterator.next()))));
 }
 return result;
}

代码示例来源：origin: com.intoverflow.booster/booster-core

List<Tuple> result = zscan.getResult();
for (Tuple tuple : result) {
  byte[] key = tuple.getBinaryElement();
  Transaction multi = jedis.multi();
  multi.del(key);

代码示例来源：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: 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: sohutv/cachecloud

@Override
@SuppressWarnings("unchecked")
public Set<Tuple> build(Object data) {
 if (null == data) {
  return null;
 }
 List<byte[]> l = (List<byte[]>) data;
 final Set<Tuple> result = new LinkedHashSet<Tuple>(l.size());
 Iterator<byte[]> iterator = l.iterator();
 while (iterator.hasNext()) {
  result.add(new Tuple(SafeEncoder.encode(iterator.next()), Double.valueOf(SafeEncoder
    .encode(iterator.next()))));
 }
 return result;
}

代码示例来源：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;
}