[vertx.redis.client]没有等待消息的处理程序

Question

版本

维特。x核心：3.5.0

vert. x redis客户端：3.5.0

上下文

2018-06-02 17:40:55.981错误4933---[ntlop-thread-2]io.vertx.redis.impl.重新连接：没有处理程序等待消息：14751915

2018-06-02 17:41:10.937错误4933---[ntloop-thread-2]io。维特斯。雷迪斯。impl。重新连接：没有处理程序等待消息：false

2018-06-02 17:41:10.947错误4933---[ntlop-thread-2]io.vertx.redis.impl.重新连接：没有处理程序等待消息：false

2018-06-02 17:41:20.937错误4933---[ntloop-thread-2]io。维特斯。雷迪斯。impl。重新连接：没有处理程序等待消息：true

2018-06-02 17:41:30.937错误4933---[ntloop-thread-2]io。维特斯。雷迪斯。impl。重新连接：没有处理程序等待消息：true

2018-06-02 17:41:35.927错误4933---[ntloop-thread-2]io。维特斯。雷迪斯。impl。重新连接：没有处理程序等待消息：false

2018-06-02 17:41:40.937错误4933---[ntlop-thread-2]io.vertx.redis.impl.重新连接：没有处理程序等待消息：true

2018-06-02 17:41:50.948错误4933---[ntloop-thread-2]io。维特斯。雷迪斯。impl。重新连接：没有处理程序等待消息：true

io的后视图代码。维特斯。雷迪斯。impl。我们无法找到原因：

>

当服务器启动时，创建redis连接，就可以运行了。

长时间（如几天）后，连接状态断开。维特。x redis客户端在向redis服务器发送命令时重新连接redis服务器：

      void send(final Command command) {

    // start the handshake if not connected
    if (state.get() == State.DISCONNECTED) {
      connect();
    }

connect（）调用clearQueue（）

clearQueue（）：等待命令quene将为空。

当收到来自redis服务器的新连接时，调用handleReply（）。

注意：此处会出现错误日志（底部第三行）。

      private void handleReply(Reply reply) {
        final Command cmd = waiting.poll();

        if (cmd != null) {
          switch (reply.type()) {
            case '-': // Error
              cmd.handle(Future.failedFuture(reply.asType(String.class)));
              return;
            case '+':   // Status
              switch (cmd.responseTransform()) {
                case ARRAY:
                  cmd.handle(Future.succeededFuture(new JsonArray().add(reply.asType(String.class))));
                  break;
                default:
                  cmd.handle(Future.succeededFuture(reply.asType(cmd.returnType())));
                  break;
              }
              return;
            case '$':  // Bulk
              switch (cmd.responseTransform()) {
                case ARRAY:
                  cmd.handle(Future.succeededFuture(new JsonArray().add(reply.asType(String.class, cmd.encoding()))));
                  break;
                case INFO:
                  String info = reply.asType(String.class, cmd.encoding());

                  if (info == null) {
                    cmd.handle(Future.succeededFuture(null));
                  } else {
                    String lines[] = info.split("\\r?\\n");
                    JsonObject value = new JsonObject();

                    JsonObject section = null;
                    for (String line : lines) {
                      if (line.length() == 0) {
                        // end of section
                        section = null;
                        continue;
                      }

                      if (line.charAt(0) == '#') {
                        // begin section
                        section = new JsonObject();
                        // create a sub key with the section name
                        value.put(line.substring(2).toLowerCase(), section);
                      } else {
                        // entry in section
                        int split = line.indexOf(':');
                        if (section == null) {
                          value.put(line.substring(0, split), line.substring(split + 1));
                        } else {
                          section.put(line.substring(0, split), line.substring(split + 1));
                        }
                      }
                    }
                    cmd.handle(Future.succeededFuture(value));
                  }
                  break;
                default:
                  cmd.handle(Future.succeededFuture(reply.asType(cmd.returnType(), cmd.encoding())));
                  break;
              }
              return;
            case '*': // Multi
              switch (cmd.responseTransform()) {
                case HASH:
                  cmd.handle(Future.succeededFuture(reply.asType(JsonObject.class, cmd.encoding())));
                  break;
                default:
                  cmd.handle(Future.succeededFuture(reply.asType(JsonArray.class, cmd.encoding())));
                  break;
              }
              return;
            case ':':   // Integer
              switch (cmd.responseTransform()) {
                case ARRAY:
                  cmd.handle(Future.succeededFuture(new JsonArray().add(reply.asType(Long.class))));
                  break;
                default:
                  cmd.handle(Future.succeededFuture(reply.asType(cmd.returnType())));
                  break;
              }
              return;
            default:
              cmd.handle(Future.failedFuture("Unknown message type"));
          }
        } else {
          // **An error log appears here**
          log.error("No handler waiting for message: " + reply.asType(String.class));
        }
      }

问题：

是不是虫子？如果不是错误，重新连接redis服务器时，post命令将被丢弃。

处理这种情况的好方法是什么？

Answer 1

问题已解决，出现上述问题的原因是连接已被重用，尚未关闭，解决方法是：'

RedisClient redisClient = RedisClient.create(this.vertx, redisOptions);
//do some thing; 
redisClient.close(h-{})...

`每节课。