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

RedisClient.keys介绍

[英]Find all keys matching the given pattern
[中]查找与给定模式匹配的所有键

代码示例

代码示例来源：origin: xenv/gushici

@Override
public void start(Future<Void> startFuture) {
  vertx.eventBus().consumer(Key.GET_GUSHICI_FROM_REDIS, this::getGushiciFromRedis);
  vertx.eventBus().consumer(Key.GET_HELP_FROM_REDIS, this::getHelpFromRedis);
  redisClient = RedisClient.create(vertx, redisOptions);
  // 从 redis 缓存所有 key
  Future<JsonArray> imgKeys = Future.future(f -> redisClient.keys(Key.IMG, f));
  Future<JsonArray> jsonKeys = Future.future(f -> redisClient.keys(Key.JSON, f));
  CompositeFuture.all(Arrays.asList(imgKeys, jsonKeys)).setHandler(v -> {
    if (v.succeeded()) {
      imgKeys.result().addAll(jsonKeys.result())
        .stream()
        .forEach(key -> keysInRedis.insert((String) key));
      startFuture.complete();
    } else {
      log.error("DataService fail to start", v.cause());
      startFuture.fail(v.cause());
    }
  });
}

代码示例来源：origin: vert-x3/vertx-rx

/**
 * Find all keys matching the given pattern
 * @param pattern Pattern to limit the keys returned
 * @param handler Handler for the result of this call.
 * @return 
 */
public io.vertx.rxjava.redis.RedisClient keys(String pattern, Handler<AsyncResult<JsonArray>> handler) { 
 delegate.keys(pattern, handler);
 return this;
}

代码示例来源：origin: io.vertx/vertx-rx-java

/**
 * Find all keys matching the given pattern
 * @param pattern Pattern to limit the keys returned
 * @param handler Handler for the result of this call.
 * @return 
 */
public io.vertx.rxjava.redis.RedisClient keys(String pattern, Handler<AsyncResult<JsonArray>> handler) { 
 delegate.keys(pattern, handler);
 return this;
}

代码示例来源：origin: io.vertx/vertx-lang-groovy

public static io.vertx.redis.RedisClient keys(io.vertx.redis.RedisClient j_receiver, java.lang.String pattern, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.List<Object>>> handler) {
 io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.keys(pattern,
  handler != null ? new io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.json.JsonArray>>() {
  public void handle(io.vertx.core.AsyncResult<io.vertx.core.json.JsonArray> ar) {
   handler.handle(ar.map(event -> io.vertx.core.impl.ConversionHelper.fromJsonArray(event)));
  }
 } : null));
 return j_receiver;
}
public static io.vertx.redis.RedisClient lrange(io.vertx.redis.RedisClient j_receiver, java.lang.String key, long from, long to, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.List<Object>>> handler) {

代码示例来源：origin: org.swisspush/redisques

/**
 * Caution: this may in some corner case violate the ordering for one
 * message.
 */
private void resetConsumers() {
  log.debug("RedisQues Resetting consumers");
  String keysPattern = getConsumersPrefix() + "*";
  if (log.isTraceEnabled()) {
    log.trace("RedisQues reset consumers keys: " + keysPattern);
  }
  redisClient.keys(keysPattern, keysResult -> {
    if (keysResult.failed() || keysResult.result() == null) {
      log.error("Unable to get redis keys of consumers", keysResult.cause());
      return;
    }
    JsonArray keys = keysResult.result();
    if (keys == null || keys.isEmpty()) {
      log.debug("No consumers found to reset");
      return;
    }
    redisClient.delMany(keys.getList(), delManyResult -> {
      if (delManyResult.succeeded()) {
        Long count = delManyResult.result();
        log.debug("Successfully reset " + count + " consumers");
      } else {
        log.error("Unable to delete redis keys of consumers");
      }
    });
  });
}