本文整理了Java中redis.clients.jedis.JedisCommands.sscan()
方法的一些代码示例,展示了JedisCommands.sscan()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。JedisCommands.sscan()
方法的具体详情如下:
包路径:redis.clients.jedis.JedisCommands
类名称: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);
}
内容来源于网络,如有侵权,请联系作者删除!