在 Akka 类型化演员中配置调度程序

Question

我正在使用 Akka 类型，但我无法检查官方文档(https://doc.akka.io/docs/akka/current/typed/actors.html#actors(，我发现它真的很短，如何在输入的 Actor 中配置调度程序。

这是我的代码示例

private int actorTimeout = Integer.parseInt(getProperty("environment.actor.timeout", "10"));
@Autowired
private AkkaTypedDAO akkaTypedDAO;
private ActorSystem<AkkaTypedDTO> system;
@PostConstruct
private void initActor() {
system = ActorSystem.create(akkaTypedDAO.daoWithSupervisor, "AkkaTypedDAO");
}
private final Behavior<CommandAkkaTyped> service = Actor.immutable((ctx, msg) -> {
sendToDAO(msg.id).thenApply(either -> {
msg.replyTo.tell(either);
return either;
});
return Actor.same();
});
public final Behavior<CommandAkkaTyped> serviceWithSupervisor = Actor.supervise(service).onFailure(Exception.class, restart());
private CompletionStage<Either<ConnectorErrorVO, EntityDaoDTO>> sendToDAO(MUSIn<AkkaTypedPayLoad> id) {
return AskPattern.ask(system,
(ActorRef<Either<ConnectorErrorVO, EntityDaoDTO>> replyTo) -> new AkkaTypedDTO(new EntityDaoDTO(musIn), replyTo),
new Timeout(actorTimeout, TimeUnit.SECONDS), system.scheduler());
}

当我创建我的Actor系统时，如何为我的Actor.immutable配置调度程序？

Answer 1

您使用的是过时的 Akka Typed 版本(有关 Akka Typed API 历史的更多信息，请参阅此处(。从当前版本(截至撰写本文时，2.5.14(的 Akka Typed 文档：

要在生成参与者时指定调度程序，请使用调度程序选择器。如果未指定，参与者将使用默认调度程序，有关详细信息，请参阅默认调度程序。

public static final Behavior<Start> main =
Behaviors.setup(context -> {
final String dispatcherPath = "akka.actor.default-blocking-io-dispatcher";
Props props = DispatcherSelector.fromConfig(dispatcherPath);
final ActorRef<HelloWorld.Greet> greeter =
context.spawn(HelloWorld.greeter, "greeter", props);
return Behaviors.receiveMessage(msg -> {
ActorRef<HelloWorld.Greeted> replyTo =
context.spawn(HelloWorldBot.bot(0, 3), msg.name);
greeter.tell(new HelloWorld.Greet(msg.name, replyTo));
return Behaviors.same();
});
});