Akka - 远程群集发现



我正在设置一个 Akka 集群,以便能够使用 Artery 远程处理连接到其他节点。我按照以下教程设置了几个本地节点来模拟这种效果 (https://developer.lightbend.com/docs/akka-management/current/bootstrap/local-config.html(,它有效。这是我的配置文件:

akka {
  loglevel = INFO
  actor {
    provider = "cluster"
  }
  remote {
    artery {
      enabled = on
      transport = tcp
      hostname = "MY_PUBLIC_IP_ADDRESS(130.231.......)"
      canonical.port = 2551
    }
  }

}
#coorindated-shutdown
akka.cluster.shutdown-after-unsuccessful-join-seed-nodes = 30s
akka.coordinated-shutdown.exit-jvm = on
#coorindated-shutdown
#discovery
akka.discovery {
  config.services = {
    local-cluster = {
      endpoints = [
        {
          host = "127.0.0.2"
          port = 8558
        },
        {
          host = "127.0.0.3"
          port = 8558
        }
      ]
    }
  }
}
#discovery
#health
akka.management.health-checks {
  readiness-path = "health/ready"
  liveness-path = "health/alive"
}
#health
akka.management.http {
  route-providers-read-only = false
}
#bootstrap
akka.management {
  cluster.bootstrap {
    contact-point-discovery {
      service-name = "local-cluster"
      discovery-method = config
    }
  }
}
#bootstrap

现在,当我在另一台具有另一个 IP 地址的机器上启动完全相同的程序实例并在akka.discovery.config.services.local-cluster.endpoints中提供该 IP 地址时,引导程序完全失败(它甚至无法发现以前工作的 127.0.0.2 地址了(,给我连接被拒绝被对等错误消息。

知道我缺少什么其他设置来在完全远程的情况下进行这项工作吗?谢谢!

我对此

的解决方法最终是切换到种子节点设置(不再发现(并按以下格式对 IP 进行硬编码: akka://{CLUSTER_NAME}@{REMOTE_IP}:{PORT}

最新更新