本文整理了Java中redis.clients.jedis.JedisCommands.lrange()
方法的一些代码示例,展示了JedisCommands.lrange()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。JedisCommands.lrange()
方法的具体详情如下:
包路径:redis.clients.jedis.JedisCommands
类名称:JedisCommands
方法名:lrange
暂无
代码示例来源:origin: mpusher/mpush
/**
* 从列表中获取指定返回的元素 start 和 end
* 偏移量都是基于0的下标,即list的第一个元素下标是0(list的表头),第二个元素下标是1,以此类推。
* 偏移量也可以是负数,表示偏移量是从list尾部开始计数。 例如, -1 表示列表的最后一个元素,-2 是倒数第二个,以此类推。
*/
public <T> List<T> lrange(String key, int start, int end, Class<T> clazz) {
return call(jedis -> jedis.lrange(key, start, end), Collections.<String>emptyList())
.stream()
.map(s -> Jsons.fromJson(s, clazz))
.collect(Collectors.toList());
}
代码示例来源:origin: com.github.mpusher/mpush-cache
/**
* 从列表中获取指定返回的元素 start 和 end
* 偏移量都是基于0的下标,即list的第一个元素下标是0(list的表头),第二个元素下标是1,以此类推。
* 偏移量也可以是负数,表示偏移量是从list尾部开始计数。 例如, -1 表示列表的最后一个元素,-2 是倒数第二个,以此类推。
*/
public <T> List<T> lrange(String key, int start, int end, Class<T> clazz) {
return call(jedis -> jedis.lrange(key, start, end), Collections.<String>emptyList())
.stream()
.map(s -> Jsons.fromJson(s, clazz))
.collect(Collectors.toList());
}
代码示例来源:origin: com.netflix.spinnaker.clouddriver/clouddriver-core
public List<Object> getResultObjects(JedisTask task) {
String resultId = "taskResult:" + task.getId();
return retry(() -> clientForTask(task).withCommandsClient(client -> {
return client.lrange(resultId, 0, -1);
}), format("Getting results for task %s", task.getId()))
.stream()
.map(o -> {
try {
return mapper.readValue(o, Map.class);
} catch (IOException e) {
throw new RuntimeException("Failed to convert result object to map", e);
}
})
.collect(Collectors.toList());
}
代码示例来源:origin: vakinge/jeesuite-libs
public List<String> range(int start, int end) {
try {
return getJedisCommands(groupName).lrange(key, start, end);
} finally {
getJedisProvider(groupName).release();
}
}
代码示例来源:origin: com.netflix.spinnaker.clouddriver/clouddriver-core
public List<Status> getHistory(JedisTask task) {
String historyId = "taskHistory:" + task.getId();
RedisClientDelegate client = clientForTask(task);
return retry(() -> client.withCommandsClient(c -> {
return c.lrange(historyId, 0, -1);
}), format("Getting history for task %s", task.getId()))
.stream()
.map(h -> {
Map<String, String> history;
try {
history = mapper.readValue(h, HISTORY_TYPE);
} catch (IOException e) {
throw new RuntimeException("Could not convert history json to type", e);
}
return TaskDisplayStatus.create(DefaultTaskStatus.create(history.get("phase"), history.get("status"), TaskState.valueOf(history.get("state"))));
})
.collect(Collectors.toList());
}
代码示例来源:origin: com.github.bingoohuang/westid
@SneakyThrows
private Integer tryReuseWorkerId() {
val pidWorkerIds = jedis.lrange(PREFIX_PID, 0, -1);
if (pidWorkerIds.size() == 0) {
return null;
}
boolean locked = jedis.setnx(PREFIX_LOK, Os.PID_STRING) == 1;
if (!locked) {
return null;
}
@Cleanup val i = new Closeable() {
@Override
public void close() throws IOException {
jedis.del(PREFIX_LOK);
}
};
val workerId = findUsableWorkerId(pidWorkerIds);
if (workerId == null) {
return null;
}
jedis.set(PREFIX_USE + workerId, Os.PID_STRING + "x" + Os.IP_STRING + "x" + Os.HOSTNAME);
return Integer.parseInt(workerId);
}
内容来源于网络,如有侵权,请联系作者删除!