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

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

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

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);
}

相关文章

微信公众号

最新文章

更多