本文整理了Java中redis.clients.jedis.JedisCluster.hgetAll()
方法的一些代码示例,展示了JedisCluster.hgetAll()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。JedisCluster.hgetAll()
方法的具体详情如下:
包路径:redis.clients.jedis.JedisCluster
类名称:JedisCluster
方法名:hgetAll
暂无
代码示例来源:origin: apache/storm
@Override
public Map<byte[], byte[]> hgetAll(byte[] key) {
return jedisCluster.hgetAll(key);
}
代码示例来源:origin: apache/storm
@Override
public Map<String, String> hgetAll(String key) {
return jedisCluster.hgetAll(key);
}
代码示例来源:origin: spring-projects/spring-data-redis
@Override
public Map<byte[], byte[]> hGetAll(byte[] key) {
Assert.notNull(key, "Key must not be null!");
try {
return connection.getCluster().hgetAll(key);
} catch (Exception ex) {
throw convertJedisAccessException(ex);
}
}
代码示例来源:origin: hhfcyong/xxxx-dubbo
/**
* 返回哈希表 key 中,所有的域和值
* 在返回值里,紧跟每个域名(field name)之后是域的值(value),所以返回值的长度是哈希表大小的两倍
* @param key
* @return 以列表形式返回哈希表的域和域的值,若 key 不存在,返回空列表
*/
public Map<String,String> hgetAll(String key){
return jedisCluster.hgetAll(key);
}
/**
代码示例来源:origin: net.oschina.j2cache/j2cache-core
@Override
public Map<byte[], byte[]> hgetAll(byte[] bytes) {
return cluster.hgetAll(bytes);
}
代码示例来源:origin: org.nutz/nutz-integration-jedis
public Map<String, String> hgetAll(String key) {
return jedisCluster.hgetAll(key);
}
代码示例来源:origin: org.nutz/nutz-integration-jedis
public Map<byte[], byte[]> hgetAll(byte[] key) {
return jedisCluster.hgetAll(key);
}
代码示例来源:origin: com.github.yamingd.argo/argo-redis
@Override
public Map<String, Integer> hall(String key) {
Map<byte[], byte[]> bs = jedisCluster.hgetAll(SafeEncoder.encode(key));
Map<String, Integer> vals = new HashMap<String, Integer>();
Iterator<byte[]> itor = bs.keySet().iterator();
while (itor.hasNext()){
byte[] k = itor.next();
byte[] data = bs.get(k);
int v = data == null ? 0 : Integer.parseInt(SafeEncoder.encode(data));
vals.put(SafeEncoder.encode(k), v);
}
return vals;
}
代码示例来源:origin: yangfuhai/jboot
/**
* 返回哈希表 key 中,所有的域和值。
* 在返回值里,紧跟每个域名(field name)之后是域的值(value),所以返回值的长度是哈希表大小的两倍。
*/
@SuppressWarnings("rawtypes")
public Map hgetAll(Object key) {
Map<byte[], byte[]> data = jedisCluster.hgetAll(keyToBytes(key));
Map<Object, Object> result = new HashMap<Object, Object>();
for (Entry<byte[], byte[]> e : data.entrySet())
result.put(valueFromBytes(e.getKey()), valueFromBytes(e.getValue()));
return result;
}
代码示例来源:origin: org.springframework.data/spring-data-redis
@Override
public Map<byte[], byte[]> hGetAll(byte[] key) {
Assert.notNull(key, "Key must not be null!");
try {
return connection.getCluster().hgetAll(key);
} catch (Exception ex) {
throw convertJedisAccessException(ex);
}
}
代码示例来源:origin: org.nanoframework/nano-orm-jedis
@Override
public Map<String, String> hgetAll(final String key) {
Assert.hasText(key);
try {
return cluster.hgetAll(key);
} catch (final Throwable e) {
throw new RedisClientException(e.getMessage(), e);
}
}
代码示例来源:origin: apache/servicemix-bundles
@Override
public Map<byte[], byte[]> hGetAll(byte[] key) {
Assert.notNull(key, "Key must not be null!");
try {
return connection.getCluster().hgetAll(key);
} catch (Exception ex) {
throw convertJedisAccessException(ex);
}
}
代码示例来源:origin: jzyong/game-server
public Role getRole(long id) {
Role role = roles.get(id);
Map<String, String> hgetAll = JedisManager.getJedisCluster().hgetAll(role.getRoleRedisKey());
// 从redis读取最新数据
if (hgetAll != null && role != null) {
JsonUtil.map2Object(hgetAll, role);
}
return role;
}
代码示例来源:origin: jzyong/game-server
/**
* 获取所有map对象
*
* @author JiangZhiYong
* @QQ 359135103 2017年10月24日 上午10:05:43
* @param key
* @param keyClass
* @param valueClass
* @return
*/
@SuppressWarnings("unchecked")
public <K, V> Map<K, V> hgetAll(final String key, final Class<K> keyClass, final Class<V> valueClass) {
Map<String, String> hgetAll = getJedisCluster().hgetAll(key);
if (hgetAll == null) {
return null;
}
Map<K, V> map = new ConcurrentHashMap<>();
hgetAll.forEach((k, v) -> {
map.put((K) parseKey(k, keyClass), JsonUtil.parseObject(v, valueClass));
});
return map;
}
代码示例来源:origin: Nepxion/Thunder
public Map<String, String> retrieveFromCluster(String traceId) throws Exception {
JedisCluster cluster = RedisClusterFactory.getCluster();
if (cluster == null) {
throw new MonitorException("No redis cluster found, retrieve failed");
}
Map<String, String> monitorStatMap = cluster.hgetAll(traceId);
if (MapUtils.isEmpty(monitorStatMap)) {
return null;
}
return monitorStatMap;
}
代码示例来源:origin: yrain/smart-cache
/**
* 返回哈希表 key 中,所有的域和值。
* 在返回值里,紧跟每个域名(field name)之后是域的值(value),所以返回值的长度是哈希表大小的两倍。
* 返回值:
* 以列表形式返回哈希表的域和域的值。
* 若 key 不存在,返回空列表。
*/
@SuppressWarnings("unchecked")
public <K, V> Map<K, V> hgetAll(String key) {
if (null == key) {
return null;
}
Map<K, V> data = Maps.newHashMap();
Map<byte[], byte[]> bytes = null;
if (cluster) {
bytes = jedisCluster.hgetAll(serializeKey(key));
} else {
bytes = jedisOperator.hgetAll(serializeKey(key));
}
for (byte[] k : bytes.keySet()) {
data.put((K) deserializeKey(k), (V) deserializeVal(bytes.get(k)));
}
return data;
}
代码示例来源:origin: jzyong/game-server
/**
* 加载角色数据
*
* @author JiangZhiYong
* @QQ 359135103 2017年8月3日 下午3:43:59
* @param roleId
*/
public Role loadRoleData(long roleId) {
Map<String, String> roleMap = JedisManager.getJedisCluster().hgetAll(BydrKey.Role_Map.getKey(roleId));
if (roleMap == null || roleMap.size() < 1) {
return null;
}
Role role = new Role();
JsonUtil.map2Object(roleMap, role);
// TODO 其他角色数据
// //大厅角色数据
// RMap<String, Object> hallRole = RedissonManager.getRedissonClient().getMap(HallKey.Role_Map_Info.getKey(roleId), new StringCodec());
// role.setHallRole(hallRole);
return role;
}
内容来源于网络,如有侵权,请联系作者删除!