akka http中的文件解析和持久性

import akka.actor.ActorSystem
import akka.http.scaladsl.Http
import akka.http.scaladsl.model._
import akka.http.scaladsl.server.Directives._
import akka.stream.ActorMaterializer
import akka.util.ByteString
import java.nio.file.Paths

object FileUploadServer extends App {
  implicit val system = ActorSystem()
  implicit val materializer = ActorMaterializer()
  implicit val executionContext = system.dispatcher

  val route =
    path("upload") {
      post {
        entity(as[Multipart.FormData]) { formData =>
          val done = formData.parts.mapAsync(1) { part =>
            val filename = Paths.get(part.filename).getFileName.toString
            part.entity.dataBytes.runWith(FileIO.toPath(Paths.get(s"./uploads/$filename")))
          }.runFold(())(_ => _)

          onSuccess(done) { _ =>
            complete(HttpEntity(ContentTypes.`text/html(UTF-8)`, "<h1>File uploaded successfully!</h1>"))
          }
        }
      }
    }

  Http().bindAndHandle(route, "localhost", 8080)
}