使用Spray、Akka和actorSelection进行异步操作

Question

使用spray时，我一直遇到相同的设计问题，即在Akka中执行一些异步（tell）操作之后，如何为请求找到spray http请求的原始上下文。

我使用的是Net-a-Porter actor per request模型。它创建了一个子执行元，我指定该子执行元来处理每个请求，该子执行元由另一个包含正确请求上下文的执行元进行封装。

def receive: Receive = {
 case v : InputJson =>
   val id = createId
   val redisList = context.actorOf(Props[RedisListActor])
   // At this point, sender is the 'per-request' actor created, which has the HTTP context of the Spray request.
   redisList ! ListRequest(id, sender.path.toStringWithoutAddress, v)

case kr : KubernetesReply =>
  context.system.actorSelection(kr.actorPath) ! TaskResponse("Success", kr.payload, kr.id)

Answer 1

您可以将ActorRef直接放入ListRequest消息中。

case class ListRequest(id: YourIdType, requestActor: ActorRef, json: InputJson)

def receive: Receive = {
  case v : InputJson =>
    val id = createId
    val redisList = context.actorOf(Props[RedisListActor])
    redisList ! ListRequest(id, sender, v)
  case kr : KubernetesReply =>
    kr.requestActor ! TaskResponse("Success", kr.payload, kr.id)
}