Akka -配置使用REST API服务的Actor的最佳方法(阻塞操作)

import akka.actor.{Actor, ActorSystem, Props}
import akka.http.scaladsl.Http
import akka.http.scaladsl.server.Directives._
import akka.stream.ActorMaterializer

// 定义处理REST API请求的Actor
class MyActor extends Actor {
  def receive: Receive = {
    case GetRequest =>
      // 处理GET请求的逻辑
      complete("GET request received")
    case PostRequest =>
      // 处理POST请求的逻辑
      complete("POST request received")
  }
}

// 定义路由
val route =
  path("api" / "get") {
    get {
      // 调用MyActor处理GET请求
      complete((myActor ? GetRequest).mapTo[String])
    }
  } ~
  path("api" / "post") {
    post {
      // 调用MyActor处理POST请求
      complete((myActor ? PostRequest).mapTo[String])
    }
  }

object Main extends App {
  // 创建Actor系统和材料化器
  implicit val system = ActorSystem("my-system")
  implicit val materializer = ActorMaterializer()

  // 创建MyActor实例
  val myActor = system.actorOf(Props[MyActor], "my-actor")

  // 创建HTTP服务器并绑定路由和端口
  val bindingFuture = Http().bindAndHandle(route, "localhost", 8080)

  // 输出服务器启动信息
  println(s"Server online at http://localhost:8080/")

  // 等待服务器终止
  Await.result(system.whenTerminated, Duration.Inf)
}