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

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

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

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

相关文章

微信公众号

最新文章

更多

JedisCluster类方法