本文整理了Java中org.redisson.api.RedissonClient.getKeys
方法的一些代码示例,展示了RedissonClient.getKeys
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。RedissonClient.getKeys
方法的具体详情如下:
包路径:org.redisson.api.RedissonClient
类名称:RedissonClient
方法名:getKeys
[英]Returns interface with methods for Redis keys. Each of Redis/Redisson object associated with own key
[中]返回Redis键的方法接口。与自己的密钥关联的每个Redis/Redisson对象
代码示例来源:origin: debop/hibernate-redis
public void flushDb() {
log.info("flush db...");
redisson.getKeys().flushdb();
}
代码示例来源:origin: youngMen1/JAVA-
public final String type(final String key) {
RType type = redissonClient.getKeys().getType(key);
if (type == null) {
return null;
}
return type.getClass().getName();
}
代码示例来源:origin: huangjian888/jeeweb-mybatis-springboot
@Override
public final String type(final String key) {
RType type = redissonClient.getKeys().getType(key);
if (type == null) {
return null;
}
return type.getClass().getName();
}
代码示例来源:origin: debop/hibernate-redis
public long dbSize() {
return redisson.getKeys().count();
}
代码示例来源:origin: debop/hibernate-redis
public long dbSize() {
return redisson.getKeys().count();
}
代码示例来源:origin: huangjian888/jeeweb-mybatis-springboot
@Override
public final void delAll(final String pattern) {
redissonClient.getKeys().deleteByPattern(pattern);
}
代码示例来源:origin: debop/hibernate-redis
public void flushDb() {
log.info("flush db...");
redisson.getKeys().flushdb();
}
代码示例来源:origin: com.github.debop/hibernate-redis
public void flushDb() {
log.info("flush db...");
redisson.getKeys().flushdb();
}
代码示例来源:origin: youngMen1/JAVA-
public final void del(final String key) {
redissonClient.getKeys().deleteAsync(key);
}
代码示例来源:origin: youngMen1/JAVA-
public final void delAll(final String pattern) {
redissonClient.getKeys().deleteByPattern(pattern);
}
代码示例来源:origin: huangjian888/jeeweb-mybatis-springboot
@Override
public final void del(final String key) {
redissonClient.getKeys().delete(key);
}
代码示例来源:origin: tywo45/t-io
@Override
public void clear() {
long start = SystemTimer.currTime;
RKeys keys = redisson.getKeys();
// keys.deleteByPattern(keyPrefix(cacheName) + "*");
keys.deleteByPatternAsync(keyPrefix(cacheName) + "*");
long end = SystemTimer.currTime;
long iv = end - start;
log.info("clear cache {}, cost {}ms", cacheName, iv);
}
代码示例来源:origin: locationtech/geowave
private void deleteByPattern(final String pattern) {
final RKeys keySet = client.getKeys();
keySet.getKeysByPattern(pattern).forEach(k -> keySet.delete(k));
}
代码示例来源:origin: tywo45/t-io
@Override
public Iterable<String> keys() {
RKeys keys = redisson.getKeys();
Iterable<String> allkey = keys.getKeysByPattern(keyPrefix(cacheName) + "*");//.findKeysByPattern(keyPrefix(cacheName) + "*");
return allkey;
}
代码示例来源:origin: justlive1/earth-frost
private void waitFor(String uuid, int subscribers) {
RSemaphore semaphore = redissonClient.getSemaphore(String.format(JobConfig.WORKER_REQ, uuid));
try {
semaphore.tryAcquire(subscribers, 10L, TimeUnit.SECONDS);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
redissonClient.getKeys().delete(semaphore);
}
代码示例来源:origin: locationtech/geowave
public static Set<ByteArray> getPartitions(
final RedissonClient client,
final String setNamePrefix) {
return Streams.stream(client.getKeys().getKeysByPattern(setNamePrefix + "*")).map(
str -> str.length() > (setNamePrefix.length() + 1)
? new ByteArray(
ByteArrayUtils.byteArrayFromString(str.substring(setNamePrefix.length() + 1)))
: new ByteArray()).collect(Collectors.toSet());
}
代码示例来源:origin: youngMen1/JAVA-
public Set<Object> getAll(String pattern) {
Set<Object> set = InstanceUtil.newHashSet();
Iterable<String> keys = redissonClient.getKeys().getKeysByPattern(pattern);
for (Iterator<String> iterator = keys.iterator(); iterator.hasNext();) {
String key = iterator.next();
set.add(getRedisBucket(key).get());
}
return set;
}
代码示例来源:origin: huangjian888/jeeweb-mybatis-springboot
@Override
public Set<Object> getAll(String pattern) {
Set<Object> set = ArrayUtils.newHashSet();
Iterable<String> keys = redissonClient.getKeys().getKeysByPattern(pattern);
for (String key : keys) {
set.add(getRedisBucket(key).get());
}
return set;
}
代码示例来源:origin: huangjian888/jeeweb-mybatis-springboot
@Override
public Set<Object> getAll(String pattern, Integer expire) {
Set<Object> set = ArrayUtils.newHashSet();
Iterable<String> keys = redissonClient.getKeys().getKeysByPattern(pattern);
for (String key : keys) {
RBucket<Object> bucket = getRedisBucket(key);
expire(bucket, expire);
set.add(bucket.get());
}
return set;
}
代码示例来源:origin: getheimdall/heimdall
/**
* Clears a cache if it exists
*
* @param cacheName Cache name provided
*/
public void cacheClearInterceptor(String cacheName) {
RedissonClient redisson = (RedissonClient) BeanManager.getBean(RedissonClient.class);
RequestContext context = RequestContext.getCurrentContext();
redisson.getKeys().deleteByPattern(createDeleteCacheKey(context, cacheName));
}
内容来源于网络,如有侵权,请联系作者删除!