若要进一步自定义日志记录或为死信采取其他行动,你可以订阅事件流。
辅助日志选项
Akka 为非常底层的debug提供了一组配置选项,这些主要是为Akka的开发者所用,而非普通用户。
你一定要将日志级别设为 DEBUG 来使用这些选项:
akka {
loglevel = "DEBUG"
如果你想知道Akka装载了哪些配置设置,下面这个配置选项非常有用:
akka {
# 在actor系统启动时以INFO级别记录完整的配置
# 当你不确定使用的是哪个配置时有用
log-config-on-start = on
如果你希望记录用户级消息的细节,则使用akka.event.LoggingReceive
包装你的actor行为,并打开receive
选项:
akka {
actor {
debug {
# 打开 LoggingReceive 功能, 以DEBUG级别记录所有接收到的消息
receive = on
如果你希望记录Actor处理的所有自动接收的消息的细节:
akka {
actor {
debug {
# 为所有的 AutoReceiveMessages(Kill, PoisonPill 之类) 打开DEBUG日志
autoreceive = on
如果你希望记录Actor的所有生命周期变化 (重启,死亡等 ) 的细节:
akka {
actor {
debug {
# 打开actor生命周期变化的DEBUG日志
lifecycle = on
如果你希望记录所有继承了LoggingFSM的FSM actor的事件、状态转换和计时器的细节:
akka {
actor {
debug {
# 打开所有 LoggingFSMs 事件、状态转换和计时器的DEBUG日志
fsm = on
如果你希望监控对 ActorSystem.eventStream 的订阅/取消订阅:
akka {
actor {
debug {
# 打开eventStream上订阅关系变化的DEBUG日志
event-stream = on
辅助的远程日志选项
如果你希望以DEBUG级别查看所有远程发送的消息: (这些日志是被传输层发送时所记录的,而非actor)
akka {
remote {
# 如果打开这个选项,Akka将以DEBUG级别记录所有发出的消息, 不打开则不记录
log-sent-messages = on
如果你希望以DEBUG级别查看所有接收到的远程消息: (这些日志是被传输层接收时所记录的,而非actor)
akka {
remote {
# 如果打开这个选项,Akka将以DEBUG级别记录所有接收到的消息, 不打开则不记录
log-received-messages = on
如果你希望以INFO级别查看的消息类型与大于指定限制的负载大小 (字节):
akka {
remote {
# Logging of message types with payload size in bytes larger than
# this value. Maximum detected size per message type is logged once,
# with an increase threshold of 10%.
# By default this feature is turned off. Activate it by setting the property to
# a value in bytes, such as 1000b. Note that for all messages larger than this
# limit there will be extra performance and scalability cost.
log-frame-size-exceeding = 1000b
同时参阅 TestKit 的日志选项: 跟踪Actor调用.
将日志源转换为字符串和类
在运行时将源对象转换成要插入 LogEvent
的源字符串和类的规则是使用隐式参数的方式实现的, 因此是完全可配置的: 只需要创建你自己的 LogSource[T]
实例并将它放在创建logger的作用域中即可。
import akka.event.LogSource
import akka.actor.ActorSystem
object MyType {
implicit val logSource: LogSource[AnyRef] = new LogSource[AnyRef] {
def genString(o: AnyRef): String = o.getClass.getName
override def getClazz(o: AnyRef): Class[_] = o.getClass
class MyType(system: ActorSystem) {
import MyType._
import akka.event.Logging
val log = Logging(system, this)
这个例子创建了一个日志源来模拟Java logger的传统用法,该日志源使用原对象的类名作为日志类别。 在这里加入对 getClazz 的重写只是为了作说明,因为它精确地包含了缺省行为。
你也可以先创建字符串然后将它作为日志源传入,但要知道这时放入 LogEvent
中的 Class[_]
将是 akka.event.DummyClassForStringSources
.
SLF4J 事件监听器对这种情况会特殊处理 (使用实际的字符串来查找logger实例而不是类名), 你在实现自己的日志适配器时可能也会这么做。
关闭日志记录
要关闭日志记录,你可以配置日志级别为OFF
像这样。
akka {
stdout-loglevel = "OFF"
loglevel = "OFF"
stdout-loglevel
将仅在系统启动和关闭时起作用,并且也设置为 OFF
,以确保在系统启动或关闭过程中没有日志记录。
事件处理器
日志记录是通过一个事件总线异步地完成的。日志事件都由一个actor事件处理程序来处理,它将按照它们被发送的相同顺序接收日志事件。
你可以配置的系统启动时创建哪一个事件处理程序来监听日志记录事件。这是使用配置中的loggers
元素。你还可以在这里定义日志级别。
akka {
# 在启动时注册的事件处理器 (akka.event.Logging$DefaultLogger 记录日志到标准输出)
loggers = ["akka.event.Logging$DefaultLogger"]
# Options: OFF, ERROR, WARNING, INFO, DEBUG
loglevel = "DEBUG"
缺省会注册一个事件处理器,它将日志记录到标准输出. 在生产系统中不建议使用它。 在 ‘akka-slf4j’ 模块中还有一个 SLF4J logger。
创建监听器的示例:
import akka.event.Logging.InitializeLogger
import akka.event.Logging.LoggerInitialized
import akka.event.Logging.Error
import akka.event.Logging.Warning
import akka.event.Logging.Info
import akka.event.Logging.Debug
class MyEventListener extends Actor {
def receive = {
case InitializeLogger(_) => sender() ! LoggerInitialized
case Error(cause, logSource, logClass, message) =>
case Warning(logSource, logClass, message) =>
case Info(logSource, logClass, message) =>
case Debug(logSource, logClass, message) =>
在启动和关闭时记录日志到stdout
当actor系统启动和关闭配置的loggers
不会被使用。相反日志消息会打印到标准输出stdout(System.out)。对这个stdout logger的默认的日志级别是WARNING
,并可以通过设置 akka.stdout-loglevel=OFF
使其完全沉默。
Akka 为 SL4FJ提供了一个logger. 它在 ‘akka-slf4j.jar’ 模块中. 它的唯一依赖是 slf4j-api 包. 在运行时,你还需要一个 SLF4J 后端, 我们推荐 Logback:
lazy val logback = "ch.qos.logback" % "logback-classic" % "1.0.13"
你需要打开配置中的'loggers'来启用 Slf4jLogger。 你还可以在这里定义事件总线的日志级别。更细粒度的日志级别可以在SLF4j后端的配置(例如:logback.xml)中定义。
akka {
loggers = ["akka.event.slf4j.Slf4jLogger"]
loglevel = "DEBUG"
一个隐含的迷惑是,时间戳在事件处理程序中标记,而不是实际记录时。
SLF4J 为每个日志事件选择日志记录器是基于创建LoggingAdapter
时的日志源的 Class[_]
,除非日志源是一个字符串,那么就使用这个串 (即 LoggerFactory.getLogger(c: Class[_]
用于前者而 LoggerFactory.getLogger(s: String)
用于后者).
如果创建LoggingAdapter时向工厂方法提供了一个ActorSystem
,那么该Actor系统的名字将被加在String
日志源的后面。 如果不希望这样,像下面这样传一个 LoggingBus
:
val log = Logging(system.eventStream, "my.nice.string")
用MDC记录线程日志与Akka源
因为日志的记录是异步的,完成日志记录的线程被保存在 Mapped Diagnostic Context (MDC) 的 sourceThread
属性里. 在 Logback 的模式布局配置中线程名可以通过 %X{sourceThread} 指定:
<appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
<encoder>
<pattern>%date{ISO8601} %-5level %logger{36} %X{sourceThread} - %msg%n</pattern>
</encoder>
</appender>
最好在应用程序的非Akka的部分也使用MDC的 sourceThread
,使得这个值在日志里保持一致。
Akka 的另一个有用的工具是创建logger实例时会捕捉 actor 的地址, 这意味着可以访问到actor实例的全部身份信息来将日志信息与其它信息进行关联(例如:路由的成员)。 这个信息保存在MDC的 akkaSource
属性中:
<appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
<encoder>
<pattern>%date{ISO8601} %-5level %logger{36} %X{akkaSource} - %msg%n</pattern>
</encoder>
</appender>
要了解这个属性所包括的内容(也适用于非actor)的细节见 如何记录日志.
MDC中日志输出更准确的时间戳
Akka的日志记录是异步的,这意味着日志条目的时间戳取的是调用底层的记录器实现的时间,这一开始是令人惊讶的。如果你想要更准确地输出时间戳,使用 MDC 属性 akkaTimestamp
:
<appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
<encoder>
<pattern>%X{akkaTimestamp} %-5level %logger{36} %X{akkaSource} - %msg%n</pattern>
</encoder>
</appender>
由应用程序定义的 MDC 值
Slf4j一个很有用的功能是MDC,Akka有一种方法让应用程序指定自定义值,你只需要湖区特殊的LoggingAdapter
——DiagnosticLoggingAdapter
。为了得到它,你将使用工厂接收actor作为logSource:
val log: DiagnosticLoggingAdapter = Logging(this);
一旦你有了记录器,你只需要在记录日志之前先添加自定义的值。这种方式下,这些值将在日志追加前放在 SLF4J MDC中,并在追加后移除。
清理 (清除) 应该在actor之后处理,否则,如果它不设置新的map, 下一条消息海将使用相同的 mdc 值。使用 log.clearMDC()
。
val mdc = Map("requestId" -> 1234, "visitorId" -> 5678)
log.mdc(mdc)
log.info("Starting new request")
log.clearMDC()
方便起见你可以在actor中混入log
成员,而不是如上定义。这一特质还允许你重写def mdc(msg: Any): MDC
用于为当前消息指定 MDC值,并允许你忘记清理,因为它已经为你做过了。
import Logging.MDC
case class Req(work: String, visitorId: Int)
class MdcActorMixin extends Actor with akka.actor.DiagnosticActorLogging {
var reqId = 0
override def mdc(currentMessage: Any): MDC = {
reqId += 1
val always = Map("requestId" -> reqId)
val perMessage = currentMessage match {
case r: Req => Map("visitorId" -> r.visitorId)
case _ => Map()
always ++ perMessage
def receive: Receive = {
case r: Req => {
log.info(s"Starting new request: ${r.work}")
现在,这些值将可用在MDC中,因此你可以在布局模式中使用它们:
<appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
<encoder>
<pattern>
%-5level %logger{36} [req: %X{requestId}, visitor: %X{visitorId}] - %msg%n
</pattern>
</encoder>
</appender>