阿卡集羣 - 協會與遠程系統失敗...原因：[公會未能]

Question

我有一個簡單的POC有兩個參與者：

public final class Task1Actor extends AbstractLoggingActor { 
    public Task1Actor() { 
    final UnitPFBuilder<Object> builder = ReceiveBuilder.create() 
     .matchAny(message -> { 
      log().warning("Received unknown message: {}", message); 
      unhandled(message); 
     }); 
    receive(builder.build()); 
    } 

    @Override 
    public void preStart() throws Exception { 
    IntStream.range(0, 5).forEach(i -> { 
     final ActorRef actor = context().actorOf(Props.create(Task2Actor.class)); 
     actor.tell(RandomStringUtils.randomAlphabetic(10), self()); 
    }); 
    } 
} 

---

public final class Task2Actor extends AbstractLoggingActor { 
    public Task2Actor() { 
    final UnitPFBuilder<Object> builder = ReceiveBuilder.create() 
     .match(String.class, this::process) 
     .matchAny(message -> { 
      log().warning("Received unknown message: {}", message); 
      unhandled(message); 
     }); 
    receive(builder.build()); 
    } 

    private void process(final String message) { 
    log().debug("Processing message: {}", message); 
    // Do something useful here in the (not-so far) future 
    } 
} 

這是主類：

final class ClusterSample { 
    public static void main(final String... args) throws Exception { 
    ClusterSample.start(2251); 
    ClusterSample.start(2252); 
    ClusterSample.start(0); 
    } 

    private static void start(final int port) { 
    final Config config = ConfigFactory.parseString(String.format("akka.remote.netty.tcp.port = %s", port)) 
     //.withFallback(ConfigFactory.parseString(String.format("akka.cluster.roles = [%s]", role))) 
     .withFallback(ConfigFactory.load("cluster")); 
    ActorSystem system = ActorSystem.create("ClusterSystem", config); 
    system.actorOf(Props.create(Task1Actor.class)); 
    } 
} 

......這些都是我的配置文件（application.conf和cluster.conf分別）：

akka { 
    actor { 
    default-dispatcher { throughput = 5 } 
    provider = cluster 
    } 

    cluster { 
    seed-nodes = [ "akka.tcp://ClusterSystem@127.0.0.1:2551", "akka.tcp://ClusterSystem@127.0.0.1:2552" ] 
    # roles = ["role"] 
    } 

    remote { 
    log-remote-lifecycle-events = off 
    netty.tcp { 
     hostname = 127.0.0.1 
     port = 0 
    } 
    } 

    loggers = [ "akka.event.slf4j.Slf4jLogger" ] 

    logging-filter = "akka.event.slf4j.Slf4jLoggingFilter" 

    loglevel = DEBUG 
} 

---

include "application" 

akka.cluster.min-nr-of-members = 2 

akka.cluster.role { 
    watson.min-nr-of-members = 2 
} 

akka.actor.deployment { 
} 

我想在這裏實現的是「形成產業集羣」，從已經建立的流程。所以我曾經有過這些演員（真的可以是任何流程），現在我試圖讓他們在（或作爲）羣集中工作。我剛開始閱讀，所以我對此不太瞭解。

我得到的錯誤是：

