我尝试使用域驱动设计编写Akka HTTP Web服务，但我很难将Web服务接收到的技术数据传递给Future（即客户端发送给Web服务的correlationId）内执行工作的代码。
我对DDD的理解是，作为一种实现选择，correlationId不应该出现在域中：

package domain
trait MyRepository {
  def startWork(): Future[Unit]
}

为了使它在不作为方法参数的情况下对实现代码可用，我考虑使用线程本地存储，如org.slf4j.MDC或ThreadLocal。但是，我不知道这是否可行，或者对Web服务的多个调用是否会由同一个线程处理并覆盖该值。
以下是实现：

package infra
class MyRepository(implicit executor: ExecutionContextExecutor) extends domain.MyRepository {
  override def startWork(): Future[Unit] = {
    Future {
      val correlationId = ??? // MDC.get("correlationId") ?
      log(s"The correlationId is $correlationId")
    }
  }
}

我的Web服务中的路由：

val repo = new infra.MyRepository()
val route = path("my" / "path") {
  post {
    parameter('correlationId) { correlationId =>
      ??? // MDC.put("correlationId", correlationId) ?
      onComplete(repo.startWork()) {
        complete(HttpResponse(StatusCodes.OK))
      }
    }
  }
}

我的问题有两个：

• 我的总体设计是否合理，DDD是否良好？
• 使用org.slf4j.MDC或ThreadLocal是否有效，或者是否有更好/更适合Akka的实现方式？