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

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

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

JedisCommands.expire介绍

暂无

代码示例

代码示例来源:origin: Netflix/conductor

public Long expire(String key, int seconds) {
  return dynoClient.expire(key, seconds);
}

代码示例来源:origin: mpusher/mpush

/**
 * @param key
 * @param value
 * @param time  seconds
 */
public void set(String key, String value, int time) {
  call(jedis -> {
    jedis.set(key, value);
    if (time > 0) {
      jedis.expire(key, time);
    }
  });
}

代码示例来源:origin: mpusher/mpush

/**
 * 设置 key 指定的哈希集中指定字段的值。该命令将重写所有在哈希集中存在的字段。如果 key 指定的哈希集不存在,会创建一个新的哈希集并与 key
 * 关联
 *
 * @param hash
 * @param time
 */
public void hmset(String key, Map<String, String> hash, int time) {
  call(jedis -> {
    jedis.hmset(key, hash);
    if (time > 0) {
      jedis.expire(key, time);
    }
  });
}

代码示例来源:origin: com.netflix.conductor/conductor-redis-persistence

public Long expire(String key, int seconds) {
  return dynoClient.expire(key, seconds);
}

代码示例来源:origin: com.gitee.qdbp/qdbp-general-biz

/** {@inheritDoc} **/
@Override
public void expire(String key, String subkey, Long expire) {
  if (expire != null) {
    JedisCommands jedis = this.getInstanceByKey(key);
    // expire单位:毫秒, jedis.expire单位:秒
    jedis.expire(concat(key, subkey), (int) (expire / SECOND));
  }
}

代码示例来源:origin: com.gitee.zhaohuihua/bdp-general-svc

/** {@inheritDoc} **/
@Override
protected void expire(String key, String subkey, Long expire) {
  if (expire != null) {
    JedisCommands jedis = this.getInstanceByKey(key);
    // expire单位:毫秒, jedis.expire单位:秒
    jedis.expire(concat(key, subkey), (int) (expire / SECOND));
  }
}

代码示例来源:origin: com.github.mpusher/mpush-cache

/**
 * @param key
 * @param value
 * @param time  seconds
 */
public void set(String key, String value, int time) {
  call(jedis -> {
    jedis.set(key, value);
    if (time > 0) {
      jedis.expire(key, time);
    }
  });
}

代码示例来源:origin: com.github.mpusher/mpush-cache

/**
 * 设置 key 指定的哈希集中指定字段的值。该命令将重写所有在哈希集中存在的字段。如果 key 指定的哈希集不存在,会创建一个新的哈希集并与 key
 * 关联
 *
 * @param hash
 * @param time
 */
public void hmset(String key, Map<String, String> hash, int time) {
  call(jedis -> {
    jedis.hmset(key, hash);
    if (time > 0) {
      jedis.expire(key, time);
    }
  });
}

代码示例来源:origin: com.netflix.spinnaker.clouddriver/clouddriver-core

public void addResultObjects(List<Object> objects, JedisTask task) {
 String resultId = "taskResult:" + task.getId();
 String[] values = objects.stream()
  .map(o -> {
   try {
    return mapper.writeValueAsString(o);
   } catch (JsonProcessingException e) {
    throw new RuntimeException("Failed to convert object to string", e);
   }
  })
  .collect(Collectors.toList())
  .toArray(new String[objects.size()]);
 log.debug("Adding results to task {} (results: {})", task.getId(), values);
 retry(() -> redisClientDelegate.withCommandsClient(client -> {
  client.rpush(resultId, values);
  client.expire(resultId, TASK_TTL);
 }), format("Adding results to task %s", task.getId()));
}

代码示例来源:origin: com.netflix.spinnaker.clouddriver/clouddriver-core

public void set(String id, JedisTask task) {
 String taskId = "task:" + task.getId();
 Map<String, String> data = new HashMap<>();
 data.put("id", task.getId());
 data.put("startTimeMs", Long.toString(task.getStartTimeMs()));
 data.put("ownerId", task.getOwnerId());
 retry(() -> redisClientDelegate.withCommandsClient(client -> {
  client.hmset(taskId, data);
  client.expire(taskId, TASK_TTL);
  client.sadd(RUNNING_TASK_KEY, id);
 }), format("Writing task %s", id));
}

代码示例来源:origin: com.netflix.spinnaker.clouddriver/clouddriver-core

public void addToHistory(DefaultTaskStatus status, JedisTask task) {
 String historyId = "taskHistory:" + task.getId();
 Map<String, String> data = new HashMap<>();
 data.put("phase", status.getPhase());
 data.put("status", status.getStatus());
 data.put("state", status.getState().toString());
 String hist;
 try {
  hist = mapper.writeValueAsString(data);
 } catch (JsonProcessingException e) {
  throw new RuntimeException("Failed converting task history to json", e);
 }
 retry(() -> redisClientDelegate.withCommandsClient(client -> {
  client.rpush(historyId, hist);
  client.expire(historyId, TASK_TTL);
  if (status.isCompleted()) {
   client.srem(RUNNING_TASK_KEY, task.getId());
  }
 }), format("Adding status history to task %s: %s", task.getId(), status));
}

代码示例来源:origin: vakinge/jeesuite-libs

/**
 * 为给定 key 设置生存时间,当 key 过期时(生存时间为 0 ),它会被自动删除。
 * 
 * @param keyBytes
 * @param seconds
 *            超时时间,单位:秒
 * @return true:超时设置成功
 * 
 *         false:key不存在或超时未设置成功
 */
public boolean setExpire(long seconds) {
  if(seconds <= 0)return true;
  try {
    if(!isBinary)return getJedisCommands(groupName).expire(key, (int)seconds) == 1;
    if(isCluster(groupName)){
      return getBinaryJedisClusterCommands(groupName).expire(keyBytes, (int)seconds) == 1;
    }
    return getBinaryJedisCommands(groupName).expire(keyBytes, (int)seconds) == 1;
  } finally {
    getJedisProvider(groupName).release();
  }
}

相关文章

微信公众号

最新文章

更多