Akka-HTTP：ファイルアップロード

Question

私はakka httpを使って簡単なファイルアップロードを実装しようとしています。 次のように私の試みはなります

import akka.actor.ActorSystem 
    import akka.event.{LoggingAdapter, Logging} 
    import akka.http.scaladsl.Http 
    import akka.http.scaladsl.model.{HttpResponse, HttpRequest} 
    import akka.http.scaladsl.model.StatusCodes._ 
    import akka.http.scaladsl.server.Directives._ 
    import akka.stream.{ActorMaterializer, Materializer} 
    import com.typesafe.config.Config 
    import com.typesafe.config.ConfigFactory 
    import scala.concurrent.{ExecutionContextExecutor, Future} 
    import akka.http.scaladsl.model.StatusCodes 
    import akka.http.scaladsl.model.HttpEntity 
    import java.io._ 
    import akka.stream.io._ 

    object UploadTest extends App { 
     implicit val system = ActorSystem() 
     implicit val executor = system.dispatcher 
     implicit val materializer = ActorMaterializer() 

     val config = ConfigFactory.load() 
     val logger = Logging(system, getClass) 

     val routes = { 
     pathSingleSlash { 
      (post & extractRequest) { 
      request => { 
       val source = request.entity.dataBytes 
       val outFile = new File("/tmp/outfile.dat") 
       val sink = SynchronousFileSink.create(outFile) 
       source.to(sink).run() 
       complete(HttpResponse(status = StatusCodes.OK)) 
      } 
      } 
     } 
     } 

     Http().bindAndHandle(routes, config.getString("http.interface"), config.getInt("http.port")) 

    } 

このコードのいくつかの問題があります。

1. が設定されたエンティティのサイズよりも大きいファイルをアップロードすることができません。 Request Content-Length 24090745 exceeds the configured limit of 8388608
2. が行に2本のアップロードを実行しますdead letters encountered.例外が発生します。

サイズの制限を克服する最良の方法は何ですか。また、後でアップロードしたファイルが既存のファイルを上書きするようにファイルを正しく閉じるにはどうすればよいですか？

Answer 1

ポイント2については、source.to(sink).run()が動作を非同期に実行すると思います。それはFutureを具体化する。したがって、ファイルの書き込みが完了する前にHTTPリクエストが返される可能性があるため、最初のリクエストが返されるとすぐにクライアントで2回目のアップロードを開始すると、最初のリクエストがファイルへの書き込みを完了していない可能性があります。将来が完了したときに

は、あなただけのhttpリクエストを完了するために、onCompleteまたはonSuccessディレクティブを使用することができます。

http://doc.akka.io/docs/akka-stream-and-http-experimental/1.0-M2/scala/http/directives/alphabetically.html

http://doc.akka.io/docs/akka-stream-and-http-experimental/1.0/scala/http/routing-dsl/directives/future-directives/onSuccess.html

EDIT：コンテンツの長さの問題については

、1あなたができることは、そのプロパティのサイズをapplication.confに増やすことです。デフォルトは次のとおりです。

akka.server.parsing.max-content-length = 8m 

はhttp://doc.akka.io/docs/akka-stream-and-http-experimental/1.0/java/http/configuration.html

Answer 2

がmattinbitsコメントをまとめる参照してください、follwingソリューションが動作します。

1. がonSuccess

を使用してakka.server.parsing.max-content-length

を増やすここでの抜粋ですコード：

val routes = { 
    pathSingleSlash { 
    (post & extractRequest) { 
     request => { 
     val source = request.entity.dataBytes 
     val outFile = new File("/tmp/outfile.dat") 
     val sink = SynchronousFileSink.create(outFile) 
     val repl = source.runWith(sink).map(x => s"Finished uploading ${x} bytes!") 
     onSuccess(repl) { repl => 
      complete(HttpResponse(status = StatusCodes.OK, entity = repl)) 
     } 
     } 
    } 
    }