Akka.net:访问集群中的远程代理程序

Question

在集群环境中，我有一个种子节点以及node1和node2。

从node1中，我想向node2上创建的Actor发送一条消息。node2上这个节点的本地路径是akka:MyAkkaSystem/user/AnActor。

现在，我想通过使用这样的一个node1，从Actor向这个特定的参与者发送一条消息：

var actorSystem = ActorSystem.Create("MyTestSystem");
var c = actorSystem.ActorSelection("/user/ConsoleReceiver");
c.Tell("Hello World");

在node2上，演员就是这样创建的：

var actorSystem = ActorSystem.Create("MyTestSystem");
            var r = actorSystem.ActorOf(Props.Create<MessageReceiver>(), "ConsoleReceiver");
            Console.WriteLine(r.Path);
            Console.ReadLine();
            actorSystem.Terminate().Wait();

不幸的是，这是行不通的，因为尝试以死信结束。

node2上的HOCON配置如下所示：

akka {
    actor {
      provider = "Akka.Cluster.ClusterActorRefProvider, Akka.Cluster"                  
      deployment {                  
      }              
    }

    remote {
      log-remote-lifecycle-events = DEBUG
      log-received-messages = on

      helios.tcp {
        transport-class = "Akka.Remote.Transport.Helios.HeliosTcpTransport, Akka.Remote"
            applied-adapters = []
            transport-protocol = tcp       
        hostname = "127.0.0.1"
        port = 0
      }
    }            

    cluster {
      #will inject this node as a self-seed node at run-time
      seed-nodes = ["akka.tcp://webcrawler@127.0.0.1:4053"] #manually populate other seed nodes here, i.e. "akka.tcp://lighthouse@127.0.0.1:4053", "akka.tcp://lighthouse@127.0.0.1:4044"
      roles = [crawler]
    }
  }

作为种子节点，我使用灯塔。从联系的角度来看，一切似乎都很顺利。种子已经找到，每个节点都收到了一条欢迎消息。

我认为我在集群上有位置透明性，并且可以到达远程资源，就好像它们是本地的一样。

Answer 1

我认为我在集群上有位置透明性，并且可以到达远程资源，就好像它们是本地的一样。

这可不容易。考虑以下场景:如果您在同一路径下的两个节点上创建了一个参与者，该怎么办？如果您尝试使用相对路径(而不显示您想要的是哪个节点)，那么哪个参与者应该接收消息？

使用基本的集群功能，您可以使用Context.ActorSelection(_cluster.ReadView.Members.Single(m => /* which node you want to choose */).Address + "/user/ConsoleReceiver");轻松选择节点。集群扩展为您提供了一个读取视图数据，其中包含从当前节点可见的所有成员的信息。

有许多方法可以向另一个参与者发送消息，而不必知道它位于哪个节点上.

第一种方法是使用Akka.Cluster.Tools 簇单例特性-它允许您最多创建集群中的参与者的一个实例。如果节点发生故障，它将迁移到另一个节点。请注意，如果您想让许多参与者以这种方式工作，则不应该使用此解决方案。它更适合不同的，特殊情况的演员。

第二种方法是使用Akka.Cluster.Tools 分布式Pub/Sub特性在集群中订阅特定主题的参与者之间广播集群范围内的事件，而不必担心它们的实际位置。对于消息广播场景来说，这是很好的选择。

最后一种方法是使用Akka.Cluster.Sharding特性，它自动管理参与者生命周期--您不需要显式地创建参与者--它还可以将消息从集群中的任何地方路由到它们，并且在需要时可以在许多集群节点上对它们进行重新平衡。