常见问题

优质

小牛编辑

134浏览

2023-12-01

Akka Project

Where does the name Akka come from?

It is the name of a beautiful Swedish mountain up in the northern part of Sweden called Laponia. The mountain is also sometimes called 'The Queen of Laponia'.

Akka is also the name of a goddess in the Sámi (the native Swedish population) mythology. She is the goddess that stands for all the beauty and good in the world. The mountain can be seen as the symbol of this goddess.

Also, the name AKKA is the a palindrome of letters A and K as in Actor Kernel.

Akka is also:

the name of the goose that Nils traveled across Sweden on in The Wonderful Adventures of Nils by the Swedish writer Selma Lagerlöf.
the Finnish word for 'nasty elderly woman' and the word for 'elder sister' in the Indian languages Tamil, Telugu, Kannada and Marathi.
a font
a town in Morocco
a near-earth asteroid

Actor总体

当我在Actor中使用Future时，sender()/getSender()消失了，为什么呢？

当在Actor内部使用Future回调时需要小心，避免闭合包含Actor的引用，即对闭合的Actor不在回调内调用方法或访问其内的可变状态。这将打破Actor封装，因为回调将被调度与闭合的Actor并发执行，所以可能会引入同步 bug 和竞态条件。不幸的是没有编译时的方法发现这些非法访问。

更多内容参见Actor与共享可变状态的文档。

为什么发生OutOfMemoryError？

产生OutOfMemoryError错误的原因很多。例如，在基于纯推送系统中，消费者的消息处理速度可能低于相应消息生产者，必须添加某种消息流量控制。否则邮件将在消费者的邮箱中排队，从而填满堆内存。

一些寻找灵感的文章：

Actors Scala API

我怎么会得到`receive`方法丢失消息的编译时错误呢？

一种解决方案来帮助你获得警告，因为基于你的actor输入输出消息实现基本特质的定义，编译时将检查的处理消息的全面性，如有遗漏将会告警。

这里有一个例子，编译器将发出警告你接收的比配并不是详尽无遗的：

object MyActor {
  // these are the messages we accept
  sealed abstract trait Message
  case class FooMessage(foo: String) extends Message
  case class BarMessage(bar: Int) extends Message

  // these are the replies we send
  sealed abstract trait Reply
  case class BazMessage(baz: String) extends Reply
}

class MyActor extends Actor {
  import MyActor._
  def receive = {
    case message: Message => message match {
      case BarMessage(bar) => sender ! BazMessage("Got " + bar)
      // warning here:
      // "match may not be exhaustive. It would fail on the following input: FooMessage(_)"
    }
  }
}

Remoting

我想发送到远程系统，但它没有做任何事情

请确保你有在两端上都启用远程处理：客户端和服务器。两端都需要配置主机名和端口，而且你将需要知道服务器端口；客户端在大多数情况下可以使用一个自动的港口（即配置端口为零）。如果这两个系统在同一网络主机上运行，它们的端口必须是不同的。

如果仍然看不到任何东西，看看远程的生命周期事件的日志记录了什么（通常在 INFO 级别）或打开辅助的远程日志记录选项，以查看所有发送和接收消息（在DEBUG级别）。

调试远程处理问题时，应启用哪些选项？

详见远程配置，典型的候选人是：

akka.remote.log-sent-messages
akka.remote.log-received-messages
akka.remote.log-remote-lifecycle-events (this also includes deserialization errors)

远程Actor的名字是什么？

当你想要将消息发送到远程主机上的Actor时，你需要知道它的完整路径，格式如下：

akka.protocol://system@host:1234/user/my/actor/hierarchy/path

所需要的部分是：

protocol是要用来与远程系统进行通信的协议。大多数情况下是 tcp。
system是远程系统的名称（必须完全匹配，区分大小写!)
host是远程系统的 IP 地址或 DNS 名称，它必须匹配该系统的配置（即 akka.remote.netty.hostname）
1234 是侦听连接和接收消息的远程系统的端口号
/user/my/actor/hierarchy/path 是远程Actor在远程系统监督层次结构中的绝对路径，包括系统的监护者(即 /user还有其他如/system承载日志记录器，/temp 保存使用ask()创建的临时Actor引用，/remote启用远程部署等);这符合该Actor在远程主机上打印它自身的引用的方式，例如在日志输出。

为什么没有收到远程Actor的答复？

最常见的原因是本地系统名称（即上述答案中的 system@host:1234 部分）是从远程系统的网络位置不可以到达的，例如因为host被配置为为0.0.0.0，localhost或 NAT'ed IP 地址。

消息如何可靠传递？

一般的规则是至多一次交付(at-most-once delivery)，即没有保证。可以在其上面建立更强的可靠性，Akka提供了工具来这样做。

详见消息传递可靠性。

调试

如何打开调试日志记录

若要打开actor系统调试日志记录，添加如下配置：

akka.loglevel = DEBUG

若要打开不同类型的调试日志记录，添加如下配置：

akka.actor.debug.receive 将记录发送到一个actor的所有消息，如果actor receive方法是 LoggingReceive
akka.actor.debug.autoreceive 将记录发送给所有actor的所有特殊消息如Kill， PoisonPill等
akka.actor.debug.lifecycle 将记录所有actor的所有actor生命周期事件

更多内容参见日志记录和追踪Actor调用。