Streaming file from server to client using Akka

问题:

Basically I want to allow a user to download a csv file from the server. Assume the CSV file already exists on the server. A API endpoint is exposed via GET /export. How do I stream the file from Akka HTTP server to client? This is what I have so far...

Service:

def export(): Future[IOResult] = {
    FileIO.fromPath(Paths.get("file.csv"))
      .to(Sink.ignore)
      .run()
}

Route:

pathPrefix("export") {
  pathEndOrSingleSlash {
    get {
      complete(HttpEntity(ContentTypes.`text/csv`, export())
    }
  }
}

回答1:

The Akka-Stream API allow you to create an entity directly out of a Source[ByteString, _], so you can do something along the lines of

pathPrefix("export") {
  pathEndOrSingleSlash {
    get {
      complete(HttpEntity(ContentTypes.`text/csv(UTF-8)`, FileIO.fromPath(Paths.get("file.csv")))
    }
  }
}

Note that this way your server code will not need to ingest the whole CSV file in memory before sending it over the wire. The file contents will be sent over in a backpressure-enabled stream. More on this here.