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