Akka HTTP Routing DSL示例失效，无法搭建极简POST请求服务器

首先，你的问题主要来自Akka 2.6.x和Akka HTTP 10.2.x的API变化——官方文档可能没及时更新细节，导致你踩了两个小坑：

一、修正你的Akka HTTP代码 #

下面是能正常运行的版本，我标注了关键修改点：

完整可运行代码 #

import akka.actor.ActorSystem
import akka.http.scaladsl.Http
import akka.http.scaladsl.model.ContentTypes._
import akka.http.scaladsl.model.HttpEntity
import akka.http.scaladsl.server.Directives._
import akka.stream.Materializer
import scala.concurrent.ExecutionContextExecutor
import scala.io.StdIn

object Main extends App {
  implicit val system: ActorSystem = ActorSystem("server-system")
  // 关键修改1：用system.dispatcher获取ExecutionContext（Akka 2.6.x经典ActorSystem的正确方式）
  implicit val executionContext: ExecutionContextExecutor = system.dispatcher
  // 关键修改2：添加Akka HTTP需要的隐式Materializer实例
  implicit val materializer: Materializer = Materializer(system)

  // 新增POST请求处理的示例路由
  val route = path("test") {
    get {
      complete(HttpEntity(`text/plain(UTF-8)`, "GET test response"))
    } ~
    post {
      // 解析POST请求的文本内容并返回
      entity(as[String]) { body =>
        complete(HttpEntity(`text/plain(UTF-8)`, s"Received POST body: $body"))
      }
    }
  }

  val address = "localhost"
  val port = 8080
  val bindingFuture = Http().newServerAt(address, port).bind(route)

  println(s"Server online at http://$address:$port\nPress RETURN to stop...")
  StdIn.readLine()

  bindingFuture
    .flatMap(_.unbind())
    .onComplete(_ => system.terminate())
}

问题原因解释 #

1. ExecutionContext找不到：Akka 2.6.x的经典ActorSystem中，执行上下文需要通过system.dispatcher获取，而不是system.executionContext（后者是Typed ActorSystem的API）。
2. unbind()缺少隐式值：Akka HTTP 10.2.x需要隐式的Materializer实例来处理流操作，你的代码之前缺少这个，导致后续异步操作找不到必要的隐式依赖。

二、更易用的极简HTTP服务器库推荐 #

如果觉得Akka HTTP的配置和隐式依赖太繁琐，这些轻量库更适合快速搭建极简服务：

• Scalatra：对标Ruby Sinatra的极简框架，路由定义直观，学习成本极低，适合快速原型开发。
• Http4s：纯函数式风格的轻量库，基于Cats生态，代码简洁且灵活，适合函数式编程场景。
• Finatra：Twitter开源的框架，基于Finagle，内置JSON处理和常用工具，性能出色，适合生产级服务。

Scalatra极简示例（含POST） #

import org.scalatra._

class TestServlet extends ScalatraServlet {
  // 处理GET请求
  get("/test") {
    "GET test response"
  }
  // 处理POST请求
  post("/test") {
    s"Received POST body: ${request.body}"
  }
}

// 启动服务器
import org.eclipse.jetty.server.Server
import org.eclipse.jetty.servlet.{ServletContextHandler, ServletHolder}

object Main extends App {
  val server = new Server(8080)
  val context = new ServletContextHandler(ServletContextHandler.SESSIONS)
  context.setContextPath("/")
  server.setHandler(context)
  context.addServlet(new ServletHolder(new TestServlet), "/*")
  
  server.start()
  println(s"Server online at http://localhost:8080\nPress RETURN to stop...")
  StdIn.readLine()
  server.stop()
}

对应的Gradle依赖：

compile group: 'org.scalatra', name: 'scalatra_2.12', version: '2.8.2'
compile group: 'org.eclipse.jetty', name: 'jetty-webapp', version: '9.4.44.v20210927'

内容的提问来源于stack exchange，提问作者Noël Mastrorillo