Akka HTTP kullanarak dosya yükleme

Question

Akka HTTP kullanarak uygulamamda dosya yükleme işlevselliği uygulamaya çalışıyorum. akka-stream sürüm 2.4.4 kullanıyorum. İşte

Bu kod iyi çalışıyor ve verilen yoluna dosya yüklerken ( akka-doc değiştirilmiş) kodu

path("fileupload") { 
    post { 
     extractRequestContext { 
     ctx => { 
      implicit val materializer = ctx.materializer 
      implicit val ec = ctx.executionContext 
      fileUpload("fileUpload") { 
      case (metadata, byteSource) => 
       val location = FileUtil.getUploadPath(metadata) 
       val updatedFileName = metadata.fileName.replaceAll(" ", "").replaceAll("\"", "") 
       val uniqFileName = uniqueFileId.concat(updatedFileName) 
       val fullPath = location + File.separator + uniqFileName 
       val writer = new FileOutputStream(fullPath) 
       val bufferedWriter = new BufferedOutputStream(writer) 

       val result = byteSource.map(s => { 
       bufferedWriter.write(s.toArray) 
       }).runWith(Sink.ignore) 

       val result1 = byteSource.runWith(Sink.foreach(s=>bufferedWriter.write(s.toArray))) 
       Await.result(result1, 5.seconds) 
       bufferedWriter.flush() 
       bufferedWriter.close() 
       complete(uniqFileName) 
      /*onSuccess(result) { x => 
       bufferedWriter.flush() 
       bufferedWriter.close() 
       complete("hello world") 
      }*/ 
      } 
     } 
     } 
    } 
    } 

olduğunu. Dosya adlarının benzersiz olduğundan emin olmak için UUID ekleyerek yeni dosya adları oluşturuyorum. Bu yüzden yeni dosya adını arayan kişiye geri vermem gerekiyor. Ancak, bu yöntem her zaman dosya adını döndürmüyor. Bazen, Response has no content ile bitiriyor.

Burada yanlış yaptığım şeyi bana bilen biri var mı? Bu kod /tmp dizinde içinde bir dosyaya fileUpload çok parçalı alanını yükleyecek

path("fileUpload") { 
    post { 
     fileUpload("fileUpload") { 
     case (fileInfo, fileStream) => 
      val sink = FileIO.toPath(Paths.get("/tmp") resolve fileInfo.fileName) 
      val writeResult = fileStream.runWith(sink) 
      onSuccess(writeResult) { result => 
      result.status match { 
       case Success(_) => complete(s"Successfully written ${result.count} bytes") 
       case Failure(e) => throw e 
      } 
      } 
     } 
    } 
    } 

: Eğer bu amaçla reaktif akışları olduğunda standart engelleme kullanmaya gerek yoktur

Answer 1

akışları. Sadece giriş kaynağının içeriğini ilgili dosya havuzuna döker ve yazım işleminin tamamlanması üzerine bir mesaj verir.

their scaladocs'da açıklandığı gibi FileIO kaynakları ve girişleri için kullanılan dağıtıcıyı da değiştirmek isteyebilirsiniz.