本文整理了Java中redis.clients.jedis.JedisCommands.hmget()
方法的一些代码示例,展示了JedisCommands.hmget()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。JedisCommands.hmget()
方法的具体详情如下:
包路径:redis.clients.jedis.JedisCommands
类名称:JedisCommands
方法名:hmget
暂无
代码示例来源:origin: mpusher/mpush
/**
* 返回 key 指定的哈希集中指定字段的值
*
* @param fields
* @param clazz
* @return
*/
public <T> List<T> hmget(String key, Class<T> clazz, String... fields) {
return call(jedis -> jedis.hmget(key, fields), Collections.<String>emptyList())
.stream()
.map(s -> Jsons.fromJson(s, clazz))
.collect(Collectors.toList());
}
代码示例来源: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
/**
* 返回 key 指定的哈希集中指定字段的值
*
* @param fields
* @param clazz
* @return
*/
public <T> List<T> hmget(String key, Class<T> clazz, String... fields) {
return call(jedis -> jedis.hmget(key, fields), Collections.<String>emptyList())
.stream()
.map(s -> Jsons.fromJson(s, clazz))
.collect(Collectors.toList());
}
代码示例来源:origin: vakinge/jeesuite-libs
/**
* 获取多个key的值
*
* @param fields
* @return
*/
public Map<String, String> get(String... fields) {
try {
List<String> datas = getJedisCommands(groupName).hmget(key, fields);
Map<String, String> result = new HashMap<>();
for (int i = 0; i < fields.length; i++) {
result.put(fields[i], datas.get(i));
}
return result;
} finally {
getJedisProvider(groupName).release();
}
}
}
代码示例来源: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: 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.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.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;
}
内容来源于网络,如有侵权,请联系作者删除!