Akka 2.6 非 Actor 类中的 Actor 发现（在 ActorSystem 之外获取 ActorRef）

Question

目前我正在使用 Akka，我有以下协议。

在我的协议中，我有一个只负责创建资源（房间和 gabblers）的服务器。这些资源被创建然后被访问。接下来，我想通过一个键找到相应的 Gabbler ActorRef 来发送消息，但这一次是从一个公开了一个不是演员的 API/方法的类中。我已经看过文档，令我难以置信的是，演员系统中没有一种方法可以从其层次结构中返回特定的演员来使用它。我已经阅读了接待员部分，虽然对我来说不是很清楚，但我看到它再次面向演员。 Akka中没有根据Actor的路径返回引用的方法吗？

package co.test;

import akka.actor.typed.ActorSystem;
import akka.actor.typed.javadsl.AskPattern;
import akka.actor.typed.receptionist.Receptionist;
import co.test.actors.ChatServer;

public class ChatServerApplication {

    public static void main(String[] args) {
        
        ActorSystem<ChatServer.ServerCommand> system = 
            ActorSystem.create(ChatServer.create(), "chat-server");
        
        system.tell(new ChatServer.NewEventRoom("room1"));
        system.tell(new ChatServer.AttendeeJoin("room1", "user1"));
        system.tell(new ChatServer.AttendeeJoin("room1", "user2"));
        system.tell(new ChatServer.AttendeeJoin("room1", "user3"));
        system.tell(new ChatServer.AttendeeJoin("room1", "user4"));
        system.tell(new ChatServer.AttendeeJoin("room1", "user5"));
        system.tell(new ChatServer.AttendeeJoin("room1", "user6"));
        system.tell(new ChatServer.AttendeeJoin("room1", "user7"));
        
        //ActorRef<Gabbler.Command> gabbler = get specific Gabbler ActorRef
        //gabbler.tell(new Gabbler.SendMessage("test");
    }
    
}

上图中的协议已经实现，但我无法理解上面的问题。

Answer 1

一般来说，为了将数据从actors 获取到actor 系统之外（例如main 方法），您需要处理ask pattern。使用 ask 模式时，您需要设计消息协议来支持它，通常是通过使要被询问的消息具有 ActorRef<ReplyMsg> 字段（通常命名为 replyTo）。 akka.actor.typed.javadsl.AskPattern.ask 有效地创建了一个短暂的actor，将该actor 的ActorRef 注入到消息中，如果它在超时期限内收到一条消息，它会使用该消息完成一个CompletionStage。

在此应用程序中，由于您要路由从 main 到 system 演员的所有内容，因此您可以定义 ChatServer.GetAttendee 消息：

// assuming that there's an interface Command {} already in ChatServer
public class ChatServer extends AbstractBehavior<ChatServer.Command> {
  public static class GetAttendee extends Command {
    public final String room;
    public final String user;
    public final ActorRef<ChatServer.AttendeeIs> replyTo;

    public GetAttendee(String room, String user, ActorRef<ChatServer.AttendeeIs> replyTo) {
      this.room = room;
      this.user = user;
      this.replyTo = replyTo;
    }
  }

  public static class AttendeeIs {
    public final ActorRef<Gabbler.Command> ref

    public AttendeeIs(ActorRef<Gabbler.Command> ref) {
      this.ref = ref;
    }
  }
}

（ChatServer 可能会在相应的ChatRoom 上传递消息）

在您的main 中，您可以发送类似的询问

String desiredRoom = "whatever";
String desiredUser = "whoever";

CompletionStage<ChatServer.AttendeeIs> getGabbler =
  AskPattern.ask(
    system,
    replyTo -> new ChatServer.GetAttendee(desiredRoom, desiredUser, replyTo),
    Duration.ofSeconds(15),
    system.scheduler()
  )

 CompletionStage<ActorRef<Gabbler.Command>> gabblerFuture =
   getGabbler.thenCompose(
     (ChatServer.AttendeeIs response) ->
       return CompletableFuture.completedFuture(response.ref)
   )

 ActorRef<Gabbler.Command> gabbler = gabblerFuture.toCompletableFuture().get()