org.redisson.api.RedissonClient.getKeys()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(4.8k)|赞(0)|评价(0)|浏览(1045)

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

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

相关文章

微信公众号

最新文章

更多