警告i.v.c.e.i.clustered.ConnectionHolder失败

Question

我收到一条错误消息:

10:29:56.116 [vert.x-worker-thread-18] WARN  i.v.c.e.i.clustered.ConnectionHolder - Connecting to server localhost:53990 failed

对此，我进行了讨论：https://groups.google.com/forum/#!主题/vertx/bws3x9-WsV0，其中一个回复是：

你如何开始垂直。x？CLI和启动器类中有一个主机名检测机制。如果您有自己的主类，请确保正确设置ClusterHost选项。

因此，我在中查找描述https://vertx.io/docs/vertx-hazelcast/java/

它说：

当 Vert.x 处于集群模式运行时，您还应该确保 Vert.x 知道正确的接口。在命令行运行时，这是通过指定群集主机选项来完成的：vertx 运行 myverticle.js群集 -群集-主机您的 IP 地址 其中您的 IP 地址与您在 Hazelcast 配置中指定的 IP 地址相同。如果以编程方式使用 Vert.x，则可以使用集合簇主机来指定它。

我得到这个，因为我假设本地主机会很好。我只是在尝试双节点配置，请参阅 https://github.com/rc-dukes/dukes/issues/19

需要什么来理解和解决这个问题？

https://github.com/vert-x3/vertx-maven-starter/issues/6

展示另一个启动器可能会搞砸事情的场景。我怎么能调试这个？

Answer 1

日志输出显示，所涉及的两个vert.x客户端确实通过多播连接器正确连接(x.y.z隐藏了真实的ip):

08:42:09.539 [hz._hzInstance_1_dev.priority-generic-operation.thread-0] INFO  c.h.internal.cluster.ClusterService - [x.y.z.82]:5701 [dev] [3.12.5] 

Members {size:2, ver:8} [
    Member [x.y.z.82]:5701 - 29b35836-aad1-4314-af62-c453ce200ffa this
    Member [x.y.z.25]:5701 - f67995b7-f47e-4037-b7a4-fcedeff4fc91
]

其中一个客户端是树莓派，默认情况下，它使用127.0.0.1主机地址标识自己。

删除/etc/hosts中的条目并用具有完整ip地址的正确条目替换它是第一步。

cat /etc/hosts
127.0.0.1   localhost
::1     localhost ip6-localhost ip6-loopback
ff02::1     ip6-allnodes
ff02::2     ip6-allrouters

# on the main network
x.y.z.82 picarford.bitplan.com picarford

然后，需要将主机名用作所有成员的主机/群集主机。

hostname=InetAddress.getLocalHost().getCanonicalHostName()
starter.setClusterHost(hostname,hostname)

看ClusterStarter.java

   /**
   * prepare the starter
   */
  public void prepare() {
    if (!prepared) {
      Config.configureLogging();
      try {
        setHostname(InetAddress.getLocalHost().getCanonicalHostName());
      } catch (UnknownHostException e) {
        LOG.error(e.getMessage());
      }
      prepared = true;
    }
  }

  private String hostname;

  /**
   * configure the cluster
   * @param clusterHostname
   * @param publicHost
   */
  public void configureCluster(String clusterHostname,String publicHost) {
    if (clusterHostname == null) {
      clusterHostname=getHostname();
    }
    if (publicHost==null) {
      publicHost=getHostname();
    }
    String msg=String.format("starting cluster on %s setting host to %s and clusterPublicHost to %s",getHostname(),clusterHostname,publicHost);
    LOG.info(msg);
    EventBusOptions eventBusOptions = getOptions().getEventBusOptions();
    // https://github.com/eclipse-vertx/vert.x/issues/3229
    // https://stackoverflow.com/a/49028531/1497139
    // https://vertx.io/docs/apidocs/io/vertx/core/eventbus/EventBusOptions.html#setClusterPublicHost-java.lang.String-
    eventBusOptions.setHost(clusterHostname);
    eventBusOptions.setClusterPublicHost(publicHost);
  }