本文整理了Java中redis.clients.jedis.JedisCluster.mset()
方法的一些代码示例,展示了JedisCluster.mset()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。JedisCluster.mset()
方法的具体详情如下:
包路径:redis.clients.jedis.JedisCluster
类名称: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");
}
}
内容来源于网络,如有侵权,请联系作者删除!