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

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

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

JedisCommands.hgetAll介绍

暂无

代码示例

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

public Map<String, String> hgetAll(String key) {
  return call(jedis -> jedis.hgetAll(key), Collections.<String, String>emptyMap());
}

代码示例来源：origin: brianfrankcooper/YCSB

@Override
public Status read(String table, String key, Set<String> fields,
  Map<String, ByteIterator> result) {
 if (fields == null) {
  StringByteIterator.putAllAsByteIterators(result, jedis.hgetAll(key));
 } else {
  String[] fieldArray =
    (String[]) fields.toArray(new String[fields.size()]);
  List<String> values = jedis.hmget(key, fieldArray);
  Iterator<String> fieldIterator = fields.iterator();
  Iterator<String> valueIterator = values.iterator();
  while (fieldIterator.hasNext() && valueIterator.hasNext()) {
   result.put(fieldIterator.next(),
     new StringByteIterator(valueIterator.next()));
  }
  assert !fieldIterator.hasNext() && !valueIterator.hasNext();
 }
 return result.isEmpty() ? Status.ERROR : Status.OK;
}

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

public Map<String, String> hgetAll(String key) {
  return call(jedis -> jedis.hgetAll(key), Collections.<String, String>emptyMap());
}

代码示例来源：origin: com.gitee.qdbp/qdbp-general-biz

/** {@inheritDoc} **/
@Override
public <T> Map<String, T> haget(String key, String subkey, Class<T> clazz) {
  JedisCommands jedis = this.getInstanceByKey(key);
  Map<String, String> map = jedis.hgetAll(concat(key, subkey));
  Map<String, T> values = new HashMap<>();
  if (map != null && !map.isEmpty()) {
    for (Map.Entry<String, String> entry : map.entrySet()) {
      values.put(entry.getKey(), deserializeValue(entry.getValue(), clazz));
    }
  }
  return values;
}

代码示例来源：origin: com.gitee.zhaohuihua/bdp-general-svc

/** {@inheritDoc} **/
@Override
public <T> Map<String, T> haget(String key, String subkey, Class<T> clazz) {
  JedisCommands jedis = this.getInstanceByKey(key);
  Map<String, String> map = jedis.hgetAll(concat(key, subkey));
  Map<String, T> values = new HashMap<>();
  if (map != null && !map.isEmpty()) {
    for (Map.Entry<String, String> entry : map.entrySet()) {
      values.put(entry.getKey(), deserializeValue(entry.getValue(), clazz));
    }
  }
  return values;
}

代码示例来源：origin: com.gitee.qdbp/qdbp-general-biz

/** {@inheritDoc} **/
@Override
public Map<String, String> haget(String key, String subkey) {
  JedisCommands jedis = this.getInstanceByKey(key);
  return jedis.hgetAll(concat(key, subkey));
}

代码示例来源：origin: com.gitee.zhaohuihua/bdp-general-svc

/** {@inheritDoc} **/
@Override
public Map<String, String> haget(String key, String subkey) {
  JedisCommands jedis = this.getInstanceByKey(key);
  return jedis.hgetAll(concat(key, subkey));
}

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

@Override
public Task get(String id) {
 Map<String, String> taskMap = retry(() -> redisClientDelegate.withCommandsClient(client -> {
  return client.hgetAll("task:" + id);
 }), format("Getting task ID %s", id));
 boolean oldTask = redisClientDelegatePrevious.isPresent() && (taskMap == null || taskMap.isEmpty());
 if (oldTask) {
  try {
   taskMap = redisClientDelegatePrevious.get().withCommandsClient(client -> {
    return client.hgetAll("task:" + id);
   });
  } catch (Exception e) {
   // Failed to hit old redis, let's not blow up on that
   return null;
  }
 }
 if (taskMap.containsKey("id") && taskMap.containsKey("startTimeMs")) {
  return new JedisTask(
   taskMap.get("id"),
   Long.parseLong(taskMap.get("startTimeMs")),
   this,
   taskMap.get("ownerId"),
   oldTask
  );
 }
 return null;
}

代码示例来源：origin: com.gitee.qdbp/qdbp-general-biz

/** {@inheritDoc} **/
@Override
public <T> T hoget(String key, String subkey, Class<T> clazz) {
  JedisCommands jedis = this.getInstanceByKey(key);
  Map<String, String> map = jedis.hgetAll(concat(key, subkey));
  if (map == null || map.isEmpty()) {
    return null;
  } else {
    return deserializeFeilds(map, clazz);
  }
}

代码示例来源：origin: com.gitee.zhaohuihua/bdp-general-svc

/** {@inheritDoc} **/
@Override
public <T> T hoget(String key, String subkey, Class<T> clazz) {
  JedisCommands jedis = this.getInstanceByKey(key);
  Map<String, String> map = jedis.hgetAll(concat(key, subkey));
  if (map == null || map.isEmpty()) {
    return null;
  } else {
    return deserializeFeilds(map, clazz);
  }
}

代码示例来源：origin: com.gitee.qdbp/qdbp-general-biz

/** {@inheritDoc} **/
@Override
public Map<String, String> hmget(String key, String subkey, List<String> fields) {
  JedisCommands jedis = this.getInstanceByKey(key);
  if (fields == null) {
    return jedis.hgetAll(concat(key, subkey));
  } else if (fields.size() == 0) {
    return new HashMap<>();
  } else if (fields.size() == 1) {
    Map<String, String> map = new HashMap<>();
    map.put(fields.get(0), jedis.hget(concat(key, subkey), fields.get(0)));
    return map;
  } else {
    List<String> values = jedis.hmget(concat(key, subkey), toArray(fields));
    Map<String, String> map = new HashMap<>();
    for (int i = 0; i < fields.size() && i < values.size(); i++) {
      map.put(fields.get(i), values.get(i));
    }
    return map;
  }
}