03-09-2017 16:52:43.749 |- DEBUG in Task2Actor:88 [ClusterSystem-akka.actor.default-dispatcher-20] - Processing message: GCGboeqRKJ 
03-09-2017 16:52:43.749 |- DEBUG in Task2Actor:88 [ClusterSystem-akka.actor.default-dispatcher-21] - Processing message: ykhePhziFT 
03-09-2017 16:52:43.749 |- DEBUG in Task2Actor:88 [ClusterSystem-akka.actor.default-dispatcher-2] - Processing message: SFvnRAlGgg 
03-09-2017 16:52:43.753 |- DEBUG in Task2Actor:88 [ClusterSystem-akka.actor.default-dispatcher-21] - Processing message: bMgBtCzWCI 
03-09-2017 16:52:43.753 |- DEBUG in Task2Actor:88 [ClusterSystem-akka.actor.default-dispatcher-20] - Processing message: ifoOOmqbbv 
03-09-2017 16:52:43.753 |- DEBUG in Task2Actor:88 [ClusterSystem-akka.actor.default-dispatcher-2] - Processing message: ZekwWXmmSQ 
03-09-2017 16:52:43.754 |- DEBUG in Task2Actor:88 [ClusterSystem-akka.actor.default-dispatcher-21] - Processing message: MqXGoSQSzU 
03-09-2017 16:52:43.754 |- DEBUG in Task2Actor:88 [ClusterSystem-akka.actor.default-dispatcher-20] - Processing message: NrdVYAFgrR 
03-09-2017 16:52:43.754 |- DEBUG in Task2Actor:88 [ClusterSystem-akka.actor.default-dispatcher-2] - Processing message: GsjyIsxetC 
03-09-2017 16:52:43.754 |- DEBUG in Task2Actor:88 [ClusterSystem-akka.actor.default-dispatcher-21] - Processing message: LpVNmbriXO 
03-09-2017 16:52:43.754 |- DEBUG in Task2Actor:88 [ClusterSystem-akka.actor.default-dispatcher-20] - Processing message: HCFzOjJwnO 
03-09-2017 16:52:43.755 |- DEBUG in Task2Actor:88 [ClusterSystem-akka.actor.default-dispatcher-2] - Processing message: iqflQMSeJF 
03-09-2017 16:52:43.755 |- DEBUG in Task2Actor:88 [ClusterSystem-akka.actor.default-dispatcher-21] - Processing message: HlyMdMJfUs 
03-09-2017 16:52:43.755 |- DEBUG in Task2Actor:88 [ClusterSystem-akka.actor.default-dispatcher-20] - Processing message: jlwxzLmRsF 
03-09-2017 16:52:43.755 |- DEBUG in Task2Actor:88 [ClusterSystem-akka.actor.default-dispatcher-2] - Processing message: XPSmMYekCs 
03-09-2017 16:52:43.794 |- WARN in ReliableDeliverySupervisor:78 [ClusterSystem-akka.actor.default-dispatcher-20] - Association with remote system [akka.tcp://ClusterSystem@127.0.0.1:2552] has failed, address is now gated for [5000] ms. Reason: [Association failed with [akka.tcp://ClusterSystem@127.0.0.1:2552]] Caused by: [Connection refused: /127.0.0.1:2552] 
03-09-2017 16:52:43.794 |- WARN in ReliableDeliverySupervisor:78 [ClusterSystem-akka.actor.default-dispatcher-21] - Association with remote system [akka.tcp://ClusterSystem@127.0.0.1:2552] has failed, address is now gated for [5000] ms. Reason: [Association failed with [akka.tcp://ClusterSystem@127.0.0.1:2552]] Caused by: [Connection refused: /127.0.0.1:2552] 
03-09-2017 16:52:43.794 |- WARN in ReliableDeliverySupervisor:78 [ClusterSystem-akka.actor.default-dispatcher-20] - Association with remote system [akka.tcp://ClusterSystem@127.0.0.1:2551] has failed, address is now gated for [5000] ms. Reason: [Association failed with [akka.tcp://ClusterSystem@127.0.0.1:2551]] Caused by: [Connection refused: /127.0.0.1:2551] 
03-09-2017 16:52:43.794 |- WARN in ReliableDeliverySupervisor:78 [ClusterSystem-akka.actor.default-dispatcher-2] - Association with remote system [akka.tcp://ClusterSystem@127.0.0.1:2551] has failed, address is now gated for [5000] ms. Reason: [Association failed with [akka.tcp://ClusterSystem@127.0.0.1:2551]] Caused by: [Connection refused: /127.0.0.1:2551] 
03-09-2017 16:52:43.795 |- WARN in ReliableDeliverySupervisor:78 [ClusterSystem-akka.actor.default-dispatcher-21] - Association with remote system [akka.tcp://ClusterSystem@127.0.0.1:2551] has failed, address is now gated for [5000] ms. Reason: [Association failed with [akka.tcp://ClusterSystem@127.0.0.1:2551]] Caused by: [Connection refused: /127.0.0.1:2551] 
03-09-2017 16:52:43.796 |- WARN in ReliableDeliverySupervisor:78 [ClusterSystem-akka.actor.default-dispatcher-2] - Association with remote system [akka.tcp://ClusterSystem@127.0.0.1:2552] has failed, address is now gated for [5000] ms. Reason: [Association failed with [akka.tcp://ClusterSystem@127.0.0.1:2552]] Caused by: [Connection refused: /127.0.0.1:2552] 

我在同一臺機器上執行此而已使用這些端口...保證。我在我的Gradle配置中擁有所有的依賴關係，但仍然無法使其工作。

Answer 1

原來我使用的是不同的端口號;在Java代碼中爲2252和2251，在Akka配置中爲2552和2551。

糾正這將使錯誤消失......但是，如果我打印出演員的路徑，我不認爲它像akka.tcp://. . .但akka:// . . .，所以我會假設整個羣集的東西也無法正常工作。一個不同的故事，也許另一個問題。