如何在Scala中将文件作为字节数组读取

Question

我可以找到大量示例，但它们似乎要么主要依赖于 Java 库，要么只是读取字符/行/等。

我只想读入一些文件并获得一个带有 scala 库的字节数组 - 有人可以帮我吗？

Answer 1

Java 7：

import java.nio.file.{Files, Paths}

val byteArray = Files.readAllBytes(Paths.get("/path/to/file"))

我相信这是最简单的方法。只是在这里利用现有的工具。 NIO.2 很棒。

Answer 2

这应该可以工作（Scala 2.8）：

val bis = new BufferedInputStream(new FileInputStream(fileName))
val bArray = Stream.continually(bis.read).takeWhile(-1 !=).map(_.toByte).toArray

Answer 3

库scala.io.Source有问题，不要用它来读取二进制文件。

可以按照此处的说明重现错误：https://github.com/liufengyun/scala-bug

在data.bin文件中，包含十六进制的0xea，即二进制的11101010，需要转换成十进制的234。

main.scala 文件包含两种读取文件的方式：

import scala.io._
import java.io._

object Main {
  def main(args: Array[String]) {
    val ss = Source.fromFile("data.bin")
    println("Scala:" + ss.next.toInt)
    ss.close

    val bis = new BufferedInputStream(new FileInputStream("data.bin"))
    println("Java:" + bis.read)
    bis.close
  }
}

当我运行scala main.scala时，程序输出如下：

Scala:205
Java:234

Java 库生成正确的输出，而 Scala 库没有。

Answer 4

val is = new FileInputStream(fileName)
val cnt = is.available
val bytes = Array.ofDim[Byte](cnt)
is.read(bytes)
is.close()

Answer 5

您也可以考虑使用scalax.io：

scalax.io.Resource.fromFile(fileName).byteArray

Answer 6

您可以使用Apache Commons CompressIOUtils

import org.apache.commons.compress.utils.IOUtils

val file = new File("data.bin")
IOUtils.toByteArray(new FileInputStream(file))

Answer 7

使用 Scala Future 和 Java NIO2 进行异步文件读取

  def readFile(path: Path)(implicit ec: ExecutionContext): Future[Array[Byte]] = {
    val p = Promise[Array[Byte]]()
    try {
      val channel = AsynchronousFileChannel.open(path, StandardOpenOption.READ)
      val buffer = ByteBuffer.allocate(channel.size().toInt);
      channel.read(buffer, 0L, buffer, onComplete(channel, p))
    }
    catch {
      case t: Exception => p.failure(t)
    }
    p.future
  }

  private def onComplete(channel: AsynchronousFileChannel, p: Promise[Array[Byte]]) = {
    new CompletionHandler[Integer, ByteBuffer]() {
      def completed(res: Integer, buffer: ByteBuffer): Unit = {
        p.complete(Try {
          buffer.array()
        })
      }

      def failed(t: Throwable, buffer: ByteBuffer): Unit = {
        p.failure(t)
      }
    }
  }

Answer 8

我已使用以下代码读取 CSV 文件。

import scala.io.StdIn.readLine
import scala.io.Source.fromFile

readFile("C:/users/xxxx/Downloads/", "39025968_ccccc_1009.csv")

def readFile(loc :String,filenm :String): Unit ={

  var flnm = fromFile(s"$loc$filenm") // Imported fromFile package

  println("Files testing")
  /*for (line <- flnm.getLines()) {
    printf("%4d %s\n", line.length, line)
  }*/
  flnm.getLines().foreach(println) // getLines() is imported from readLines.
  flnm.close() 
}