logging - Akka 自定义记录器收不到一些消息

Question

我为 akka 编写了一个自定义记录器将日志消息传递到远程系统。我有第二个记录器，使用 slf4j与 logback作为后端打印到控制台和日志文件。

我注意到的奇怪的事情是，我的自定义记录器没有收到一些消息，但 slf4j 却可以很好地接收它们。

例如，由失败的子参与者生成的错误消息被记录为监督策略的一部分:

[DEBUG][akka://Test/system/remote-deployment-watcher]: started (akka.remote.RemoteDeploymentWatcher@b342d63)
[DEBUG][akka://Test/system]: now supervising Actor[akka://Test/system/deadLetterListener#-286980524]
started (akka.remote.RemoteDeploymentWatcher@b342d63)
now supervising Actor[akka://Test/system/deadLetterListener#-286980524]
[DEBUG][akka://Test/system/deadLetterListener]: started (akka.event.DeadLetterListener@4a3c6344)
started (akka.event.DeadLetterListener@4a3c6344)
started (akka.remote.RemoteWatcher@14fbdfea)
[DEBUG][akka://Test/system/remote-watcher]: started (akka.remote.RemoteWatcher@14fbdfea)
now supervising TestActor[akka://Test/user/$$a]
[DEBUG][akka://Test/user]: now supervising TestActor[akka://Test/user/$$a]
started (package.Discoverer@24537c20)
now supervising Actor[akka://Test/user/$$a/refresher#-138594901]
[DEBUG][akka://Test/user/$$a]: started (package.Discoverer@24537c20)
[DEBUG][akka://Test/user/$$a]: now supervising Actor[akka://Test/user/$$a/refresher#-138594901]
akka.tcp://Test@127.0.0.1:2552/user/$$a: im an error
[ERROR][akka.tcp://Test@127.0.0.1:2552/user/$$a]: im an error
stopped
[ERROR][akka://Test/user/$$a/refresher]: exception during creation
akka.actor.ActorInitializationException: exception during creation
    at akka.actor.ActorInitializationException$.apply(Actor.scala:164) ~[akka-actor_2.10-2.3.5.jar:na]
    ...

出于调试目的，我的自定义记录器将收到的消息打印到控制台。带有前缀日志级别的消息由 slf4j 生成，中间仅包含该消息的消息由我的自定义记录器生成。

正如您所看到的，我的自定义记录器可以很好地接收调试消息，甚至我手动生成的错误消息“im an error”也可以很好地接收，但不是异常生成的自动消息。

我是否必须为记录器订阅其他事件才能接收这些事件？或者这里有什么问题？

我的记录器:

class MonitoringLogger extends Actor {

  val mon = context.actorOf(Props[MonitorEndpoint], "MonitorEndpoint")

  def receive = {
    case InitializeLogger(bus) => sender ! LoggerInitialized
    case Error(cause, logSource, logClass, message: String) =>
      println(message)
      mon ! format(logSource, message, Console.RED)
    case Warning(logSource, logClass, message: String) => mon ! format(logSource, message, Console.YELLOW)
    case Info(logSource, logClass, message: String) => mon ! format(logSource, message, Console.GREEN)
    case Debug(logSource, logClass, message: String) =>
      println(message)
      mon ! format(logSource, message, Console.GREEN)
  }

  def format(src: String, msg: String, code: String) = s"${Console.BLUE}R> $code[${src.split('/').last}] ${Console.RESET}$msg"
}

application.conf 中有趣的部分:

akka {
  loggers = ["akka.event.slf4j.Slf4jLogger", "package.MonitoringLogger"]
  loglevel = "DEBUG"
  log-dead-letters-during-shutdown = off
  log-dead-letters = 10
  actor.debug {
    lifecycle = on
  }
}

Answer 1

cmbaxter 让我犯了错误。我匹配的 case class Error 定义为:

case class Error(
  cause: Throwable, 
  logSource: String, 
  logClass: Class[_], 
  message: Any = "") extends LogEvent

请注意，消息的类型为Any，但我与String匹配。我自己的日志消息得到匹配，因为我使用字符串消息。该异常的自动生成事件将 message 设置为 null，因此它不满足匹配。