如何使用 akka http 发送文件作为响应? [英] How to send a file as a response using akka http?

问题描述

我对 akka 世界有点陌生，所以我的知识领域有点小.我正在创建一个 https 服务器并使用 akka 流和 http 处理它，对于特定的 url，我需要将文件发送回客户端.我如何使用 akka 流并避免使用 akka 路由来实现这一点.

I am a little new to akka world, so my domain of knowledge is a bit small. I am creating an https server and handling it using akka streams and http, for a specific url, i need to send a file back to client. How can i achieve that using akka streams and avoiding the akka routes.

def handleCall(request:HttpRequest):HttpResponse = {
  logger.info("Request is {}",request)
  val uri:String = request.getUri().path()
  if(uri == "/download"){
    val f = new File("/1000.txt")
    logger.info("file download")
    return HttpEntity(
    //What should i put here if i want to return a text file.
    )
}

推荐答案

如果文件可能很大，那么您不希望在将其发送到客户端之前将整个内容消耗到内存中.这是通过纯粹基于流的解决方案来解决的:

If the file is likely to be large then you don't want to consume the entire contents into memory before sending it to the client. This is solved via a purely stream based solution:

import scala.io
import akka.stream.scaladsl.Source
import akka.http.scaladsl.model.HttpEntity.{Chunked, ChunkStreamPart}
import akka.http.scaladsl.model.{HttpResponse, ContentTypes}

val fileContentsSource : (String, String) => Source[ChunkStreamPart, _] =
  (fileName, enc) =>
    Source
      .fromIterator( io.Source.fromFile(fileName, enc).getLines )
      .map(ChunkStreamPart.apply)


val fileEntityResponse : (String, String) => HttpResponse =
  (fileName, enc) => 
    HttpResponse(entity = Chunked(ContentTypes.`text/plain(UTF-8)`,
                                  fileContentsSource(fileName, enc)))

现在您可以创建和发送 HttpResponse ，而无需服务器保留全部内容:

Now you can create and send an HttpResponse without having the server keep the entire contents:

val httpResp : HttpResponse = fileEntityResponse("/foo/log.txt", "UTF8")

这篇关于如何使用 akka http 发送文件作为响应?的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！