redis.clients.jedis.JedisCommands.sscan()方法的使用及代码示例

x33g5p2x  于2022-01-21 转载在 其他  
字(2.3k)|赞(0)|评价(0)|浏览(229)

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

JedisCommands.sscan介绍

暂无

代码示例

代码示例来源:origin: Netflix/conductor

public Set<String> smembers(String key) {
  logger.trace("smembers {}", key);
  JedisCommands client = dynoClient;
  Set<String> r = new HashSet<>();
  int cursor = 0;
  ScanParams sp = new ScanParams();
  sp.count(50);
  do {
    ScanResult<String> sr = client.sscan(key, "" + cursor, sp);
    cursor = Integer.parseInt(sr.getStringCursor());
    r.addAll(sr.getResult());
  } while (cursor > 0);
  return r;
}

代码示例来源:origin: mpusher/mpush

/**
 * 默认使用每页10个
 *
 * @param key
 * @param clazz
 * @return
 */
public <T> List<T> sScan(String key, Class<T> clazz, int start) {
  List<String> list = call(jedis -> jedis.sscan(key, Integer.toString(start), new ScanParams().count(10)).getResult(), null);
  return toList(list, clazz);
}

代码示例来源:origin: com.netflix.conductor/conductor-redis-persistence

public Set<String> smembers(String key) {
  logger.trace("smembers {}", key);
  JedisCommands client = dynoClient;
  Set<String> r = new HashSet<>();
  int cursor = 0;
  ScanParams sp = new ScanParams();
  sp.count(50);
  do {
    ScanResult<String> sr = client.sscan(key, "" + cursor, sp);
    cursor = Integer.parseInt(sr.getStringCursor());
    r.addAll(sr.getResult());
  } while (cursor > 0);
  return r;
}

代码示例来源:origin: com.netflix.spinnaker.clouddriver/clouddriver-core

private Set<String> scanMembers(String setKey) {
 return redisClientDelegate.withCommandsClient(client -> {
  final Set<String> matches = new HashSet<>();
  final ScanParams scanParams = new ScanParams().count(redisCacheOptions.getScanSize());
  String cursor = "0";
  while (true) {
   final ScanResult<String> scanResult = client.sscan(setKey, cursor, scanParams);
   matches.addAll(scanResult.getResult());
   cursor = scanResult.getStringCursor();
   if ("0".equals(cursor)) {
    return matches;
   }
  }
 });
}

代码示例来源:origin: com.github.mpusher/mpush-cache

/**
 * 默认使用每页10个
 *
 * @param key
 * @param clazz
 * @return
 */
public <T> List<T> sScan(String key, Class<T> clazz, int start) {
  List<String> list = call(jedis -> jedis.sscan(key, Integer.toString(start), new ScanParams().count(10)).getResult(), null);
  return toList(list, clazz);
}

相关文章

微信公众号

最新文章

更多