如何在Akka.Delivery中获取远程ProducerController的引用？

我正尝试在本地生产者进程与远程消费者进程之间，使用Akka.Delivery实现Exactly-once交付。根据官方文档的注册流程要求，需要将消费者控制器注册到生产者控制器中。目前已完成两个项目的基础配置，但在注册环节遇到了问题——不知道如何获取处于远程进程中的ProducerController引用。

文档中给出的注册代码示例如下：

private IActorRef CreateConsumerController()
{
    var consumerControllerSettings = ConsumerController.Settings.Create(Context.System);
    var consumerControllerProps = ConsumerController.Create<IMessageProtocol>(Context, Option<IActorRef>.None, consumerControllerSettings);
    var consumerController = Context.ActorOf(consumerControllerProps, "consumer-controller");

    consumerController.Tell(new ConsumerController.Start<IMessageProtocol>(Self));
    consumerController.Tell(new ConsumerController.RegisterToProducerController<IMessageProtocol>(_producerController));

    return consumerController;
}

解决方法 #

获取远程Actor引用的核心是利用Akka的Actor路径寻址，具体步骤如下：

1. 确认远程Actor系统的通信配置
   确保生产者进程的Akka配置已启用远程通信，示例配置：

   akka {
     remote {
       dot-netty.tcp {
         hostname = "192.168.1.100" // 生产者进程的IP或主机名
         port = 8081 // 远程监听端口
       }
     }
   }
   

2. 构建远程ProducerController的Actor路径
   远程Actor的标准路径格式为：akka.tcp://<ActorSystem名称>@<主机名>:<端口>/user/<Actor完整路径>
   假设生产者的ActorSystem名为ProducerSystem，ProducerController的Actor名称是producer-controller，则路径为：

   akka.tcp://ProducerSystem@192.168.1.100:8081/user/producer-controller
   

3. 通过ActorSelection获取并确认引用
   在消费者进程中，先通过路径创建Actor选择器，再发送Identify消息获取真实的IActorRef：

   // 在消费者Actor内部
   var remoteProducerPath = "akka.tcp://ProducerSystem@192.168.1.100:8081/user/producer-controller";
   var producerSelection = Context.ActorSelection(remoteProducerPath);
   
   // 发送Identify消息，用路径作为关联ID
   producerSelection.Tell(new Identify(remoteProducerPath));
   
   // 在消费者Actor的Receive方法中处理响应
   Receive<ActorIdentity>(msg =>
   {
       if (msg.CorrelationId.Equals(remoteProducerPath) && msg.Subject != null)
       {
           var producerController = msg.Subject;
           // 获取到引用后执行注册逻辑
           var consumerController = CreateConsumerController(producerController);
       }
   });
   

4. 调整CreateConsumerController方法
   将原方法改为接收ProducerController引用作为参数：

   private IActorRef CreateConsumerController(IActorRef producerController)
   {
       var consumerControllerSettings = ConsumerController.Settings.Create(Context.System);
       var consumerControllerProps = ConsumerController.Create<IMessageProtocol>(Context, Option<IActorRef>.None, consumerControllerSettings);
       var consumerController = Context.ActorOf(consumerControllerProps, "consumer-controller");
   
       consumerController.Tell(new ConsumerController.Start<IMessageProtocol>(Self));
       consumerController.Tell(new ConsumerController.RegisterToProducerController<IMessageProtocol>(producerController));
   
       return consumerController;
   }
   

注意事项 #

• 确保两个进程使用的Akka版本完全一致，避免序列化/反序列化兼容性问题；
• 验证远程端口的网络连通性，防火墙需开放对应端口；
• 若为复杂分布式场景，可使用Akka.Cluster的集群寻址替代手动指定路径，实现动态发现。

内容的提问来源于stack exchange，提问作者Chandra Eskay