Akka消息传递机制示例

Question

我有相当多的Apache Camel（路由/中介/Orchestation Engine；轻量级ESB）经验,正在绞尽脑汁地试图理解AKKA：

• 调度程序(Dispatcher,PinnedDispatcher,CallingThreadDispatcher)
• 路由器
• 池
• 组
• 事件总线

根据文件：

调度员是：

将路由创建为子参与者,并在路由终止时将其从路由器中删除的路由器的[一种类型]。

组包括：

[一种类型的]执行元[其中路由]是在路由器外部创建的,路由器使用执行元选择将消息发送到指定路径,而不监视终止。

• 调度器、路由器和事件总线之间有什么区别，何时使用它们？
• 何时使用池与组？

Answer 1

dispatcher基本上是一个线程池。Akka使用dispatcher进行多项操作（比如在正确的邮箱中对消息进行排队，或者从actor邮箱中提取消息并对其进行处理）。每次需要执行其中的一个操作时，都会从线程池中选择一个线程并将其用于该操作。Akka默认带有default-dispatcher配置，您可以在reference.conf中搜索default-dispatcher。您已经在使用default-dispatcher，但是您可以定义一个不同的dispatcher，以确保您有一个用于其他目的的保留线程池（例如，在使用akka-remote或akka-cluster时用于netty线程）。

Akka中的路由器是使用某种路由逻辑将消息路由到路由列表的参与者。根据逻辑的不同,路由器有很多种类型：广播、平衡、轮询...你可以在akka文档中找到它们。路由器的路由可以是池或组。路由器最流行的一个用例是垂直扩展应用程序，这意味着最大限度地利用系统中所有可用的CPU（同时使用多个线程）。

池意味着为给定类型按需创建路由。例如，您可能需要一个包含3个实例的MyFancyActor的RandomPool。Akka将创建myfancyactor的三个参与者，以及第四个作为实际路由器的参与者。路由器执行元每次获得消息时，都会将消息转发给3个MyFancyActor执行元之一。池负责重启参与者并监视它们的生命周期，以确保您有n个实例在运行。

组表示在您定义路由器之前创建路由。定义路由器后，需要传递先前创建的路由执行元列表。一个小组将不会监视您的演员的生命周期，您将需要自己做这件事。

事件总线是一个通道，您可以在其中订阅特定类型的消息。如果有一个特定类型的消息，您的演员将得到它。这用于某些Akka内部功能，如在消息无法到达其目的地时订阅deadletter，或与集群形成有关的事件（在akka-cluster中）。您将使用它来了解ActorSystem中发生的事件。