本文整理了Java中redis.clients.jedis.JedisCluster.hmset()
方法的一些代码示例,展示了JedisCluster.hmset()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。JedisCluster.hmset()
方法的具体详情如下:
包路径:redis.clients.jedis.JedisCluster
类名称:JedisCluster
方法名:hmset
暂无
代码示例来源:origin: apache/storm
@Override
public String hmset(String key, Map<String, String> fieldValues) {
return jedisCluster.hmset(key, fieldValues);
}
代码示例来源:origin: apache/storm
@Override
public String hmset(byte[] key, Map<byte[], byte[]> fieldValues) {
return jedisCluster.hmset(key, fieldValues);
}
代码示例来源:origin: spring-projects/spring-data-redis
@Override
public void hMSet(byte[] key, Map<byte[], byte[]> hashes) {
Assert.notNull(key, "Key must not be null!");
Assert.notNull(hashes, "Hashes must not be null!");
try {
connection.getCluster().hmset(key, hashes);
} catch (Exception ex) {
throw convertJedisAccessException(ex);
}
}
代码示例来源:origin: apache/storm
/**
* {@inheritDoc}
*/
@Override
protected void updateStatesToRedis(Map<String, String> keyValues) {
RedisDataTypeDescription description = this.options.dataTypeDescription;
switch (description.getDataType()) {
case STRING:
for (Map.Entry<String, String> kvEntry : keyValues.entrySet()) {
if (this.options.expireIntervalSec > 0) {
jedisCluster.setex(kvEntry.getKey(), this.options.expireIntervalSec, kvEntry.getValue());
} else {
jedisCluster.set(kvEntry.getKey(), kvEntry.getValue());
}
}
break;
case HASH:
jedisCluster.hmset(description.getAdditionalKey(), keyValues);
if (this.options.expireIntervalSec > 0) {
jedisCluster.expire(description.getAdditionalKey(), this.options.expireIntervalSec);
}
break;
default:
throw new IllegalArgumentException("Cannot process such data type: " + description.getDataType());
}
}
代码示例来源:origin: AmadeusITGroup/HttpSessionReplacer
@Override
public void run() {
jedis.hmset(key, hash);
}
});
代码示例来源:origin: org.nutz/nutz-integration-jedis
public String hmset(String key, Map<String, String> hash) {
return jedisCluster.hmset(key, hash);
}
代码示例来源:origin: net.oschina.j2cache/j2cache-core
@Override
public String hmset(byte[] bytes, Map<byte[], byte[]> map) {
return cluster.hmset(bytes, map);
}
代码示例来源:origin: org.nutz/nutz-integration-jedis
public String hmset(byte[] key, Map<byte[], byte[]> hash) {
return jedisCluster.hmset(key, hash);
}
代码示例来源:origin: hhfcyong/xxxx-dubbo
/**
* 同时将多个 field-value (域-值)对设置到哈希表 key 中
* 此命令会覆盖哈希表中已存在的域
* 如果 key 不存在,一个空哈希表被创建并执行 HMSET 操作
* @param key
* @param fieldValues field,value,field,value....
* @return 如果命令执行成功,返回 OK ,当 key 不是哈希表(hash)类型时,返回一个错误
*/
public String hmset(String key,String fieldValues){
String[] fieldValue=fieldValues.split(",");
Map<String,String> map=new HashMap<String,String>();
for(int i=0;i<fieldValue.length;i=i+2){
map.put(fieldValue[i],fieldValue[i+1]);
}
return jedisCluster.hmset(key,map);
}
/**
代码示例来源:origin: org.springframework.data/spring-data-redis
@Override
public void hMSet(byte[] key, Map<byte[], byte[]> hashes) {
Assert.notNull(key, "Key must not be null!");
Assert.notNull(hashes, "Hashes must not be null!");
try {
connection.getCluster().hmset(key, hashes);
} catch (Exception ex) {
throw convertJedisAccessException(ex);
}
}
代码示例来源:origin: yangfuhai/jboot
/**
* 同时将多个 field-value (域-值)对设置到哈希表 key 中。
* 此命令会覆盖哈希表中已存在的域。
* 如果 key 不存在,一个空哈希表被创建并执行 HMSET 操作。
*/
public String hmset(Object key, Map<Object, Object> hash) {
Map<byte[], byte[]> para = new HashMap<byte[], byte[]>();
for (Entry<Object, Object> e : hash.entrySet())
para.put(valueToBytes(e.getKey()), valueToBytes(e.getValue()));
return jedisCluster.hmset(keyToBytes(key), para);
}
代码示例来源:origin: apache/servicemix-bundles
@Override
public void hMSet(byte[] key, Map<byte[], byte[]> hashes) {
Assert.notNull(key, "Key must not be null!");
Assert.notNull(hashes, "Hashes must not be null!");
try {
connection.getCluster().hmset(key, hashes);
} catch (Exception ex) {
throw convertJedisAccessException(ex);
}
}
代码示例来源:origin: org.nanoframework/nano-orm-jedis
@Override
public boolean hmset(final String key, final Map<String, Object> map) {
Assert.hasText(key);
Assert.notEmpty(map);
try {
final Map<String, String> newMap = Maps.newHashMap();
map.forEach((field, value) -> newMap.put(field, toJSONString(value)));
return isOK(cluster.hmset(key, newMap));
} catch (final Throwable e) {
throw new RedisClientException(e.getMessage(), e);
}
}
代码示例来源:origin: yrain/smart-cache
/**
* 同时将多个 field-value (域-值)对设置到哈希表 key 中。
* 此命令会覆盖哈希表中已存在的域。
* 如果 key 不存在,一个空哈希表被创建并执行 HMSET 操作。
*/
public boolean hmset(Object key, Map<?, ?> hash) {
if (null == key || null == hash) {
return false;
}
Map<byte[], byte[]> map = Maps.newHashMap();
for (Object field : hash.keySet()) {
map.put(serializeKey(field), serializeVal(hash.get(field)));
}
if (cluster) {
return jedisCluster.hmset(serializeKey(key), map).equals("OK");
} else {
return jedisOperator.hmset(serializeKey(key), map).equals("OK");
}
}
代码示例来源:origin: jzyong/game-server
/**
* 存储整个role对象
* @author JiangZhiYong
* @QQ 359135103
* 2017年9月26日 下午5:06:51
*/
public void saveToRedis() {
JedisManager.getJedisCluster().hmset(getRoleRedisKey(), JsonUtil.object2Map(this));
}
}
代码示例来源:origin: jzyong/game-server
/**
* 存储角色数据
*
* @author JiangZhiYong
* @QQ 359135103 2017年8月3日 下午3:22:58
* @param role
*
* TODO 存储到mongodb
*/
public void saveRoleData(Role role) {
String key = BydrKey.Role_Map.getKey(role.getId());
LOGGER.debug("{}存储数据", key);
JedisManager.getJedisCluster().hmset(key, JsonUtil.object2Map(role));
//
}
}
内容来源于网络,如有侵权,请联系作者删除!