我为 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
}
}
最佳答案
cmbaxter 让我犯了错误。我匹配的 case class Error
定义为:
case class Error(
cause: Throwable,
logSource: String,
logClass: Class[_],
message: Any = "") extends LogEvent
请注意,消息
的类型为Any
,但我与String
匹配。我自己的日志消息得到匹配,因为我使用字符串消息。该异常的自动生成事件将 message
设置为 null
,因此它不满足匹配。
关于logging - Akka 自定义记录器收不到一些消息,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/25636820/