如何在Akka中使用非阻塞代码连续调用REST服务

import akka.actor.{Actor, ActorSystem, Props}
import akka.http.scaladsl.Http
import akka.http.scaladsl.model._
import akka.http.scaladsl.unmarshalling.Unmarshal
import akka.stream.ActorMaterializer
import scala.concurrent.Future
import scala.concurrent.duration._

case class RestRequest(url: String)
case class RestResponse(data: String)

class RestActor extends Actor {
  import context.dispatcher
  implicit val system = context.system
  implicit val materializer = ActorMaterializer()

  def receive: Receive = {
    case RestRequest(url) =>
      val senderRef = sender()
      val responseFuture: Future[HttpResponse] = Http().singleRequest(HttpRequest(uri = url))
      responseFuture.flatMap { response =>
        Unmarshal(response.entity).to[String]
      }.map { data =>
        senderRef ! RestResponse(data)
      }
  }
}

object Main extends App {
  val system = ActorSystem("rest-system")
  val restActor = system.actorOf(Props[RestActor], "rest-actor")

  val url1 = "https://api.example.com/service1"
  val url2 = "https://api.example.com/service2"

  val response1 = restActor ? RestRequest(url1)
  val response2 = response1.flatMap {
    case RestResponse(data1) =>
      restActor ? RestRequest(url2)
  }

  response2.map {
    case RestResponse(data2) =>
      // 处理最终的响应数据
      println(s"Final response: $data2")
  }

  // 等待一段时间后关闭Actor系统
  system.scheduler.scheduleOnce(5.seconds) {
    system.terminate()
  }
}