akka是否将MDC从源参与者复制到其他参与者和未来？

Question

正如我在akka规范中所读到的，它在actors中支持mdc。例如，我可以将unic信息放在mdc中，然后在actor中使用它。但是期货呢？akka是否提供了任何保证，即在actor中启动的未来将具有相同的mdc？另外，发送给其他参与者的消息呢？默认情况下是否复制了MDC？

注意事项

对我来说，这看起来很奇怪，我只能在一个参与者代码中使用MDC。

Answer 1

他们可以，但实际上没有。当你调用LoggingAdapter的成员时，你实际上调用actor的成员：

package akka.event
trait LoggingAdapter {// and it's implementations DagnosticLoggingAdapter, BusLoggingAdapter

  type MDC = Logging.MDC
  def mdc = Logging.emptyMDC
  def notifyError(message: String): Unit = bus.publish(Error(logSource, logClass, message, mdc))
  ...
}

所以你在这里访问演员的成员。每次处理请求之前都会设置此成员：

package akka.actor
trait DiagnosticActorLogging extends Actor {
  ...

  override protected[akka] def aroundReceive(receive: Actor.Receive, msg: Any): Unit = try {
    log.mdc(mdc(msg))
    super.aroundReceive(receive, msg)
  } finally {
    log.clearMDC()
  }
}

因此，如果您从未来访问它（另一个线程可能与其他消息同时运行）-不能保证您为您的消息选择mdc。与接收器相同的问题，但更深，因为您无法轻松捕获额外的mdc信息。

P. S.akka可以更聪明，以隐式方式获取mdc信息，因此您可以将其捕获为闭包，类似于：

  implicit val metaMdc = getMetaMdc
  Future {

    log.warning(...)
  }

这里的问题是Akka必须在每次登录时将此metaMdc附加到当前线程的mdc（或者您必须以某种方式初始化它），因为SLF4J的mdc是线程本地的，所以每个线程都不同。所以，Akka不知道你要用哪个物理MDC来执行你的log.warning（...）。