如何在Scala（Akka-Http与Slick）中利用Futures返回API响应？

Akka-Http 本身原生支持异步处理 Future，不需要手动将 Future[Option[Book]] 同步转为 Book，直接利用框架的异步能力即可高效生成响应。以下是具体实现方式：

1. 基础实现：用 complete 直接处理 Future #

Akka-Http 的 complete 指令可以直接接收 Future[T] 类型的参数，框架会自动等待 Future 完成，再将结果序列化为 HTTP 响应。前提是你需要为 Book 类型配置 JSON 序列化（这里以 Spray-JSON 为例）：

import akka.http.scaladsl.server.Directives._
import akka.http.scaladsl.marshallers.sprayjson.SprayJsonSupport._
import spray.json.DefaultJsonProtocol._
import scala.concurrent.Future

// 定义 Book 样例类及 JSON 序列化格式（根据实际字段数量调整 jsonFormatX）
case class Book(id: Int, title: String, author: String)
implicit val bookFormat = jsonFormat3[Book]

// 你的 getBook 函数
def getBook(id: Int): Future[Option[Book]] = ???

// API 路由
val bookRoute = path("books" / IntNumber) { bookId =>
  get {
    val bookFuture = getBook(bookId)
    complete {
      bookFuture.map {
        case Some(book) => StatusCodes.OK -> book
        case None => StatusCodes.NotFound -> s"Book #$bookId not found"
      }
    }
  }
}

2. 处理 Future 异常场景 #

如果 getBook 可能抛出异常（比如数据库连接错误），可以通过 recover 或全局异常处理器来捕获并返回友好响应：

局部异常处理 #

val bookRoute = path("books" / IntNumber) { bookId =>
  get {
    val bookFuture = getBook(bookId)
    complete {
      bookFuture.map {
        case Some(book) => StatusCodes.OK -> book
        case None => StatusCodes.NotFound -> s"Book #$bookId not found"
      }.recover {
        case ex: Exception => StatusCodes.InternalServerError -> s"Server error: ${ex.getMessage}"
      }
    }
  }
}

全局异常处理 #

如果多个路由需要统一异常处理，可定义全局异常处理器：

import akka.http.scaladsl.server.ExceptionHandler

val globalExceptionHandler = ExceptionHandler {
  case ex: java.sql.SQLException =>
    complete(StatusCodes.InternalServerError -> "Database access failed")
  case ex: IllegalArgumentException =>
    complete(StatusCodes.BadRequest -> s"Invalid request: ${ex.getMessage}")
}

val bookRoute = handleExceptions(globalExceptionHandler) {
  path("books" / IntNumber) { bookId =>
    get {
      complete(getBook(bookId).map {
        case Some(book) => StatusCodes.OK -> book
        case None => StatusCodes.NotFound -> s"Book #$bookId not found"
      })
    }
  }
}

为什么不推荐你之前的尝试？ #

• Await.result：会阻塞当前线程，彻底破坏 Akka-Http 的异步非阻塞架构，高并发场景下会导致线程池耗尽，严重影响性能。
• onComplete/foreach：这两个方法仅注册回调逻辑，返回值为 Unit，无法满足 Akka-Http Route 对返回值类型（RouteResult 或其 Future）的要求。

内容的提问来源于stack exchange，提问作者Ni3dzwi3dz