将Akka演员捆绑在喷雾路线中

Question

我有一个restful API，它接收一组JSON消息，这些消息将被转换为单独的Avro消息，然后发送到Kafka。在路由中，我调用3个不同的actor：1）一个actor出去，从磁盘中检索Avro模式；2）然后循环访问JSON消息数组，并将其与第二个actor中的Avro模式进行比较。如果任何消息没有验证，那么我需要返回一个响应给API的调用者并停止处理。3）循环访问数组并传递到第三个actor中，该actor接收JSON对象，将其转换为Avro消息并发送到Kafka主题。

post {
entity(as[JsObject]) { membersObj =>
      requestContext =>
        val membersJson = membersObj.fields("messages").convertTo[JsArray].elements
        val messageService = actorRefFactory.actorOf(Props(new MessageProcessingServicev2()))
        val avroService = actorRefFactory.actorOf(Props(new AvroSchemaService()))
        val validationService = actorRefFactory.actorOf(Props(new JSONMessageValidationService()))

        implicit val timeout = Timeout(5 seconds)

        val future = avroService ? AvroSchema.MemberSchema(requestContext)
        val memberSchema:Schema = Await.result(future, timeout.duration).asInstanceOf[Schema]

        for (member <- membersJson) validationService ! ValidationService.MemberValidation(member.asJsObject, memberSchema, requestContext)

        for (member <- membersJson) (messageService ! MessageProcessingv2.ProcessMember(member.asJsObject, topicName, memberSchema, requestContext))

我浏览了很多关于这个主题的博客/书籍/幻灯片，但不确定最好的方法是什么。我已经使用Scala/Akka大约两个月了，基本上自学了我需要的部分。因此，经验丰富的Scala/Akka/Spray开发人员在这方面的任何见解都是非常值得赞赏的。我的一个想法是把3个演员包装成一个“主”演员，让每个演员都成为那个演员的孩子，并试图像那样接近它。

Answer 1

由于您正在使用异步处理(！)，您无法控制邮件发送后的处理。您需要使用ask(？)，它将返回您可以使用的将来值。

但我有个更好的主意。您可以将消息从第一个演员发送到第二个演员。您可以将消息发送给第三个参与者，而不是将结果返回给第一个参与者，以便继续计算。