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

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

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

JedisCluster.mset介绍

暂无

代码示例

代码示例来源:origin: spring-projects/spring-data-redis

@Override
public Boolean mSet(Map<byte[], byte[]> tuples) {
  Assert.notNull(tuples, "Tuples must not be null!");
  if (ClusterSlotHashUtil.isSameSlotForAllKeys(tuples.keySet().toArray(new byte[tuples.keySet().size()][]))) {
    try {
      return Converters.stringToBoolean(connection.getCluster().mset(JedisConverters.toByteArrays(tuples)));
    } catch (Exception ex) {
      throw convertJedisAccessException(ex);
    }
  }
  boolean result = true;
  for (Map.Entry<byte[], byte[]> entry : tuples.entrySet()) {
    if (!set(entry.getKey(), entry.getValue())) {
      result = false;
    }
  }
  return result;
}

代码示例来源:origin: org.nutz/nutz-integration-jedis

public String mset(String... keysvalues) {
  return jedisCluster.mset(keysvalues);
}

代码示例来源:origin: org.nutz/nutz-integration-jedis

public String mset(byte[]... keysvalues) {
  return jedisCluster.mset(keysvalues);
}

代码示例来源:origin: org.springframework.data/spring-data-redis

@Override
public Boolean mSet(Map<byte[], byte[]> tuples) {
  Assert.notNull(tuples, "Tuples must not be null!");
  if (ClusterSlotHashUtil.isSameSlotForAllKeys(tuples.keySet().toArray(new byte[tuples.keySet().size()][]))) {
    try {
      return Converters.stringToBoolean(connection.getCluster().mset(JedisConverters.toByteArrays(tuples)));
    } catch (Exception ex) {
      throw convertJedisAccessException(ex);
    }
  }
  boolean result = true;
  for (Map.Entry<byte[], byte[]> entry : tuples.entrySet()) {
    if (!set(entry.getKey(), entry.getValue())) {
      result = false;
    }
  }
  return result;
}

代码示例来源:origin: yangfuhai/jboot

/**
 * 同时设置一个或多个 key-value 对。
 * 如果某个给定 key 已经存在,那么 MSET 会用新值覆盖原来的旧值,如果这不是你所希望的效果,请考虑使用 MSETNX 命令:它只会在所有给定 key 都不存在的情况下进行设置操作。
 * MSET 是一个原子性(atomic)操作,所有给定 key 都会在同一时间内被设置,某些给定 key 被更新而另一些给定 key 没有改变的情况,不可能发生。
 * <pre>
 * 例子:
 * Cache cache = RedisKit.use();            // 使用 JbootRedis 的 cache
 * cache.mset("k1", "v1", "k2", "v2");        // 放入多个 key value 键值对
 * List list = cache.mget("k1", "k2");        // 利用多个键值得到上面代码放入的值
 * </pre>
 */
public String mset(Object... keysValues) {
  if (keysValues.length % 2 != 0)
    throw new IllegalArgumentException("wrong number of arguments for met, keysValues length can not be odd");
  byte[][] kv = new byte[keysValues.length][];
  for (int i = 0; i < keysValues.length; i++) {
    if (i % 2 == 0)
      kv[i] = keyToBytes(keysValues[i]);
    else
      kv[i] = valueToBytes(keysValues[i]);
  }
  return jedisCluster.mset(kv);
}

代码示例来源:origin: apache/servicemix-bundles

@Override
public Boolean mSet(Map<byte[], byte[]> tuples) {
  Assert.notNull(tuples, "Tuples must not be null!");
  if (ClusterSlotHashUtil.isSameSlotForAllKeys(tuples.keySet().toArray(new byte[tuples.keySet().size()][]))) {
    try {
      return Converters.stringToBoolean(connection.getCluster().mset(JedisConverters.toByteArrays(tuples)));
    } catch (Exception ex) {
      throw convertJedisAccessException(ex);
    }
  }
  boolean result = true;
  for (Map.Entry<byte[], byte[]> entry : tuples.entrySet()) {
    if (!set(entry.getKey(), entry.getValue())) {
      result = false;
    }
  }
  return result;
}

代码示例来源:origin: yrain/smart-cache

/**
 * 设值-多个
 * Logs.msg(jedisTemplate.mset("x", User.I, "y", User.I, "z", User.I));
 * Logs.msg(jedisTemplate.mget("x", "y", "z"));
 */
public boolean mset(Object... keyvalues) {
  if (null == keyvalues || keyvalues.length == 0) {
    return false;
  }
  List<byte[]> args = Lists.newArrayList();
  for (int i = 0; i < keyvalues.length; i++) {
    if (i % 2 == 0) {
      args.add(serializeKey(keyvalues[i]));
    } else {
      args.add(serializeVal(keyvalues[i]));
    }
  }
  if (cluster) {
    return jedisCluster.mset(convertByteListToByteArray(args)).equals("OK");
  } else {
    return jedisOperator.mset(convertByteListToByteArray(args)).equals("OK");
  }
}

相关文章

JedisCluster类方法