我想在我的AKKA应用程序中实现logback MDC日志记录,以便组织并获得更多信息的日志;然而,我也读到MDC可能与AKKA不兼容,因为AKKA有异步日志系统(MDC可能存储在不同的线程上)。我使用了此处定义的自定义分发器进行MDC日志记录,希望解决我的问题,但我无法使其在我的应用程序中工作。虽然我的应用程序不是Play框架应用程序,但我有一个
在我的
我该如何进行MDC日志记录,使某个请求期间执行的所有代码日志(包括依赖库日志)具有相同的messageId、requestType logstamp?除了AKKA自定义调度程序之外,是否还有其他方法可以实现这一点?此外,声明
谢谢。
RequestHandler
Actor,它接收不同类型的请求并将其委托给RequestSpecificHandler
Actor来处理。class RequestHandler() extends Actor with akka.actor.ActorLogging {
def receive: Receive = {
//Requests
case req: RequestA =>
org.slf4j.MDC.put("messageId", req.msgId)
org.slf4j.MDC.put("requestType", req.requestType)
log.debug("FIRST LOG Received a RequestA")
val actorA = context.ActorOf(ActorA.props)
actorA ! req.msg
case req: RequestB => //...
//other requests...
//Response
case res: ResponseA =>
log.debug("Received responseA")
org.slf4j.MDC.remove("messageId")
org.slf4j.MDC.remove("requestType")
//other response
}
}
在我的
RequestSpecificHandler
演员中,我还创建了新的或引用其他现有的HelperActors
。class ActorA () extends Actor with akka.actor.ActorLogging {
val helperA = context.actorSelection("/user/helperA")
val helperB = context.actorOf("HelperB.props")
def receive: Receive = {
case msg: MessageTypeA =>
//do some stuff
log.debug("received MessageTypeA")
helperA ! taskForA
case doneByA =>
//do some stuff
log.debug("received doneByA")
helperB ! taskForB
case doneByB =>
log.debug("send reponseA")
sender ! ResponseA
}
}
每次发送请求时,日志记录的方式都不同,有时会记录正确的MDC messageId和requestType值,有时则没有任何值。即使是"FIRST LOG Received a RequestA"
这个日志也是如此,我认为它应该总是有正确的日志时间戳,因为它是在我调用MDC.put
的相同类中。
以下是我的application.conf:
akka {
log-dead-letters = 10
loggers = ["akka.event.slf4j.Slf4jLogger"]
loglevel = DEBUG
logging-filter = "akka.event.slf4j.Slf4jLoggingFilter"
actor{
default-dispatcher {
type = "some.package.monitoring.MDCPropagatingDispatcherConfigurator"
}
...
我该如何进行MDC日志记录,使某个请求期间执行的所有代码日志(包括依赖库日志)具有相同的messageId、requestType logstamp?除了AKKA自定义调度程序之外,是否还有其他方法可以实现这一点?此外,声明
MDC.put
和MDC.remove
代码的更有组织的方式是什么?目前,我在每个接收案例中都有这些代码。谢谢。