akka http微服务如何上传excel文件

Question

我在服务器端使用 Akka HTTP 上传 excel sheet 并保存到本地，

def uploadFile(fileData: Multipart.FormData) = {
println(" uploadFile ")
// path("user" / "upload" / "file") {
/* (post & entity(as[Multipart.FormData])) { fileData =>*/
complete {
  val fileName = UUID.randomUUID().toString
  val temp = System.getProperty("java.io.tmpdir")
  val filePath = temp + "/" + fileName+".xls"
  // var filePath = current.configuration.getString("upload.file.path").get + "/" + fileName
  println(fileData.getParts() + " - " + fileData.getMediaType() + " filePath " + filePath + " fileName " + fileName)
  val processingFileUpload = processFile(filePath, fileData)
  /*val poResult = Await.result(processingFileUpload, 50 seconds)
    println(" processFile " + poResult)*/
  processingFileUpload.map { fileSize =>
    HttpResponse(StatusCodes.OK, entity = s"File successfully uploaded. Fil size is $fileSize")
  }.recover {
    case ex: Exception => HttpResponse(StatusCodes.InternalServerError, entity = "Error in file uploading")
  }
  //  }
  // }
}
 }

我的 processFile 是

private def processFile(filePath: String, fileData: Multipart.FormData) =   {
  val fileOutput = new FileOutputStream(filePath)
  println(" fileOutput " + fileOutput+" fileDatas "+fileData.parts.module)
//  fileData.parts.mapAsync(1) { bodyPart =>
  fileData.parts.mapAsyncUnordered(1) { bodyPart =>
    println(" bodyPartLog " + bodyPart)
    def writeFileOnLocal(array: Array[Byte], byteString: ByteString): Array[Byte] = {
      println(" arraysdss " + array)
      val byteArray: Array[Byte] = byteString.toArray
      fileOutput.write(byteArray)
      println(" sdssasx " + byteArray)
      array ++ byteArray
    }
    bodyPart.entity.dataBytes.runFold(Array[Byte]())(writeFileOnLocal)
  }.runFold(0)(_ + _.length)
}

我已经跟踪了 mapAsync 和 mapAsyncUnordered 每次上传文件时都出错，它直接跳入异常如何通过上传服务将数据写入我的本地服务器

Answer 1

我用了另一种上传文件的方法，效果也不错

(post & entity(as[Multipart.FormData])) { request =>
  extractRequestContext {
    ctx => {
      implicit val materializer = ctx.materializer
      implicit val ec = ctx.executionContext
      fileUpload("fileUpload") {
        case (fileInfo, fileStream) =>

          val localPath = "c:\test"
          val sink = FileIO.toPath(Paths.get(localPath) 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
            }
          }
      }
    }
  }
}

akka http微服务如何上传excel文件

how to upload the excel file in akka http micro services

excel

scala

akka

akka-stream

akka-http