如何使用akka http发送文件作为响应？

lvmkulzt 于 2022-11-06 发布在其他

关注(0)|答案(3)|浏览(188)

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

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.
    )
}

akka

来源：https://stackoverflow.com/questions/49011621/how-to-send-a-file-as-a-response-using-akka-http

3条答案

按热度按时间

2vuwiymt1#

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

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，而无需让服务器保留整个内容：

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

赞(0）回复(0）举报 2022-11-06

li9yvcax2#

akka Http路线

pathSingleSlash {
    get {
      complete(HttpEntity.fromFile(MediaTypes.`application/zip`, new File(s"/home/shivam/sample.zip"))
    }
  }

curl 请求

curl --output sample.zip http://localhost:8080/

复制自HttpEntity.scala

/**
   * Returns either the empty entity, if the given file is empty, or a [[HttpEntity.Default]] entity
   * consisting of a stream of [[akka.util.ByteString]] instances each containing `chunkSize` bytes
   * (except for the final ByteString, which simply contains the remaining bytes).
   *
   * If the given `chunkSize` is -1 the default chunk size is used.
   */

赞(0）回复(0）举报 2022-11-06

v6ylcynt3#

val str2 = scala.io.Source.fromFile("/tmp/t.log", "UTF8").mkString
val str = Source.single(ByteString(str2))
HttpResponse(entity = HttpEntity.Chunked.fromData(ContentTypes.`application/octet-stream`, str))

赞(0）回复(0）举报 2022-11-06

我来回答

如何使用akka http发送文件作为响应？

3条答案

相关问题

热门标签

最新问答