Akka.net：访问群集中的远程Actors
在集群环境中，我有一个种子节点和node1和node2。
从node1我想发送一条消息给在node2上创建的Actor。 node2上此节点的本地路径是akka：MyAkkaSystem / user / AnActor。
现在我想通过使用如下的ActorSelection从一个Actor从node1向这个特定的actor发送一条消息：
var actorSystem = ActorSystem.Create("MyTestSystem"); var c = actorSystem.ActorSelection("/user/ConsoleReceiver"); c.Tell("Hello World"); 在node2上，actor已经像这样创建：
var actorSystem = ActorSystem.Create("MyTestSystem"); var r = actorSystem.ActorOf(Props.Create(), "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, ie "akka.tcp://lighthouse@127.0.0.1:4053", "akka.tcp://lighthouse@127.0.0.1:4044" roles = [crawler] } }
作为种子节点，我正在使用灯塔。 从连接的角度来看，一切似乎都有效。 已找到种子并且每个节点都收到了欢迎消息。
我以为我在群集上有位置透明性，可以像在本地一样到达远程资源。
我以为我在群集上有位置透明性，可以像在本地一样到达远程资源。
这并不容易。 请考虑以下场景： 如果您在同一路径下的两个节点上创建了一个actor，该怎么办？ 如果你试图使用相对路径 – 没有显示你想到的节点 – 哪个演员应该收到消息？ 。
使用基本集群function，您可以使用Context.ActorSelection(_cluster.ReadView.Members.Single(m => /* which node you want to choose */).Address + "/user/ConsoleReceiver");轻松选择节点Context.ActorSelection(_cluster.ReadView.Members.Single(m => /* which node you want to choose */).Address + "/user/ConsoleReceiver"); 。 群集扩展为您提供读取视图数据，其中包含有关当前节点可见的所有成员的信息。
有许多方法可以将消息发送给另一个actor，而无需知道它所在的节点。
第一种方法是使用Akka.Cluster.Tools 群集单例function – 它允许您创建群集中存在的actor的最多一个实例。 如果节点发生故障，它将迁移到另一个节点。 请注意，如果您希望让许多演员以这种方式工作，则不应使用此解决方案。 对于不同的特殊情况演员来说更是如此。
第二种方法是使用Akka.Cluster.Tools 分布式发布/订阅function在订阅特定主题的群集中的各个角色之间广播群集范围的事件，而不必担心其实际位置。 这是消息广播场景的不错选择。
最后一种方法是使用Akka.Cluster.Shardingfunction自动管理actor生命周期 – 您不需要显式创建actor – 它还能够从群集中的任何位置将消息路由到它们，并且可以在需要时在多个群集节点上重新平衡它们。