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

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

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

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

相关文章

微信公众号

最新文章

更多