Akka ActorSystem组件用法示例

ActorSystem是actor结构中的根actor。一个ActorSystem是一组共享通用配置(例如, 调度程序, 部署, 远程功能和地址。它也是创建或查找演员的切入点。这是一个扩展到ActorRefFactory特性的抽象类。

ActorSystem提供了一个actorOf()方法, 该方法用于创建actor实例。

Akka ActorSystem组件

1)死信局

无法传递的消息将传递给名为deadLetters的角色。通过不可靠的网络发送的邮件将丢失, 而无需转发到死信办公室。该功能的主要用途是用于调试目的, 尤其是当参与者发送的消息不一致到达时。你可以通过导入akka.actor.DeadLatter包来实现此目的。

2)用户监护人演员

它是用户使用ActorSystem创建的actor的父actor。这个特殊的守护程序用于实现有序的关闭顺序, 在该顺序中, 日志记录保持活动状态, 而所有常规actor都终止。它监视所有用户创建的参与者。

3)系统守护者

该角色与用户守护者角色相同, 但它适用于系统角色。系统监护人监视用户监护人, 并在收到终止消息后启动其自身的关闭。

4)排程器

调度程序是一个特征, 并扩展到AnyRef。它用于处理计划的任务。它提供了安排消息的功能。你可以安排消息发送和任务执行。它为每个ActorSystem创建新实例, 以安排任务在特定时间发生。

它返回一个可取消的引用, 以便你可以通过对此引用对象调用cancel方法来取消计划的操作的执行。

你可以通过导入akka.actor.Scheduler包来实现Scheduler。

5)事件系统

事件系统(也称为eventStream)是每个ActorSystem的主事件总线。它用于承载日志消息和无效消息。你还可以使用它在整个ActorSystem上发布消息。你可以通过调用actorSystemRef.eventStream()方法获取eventStream参考。

6)配置

ActorSystem提供了一个用于配置应用程序的配置组件。你可以从演员系统访问它。