使用Akka从服务器到客户端的流文件

Question

基本上我想允许用户从服务器下载csv文件。假定服务器上已经存在CSV文件。 API端点通过GET/export显示。如何将文件从Akka HTTP服务器流式传输到客户端？这是我迄今为止...

服务：

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

路线：

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

Answer 1

的阿卡，流API允许你直接创建一个实体了Source[ByteString, _]的，所以你可以按照以下方式做点什么

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

请注意，这样你的服务器代码就不需要了在通过电线发送之前将其存储在内存中的整个CSV文件。文件内容将在支持反压的流中发送。更多关于这个here。