本文整理了Java中redis.clients.jedis.JedisCluster.set()
方法的一些代码示例,展示了JedisCluster.set()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。JedisCluster.set()
方法的具体详情如下:
包路径:redis.clients.jedis.JedisCluster
类名称:JedisCluster
方法名:set
暂无
代码示例来源:origin: yu199195/hmily
@Override
public String set(final String key, final String value) {
return jedisCluster.set(key, value);
}
代码示例来源:origin: apache/storm
jedisCluster.setex(key, expireIntervalSec, value);
} else {
jedisCluster.set(key, value);
代码示例来源:origin: yu199195/myth
@Override
public String set(final String key, final String value) {
return jedisCluster.set(key, value);
}
代码示例来源: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: qiujiayu/AutoLoadCache
@Override
public void set(byte[] key, byte[] value) {
jedisCluster.set(key, value);
}
代码示例来源:origin: foxinmy/weixin4j
@Override
public void caching(String key, T cache) {
byte[] cacheKey = key.getBytes(Consts.UTF_8);
byte[] value = SerializationUtils.serialize(cache);
if (cache.getExpires() > 0) {
jedisCluster.setex(cacheKey,
(int) (cache.getExpires() - CUTMS) / 1000, value);
} else {
jedisCluster.set(cacheKey, value);
}
jedisCluster.sadd(ALLKEY, key);
}
代码示例来源:origin: yu199195/Raincat
@Override
public String set(final String key, final String value) {
return jedisCluster.set(key, value);
}
代码示例来源:origin: com.foxinmy/weixin4j-base
@Override
public void caching(String key, T cache) {
byte[] cacheKey = key.getBytes(Consts.UTF_8);
byte[] value = SerializationUtils.serialize(cache);
if (cache.getExpires() > 0) {
jedisCluster.setex(cacheKey,
(int) (cache.getExpires() - CUTMS) / 1000, value);
} else {
jedisCluster.set(cacheKey, value);
}
jedisCluster.sadd(ALLKEY, key);
}
代码示例来源:origin: yu199195/Raincat
@Override
public String set(final String key, final byte[] value) {
return jedisCluster.set(key.getBytes(), value);
}
代码示例来源:origin: yu199195/hmily
@Override
public String set(final String key, final byte[] value) {
return jedisCluster.set(key.getBytes(), value);
}
代码示例来源:origin: yu199195/myth
@Override
public String set(final String key, final byte[] value) {
return jedisCluster.set(key.getBytes(), value);
}
代码示例来源:origin: qiujiayu/AutoLoadCache
@Override
protected boolean setnx(String key, String val, int expire) {
return OK.equalsIgnoreCase(jedisCluster.set(key, val, NX, EX, expire));
}
代码示例来源:origin: mpusher/mpush
@Test
public void test() {
User user = new User("huang", 18, new Date());
cluster.set("huang", Jsons.toJson(user));
String ret = cluster.get("huang");
User newUser = Jsons.fromJson(ret, User.class);
System.out.println(ToStringBuilder.reflectionToString(newUser, ToStringStyle.JSON_STYLE));
}
代码示例来源:origin: spring-projects/spring-data-redis
@Override
public Boolean set(byte[] key, byte[] value) {
Assert.notNull(key, "Key must not be null!");
Assert.notNull(value, "Value must not be null!");
try {
return Converters.stringToBoolean(connection.getCluster().set(key, value));
} catch (Exception ex) {
throw convertJedisAccessException(ex);
}
}
代码示例来源:origin: spring-projects/spring-data-redis
return Converters.stringToBoolean(connection.getCluster().set(key, value, params));
} catch (Exception ex) {
throw convertJedisAccessException(ex);
代码示例来源:origin: alexxiyang/shiro-redis
@Override
public byte[] set(byte[] key, byte[] value, int expireTime) {
if (key == null) {
return null;
}
getJedisCluster().set(key, value);
if (expireTime >= 0) {
getJedisCluster().expire(key, expireTime);
}
return value;
}
代码示例来源:origin: apache/bahir-flink
@Override
public void set(final String key, final String value) {
try {
jedisCluster.set(key, value);
} catch (Exception e) {
if (LOG.isErrorEnabled()) {
LOG.error("Cannot send Redis message with command SET to key {} error message {}",
key, e.getMessage());
}
throw e;
}
}
代码示例来源:origin: yangfuhai/jboot
/**
* 存放 key value 对到 redis
* 如果 key 已经持有其他值, SET 就覆写旧值,无视类型。
* 此方法用了修改 incr 等的值
*/
public String setWithoutSerialize(Object key, Object value) {
return jedisCluster.set(keyToBytes(key), value.toString().getBytes());
}
代码示例来源:origin: yangfuhai/jboot
/**
* 存放 key value 对到 redis
* 如果 key 已经持有其他值, SET 就覆写旧值,无视类型。
* 对于某个原本带有生存时间(TTL)的键来说, 当 SET 命令成功在这个键上执行时, 这个键原有的 TTL 将被清除。
*/
public String set(Object key, Object value) {
return jedisCluster.set(keyToBytes(key), valueToBytes(value));
}
代码示例来源:origin: org.crazycake/shiro-redis
@Override
public byte[] set(byte[] key, byte[] value, int expireTime) {
if (key == null) {
return null;
}
getJedisCluster().set(key, value);
if (expireTime >= 0) {
getJedisCluster().expire(key, expireTime);
}
return value;
}
内容来源于网络,如有侵权,请联系作者删除!