本文整理了Java中redis.clients.jedis.JedisCommands.hset()
方法的一些代码示例,展示了JedisCommands.hset()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。JedisCommands.hset()
方法的具体详情如下:
包路径:redis.clients.jedis.JedisCommands
类名称:JedisCommands
方法名:hset
暂无
代码示例来源:origin: Netflix/conductor
public Long hset(String key, String field, String value) {
Long retVal = dynoClient.hset(key, field, value);
return retVal;
}
代码示例来源:origin: mpusher/mpush
/*********************
* hash redis start
********************************/
public void hset(String key, String field, String value) {
call(jedis -> jedis.hset(key, field, value));
}
代码示例来源:origin: apache/storm
jedisCommand.hset(additionalKey, key, value);
break;
代码示例来源:origin: com.netflix.conductor/conductor-redis-persistence
public Long hset(String key, String field, String value) {
Long retVal = dynoClient.hset(key, field, value);
return retVal;
}
代码示例来源:origin: com.github.mpusher/mpush-cache
/*********************
* hash redis start
********************************/
public void hset(String key, String field, String value) {
call(jedis -> jedis.hset(key, field, value));
}
代码示例来源:origin: com.gitee.qdbp/qdbp-general-biz
/** {@inheritDoc} **/
@Override
public <T> void hset(String key, String subkey, String field, T value) {
JedisCommands jedis = this.getInstanceByKey(key);
jedis.hset(concat(key, subkey), field, serializeValue(value));
}
代码示例来源:origin: com.gitee.zhaohuihua/bdp-general-svc
/** {@inheritDoc} **/
@Override
public <T> void hset(String key, String subkey, String field, T value) {
JedisCommands jedis = this.getInstanceByKey(key);
jedis.hset(concat(key, subkey), field, serializeValue(value));
}
代码示例来源:origin: com.netflix.spinnaker.orca/orca-redis
@Override
public void updateStageContext(@Nonnull Stage stage) {
RedisClientDelegate delegate = getRedisDelegate(stage);
String key = executionKey(stage);
String contextKey = format("stage.%s.context", stage.getId());
delegate.withCommandsClient(c -> {
try {
c.hset(key, contextKey, mapper.writeValueAsString(stage.getContext()));
} catch (JsonProcessingException e) {
throw new StageSerializationException(
format("Failed serializing stage, executionId: %s, stageId: %s", stage.getExecution().getId(), stage.getId()),
e
);
}
});
}
代码示例来源:origin: Netflix/dyno-queues
@Override
public List<String> push(final List<Message> messages) {
Stopwatch sw = monitor.start(monitor.push, messages.size());
try {
execute("push", "(a shard in) " + queueName, () -> {
for (Message message : messages) {
String json = om.writeValueAsString(message);
quorumConn.hset(messageStoreKey, message.getId(), json);
double priority = message.getPriority() / 100.0;
double score = Long.valueOf(clock.millis() + message.getTimeout()).doubleValue() + priority;
String shard = shardingStrategy.getNextShard(allShards, message);
String queueShard = getQueueShardKey(queueName, shard);
quorumConn.zadd(queueShard, score, message.getId());
}
return messages;
});
return messages.stream().map(msg -> msg.getId()).collect(Collectors.toList());
} finally {
sw.stop();
}
}
代码示例来源:origin: vakinge/jeesuite-libs
/**
* 设置ç
*
* @param field
* @param value
* @return
*/
public boolean set(String field, String value) {
boolean result = false;
if(value == null)return false;
//返回值(1:新字段被设置,0:已经存在值被更新)
try {
result = getJedisCommands(groupName).hset(key, field, value) >= 0;
//设置超时时间
if(result)setExpireIfNot(expireTime);
return result;
} finally {
getJedisProvider(groupName).release();
}
}
代码示例来源:origin: Netflix/dyno-queues
@Override
public boolean setTimeout(String messageId, long timeout) {
return execute("setTimeout", "(a shard in) " + queueName, () -> {
String json = nonQuorumConn.hget(messageStoreKey, messageId);
if(json == null) {
return false;
}
Message message = om.readValue(json, Message.class);
message.setTimeout(timeout);
for (String shard : allShards) {
String queueShard = getQueueShardKey(queueName, shard);
Double score = quorumConn.zscore(queueShard, messageId);
if(score != null) {
double priorityd = message.getPriority() / 100;
double newScore = Long.valueOf(clock.millis() + timeout).doubleValue() + priorityd;
ZAddParams params = ZAddParams.zAddParams().xx();
quorumConn.zadd(queueShard, newScore, messageId, params);
json = om.writeValueAsString(message);
quorumConn.hset(messageStoreKey, message.getId(), json);
return true;
}
}
return false;
});
}
代码示例来源:origin: suninformation/ymate-platform-v2
_holder.getCommands().hset(__cacheName, _cacheKey, _cacheValue);
内容来源于网络,如有侵权,请联系作者删除!