Akka.net:访问群集中的远程Actors

Question

在集群环境中,我有一个种子节点和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<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

我以为我在群集上有位置透明性,可以像在本地一样到达远程资源.

这不是那么容易的.请考虑以下场景:如果您在同一路径下的两个节点上创建了一个actor,该怎么办？如果你试图使用相对路径 - 没有显示你想到的节点 - 哪个演员应该收到消息？.

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

有许多方法可以将消息发送给另一个actor,而无需知道它所在的节点.

第一种方法是使用Akka.Cluster.Tools 群集单例功能 - 它允许您最多创建群集中存在的actor的一个实例.如果节点发生故障,它将迁移到另一个节点.请注意,如果您希望让许多演员以这种方式工作,则不应使用此解决方案.对于不同的特殊情况演员来说更是如此.

第二种方法是使用Akka.Cluster.Tools 分布式发布/订阅功能在订阅特定主题的群集中的各个角色之间广播群集范围的事件,而不必担心其实际位置.这是消息广播场景的不错选择.

最后一种方法是使用Akka.Cluster.Sharding功能自动管理actor生命周期 - 您不需要显式创建actor - 它还能够从群集中的任何位置将消息路由到它们,并且可以在需要时在多个群集节点上重新平衡它们.