代码示例来源：origin: com.gitee.zhaohuihua/bdp-general-svc

/** {@inheritDoc} **/
@Override
public Map<String, String> hmget(String key, String subkey, List<String> fields) {
  JedisCommands jedis = this.getInstanceByKey(key);
  if (fields == null) {
    return jedis.hgetAll(concat(key, subkey));
  } else if (fields.size() == 0) {
    return new HashMap<>();
  } else if (fields.size() == 1) {
    Map<String, String> map = new HashMap<>();
    map.put(fields.get(0), jedis.hget(concat(key, subkey), fields.get(0)));
    return map;
  } else {
    List<String> values = jedis.hmget(concat(key, subkey), toArray(fields));
    Map<String, String> map = new HashMap<>();
    for (int i = 0; i < fields.size() && i < values.size(); i++) {
      map.put(fields.get(i), values.get(i));
    }
    return map;
  }
}

代码示例来源：origin: vakinge/jeesuite-libs

/**
 * 获取所有值
 * 
 * @return
 */
public Map<String, String> getAll() {
  try {
    return getJedisCommands(groupName).hgetAll(key);
  } finally {
    getJedisProvider(groupName).release();
  }
}

代码示例来源：origin: com.gitee.zhaohuihua/bdp-general-svc

/** {@inheritDoc} **/
@Override
public <T> Map<String, T> hmget(String key, String subkey, List<String> fields, Class<T> clazz) {
  JedisCommands jedis = this.getInstanceByKey(key);
  Map<String, T> map = new HashMap<>();
  if (fields == null) {
    Map<String, String> values = jedis.hgetAll(concat(key, subkey));
    for (Map.Entry<String, String> entry : values.entrySet()) {
      map.put(entry.getKey(), deserializeValue(entry.getValue(), clazz));
    }
  } else if (fields.size() == 0) {
    // do nothing
  } else if (fields.size() == 1) {
    String string = jedis.hget(concat(key, subkey), fields.get(0));
    map.put(fields.get(0), deserializeValue(string, clazz));
  } else {
    List<String> values = jedis.hmget(concat(key, subkey), toArray(fields));
    for (int i = 0; i < fields.size() && i < values.size(); i++) {
      map.put(fields.get(i), deserializeValue(values.get(i), clazz));
    }
  }
  return map;
}

代码示例来源：origin: com.gitee.qdbp/qdbp-general-biz

/** {@inheritDoc} **/
@Override
public <T> Map<String, T> hmget(String key, String subkey, List<String> fields, Class<T> clazz) {
  JedisCommands jedis = this.getInstanceByKey(key);
  Map<String, T> map = new HashMap<>();
  if (fields == null) {
    Map<String, String> values = jedis.hgetAll(concat(key, subkey));
    for (Map.Entry<String, String> entry : values.entrySet()) {
      map.put(entry.getKey(), deserializeValue(entry.getValue(), clazz));
    }
  } else if (fields.size() == 0) {
    // do nothing
  } else if (fields.size() == 1) {
    String string = jedis.hget(concat(key, subkey), fields.get(0));
    map.put(fields.get(0), deserializeValue(string, clazz));
  } else {
    List<String> values = jedis.hmget(concat(key, subkey), toArray(fields));
    for (int i = 0; i < fields.size() && i < values.size(); i++) {
      map.put(fields.get(i), deserializeValue(values.get(i), clazz));
    }
  }
  return map;
}

代码示例来源：origin: com.netflix.spinnaker.fiat/fiat-roles

return client.hgetAll(userKey(permission.getId(), ResourceType.ROLE)).values().stream()
 .map((ThrowingFunction<String, Role>) serialized ->
  objectMapper.readValue(serialized, Role.class))

代码示例来源：origin: spinnaker/fiat

return client.hgetAll(userKey(permission.getId(), ResourceType.ROLE)).values().stream()
 .map((ThrowingFunction<String, Role>) serialized ->
  objectMapper.readValue(serialized, Role.class))

代码示例来源：origin: com.netflix.spinnaker.fiat/fiat-roles

@Override
public void remove(@NonNull String id) {
 try {
  redisClientDelegate.withCommandsClient(jedis -> {
   Map<String, String> userRolesById = jedis.hgetAll(userKey(id, ResourceType.ROLE));
   redisClientDelegate.withMultiKeyPipeline(p -> {
    p.srem(allUsersKey(), id);
    for (String roleName : userRolesById.keySet()) {
     p.srem(roleKey(roleName), id);
    }
    for (ResourceType r : ResourceType.values()) {
     p.del(userKey(id, r));
    }
    p.srem(adminKey(), id);
    p.sync();
   });
  });
 } catch (Exception e) {
  log.error("Storage exception reading " + id + " entry.", e);
 }
}

代码示例来源：origin: spinnaker/fiat

@Override
public void remove(@NonNull String id) {
 try {
  redisClientDelegate.withCommandsClient(jedis -> {
   Map<String, String> userRolesById = jedis.hgetAll(userKey(id, ResourceType.ROLE));
   redisClientDelegate.withMultiKeyPipeline(p -> {
    p.srem(allUsersKey(), id);
    for (String roleName : userRolesById.keySet()) {
     p.srem(roleKey(roleName), id);
    }
    for (ResourceType r : ResourceType.values()) {
     p.del(userKey(id, r));
    }
    p.srem(adminKey(), id);
    p.sync();
   });
  });
 } catch (Exception e) {
  log.error("Storage exception reading " + id + " entry.", e);
 }
}

内容来源于网络，如有侵权，请联系作者删除！

JedisCommands

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    JedisCommands类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com