scala 在处理文件时是否提供异步非阻塞 IO？

Question

我正在使用 scala 2.10，我想知道是否有一些包在处理文件时具有异步 IO？

我对这个主题进行了一些搜索，但大部分都找到了以下示例

val file = new File(canonicalFilename)
val bw = new BufferedWriter(new FileWriter(file))
bw.write(text)
bw.close()

本质上是具有阻塞 IO 操作的 java.io 包 - 写入、读取等。我还发现 scala-io 项目有此意图，但似乎该项目是 2012 年最后的活动。

在这种情况下，最佳做法是什么？是否有任何 scala 包或将 java.io 代码包装到 Futures 和 Observables 的常用方法？

我的用例来自一个 Akka actor，需要在本地或远程文件系统上操作文件。需要避免阻塞。还是有更好的选择？

感谢您澄清这一点

Answer 1

Scala 没有为异步文件 IO 提供显式 API，然而在这些情况下使用纯 Java API 是完全正确的（这实际上是件好事，我们可以使用所有这些漂亮的 API 而无需任何包装！）。您应该考虑使用 java.nio.channels.AsynchronousFileChannel，它从 JDK7 开始可用，并利用底层系统异步调用文件 IO。

Akka IO，虽然在其核心中不提供文件 IO，但有一个由 Dario Rexin 开发的模块，它允许以非常简单的方式将 AsynchronousFileChannel 与 Akka IO 一起使用。看看这个库来使用它：https://github.com/drexin/akka-io-file

在不久的将来Akka 将在其akka-streams 模块中提供文件 IO。虽然它可能作为一个外部库有一段时间了，我们还不确定把它放在哪里，因为它要求用户至少有 7 个 JDK，而大多数 Akka 目前支持 JDK6。话虽如此，基于流的异步背压文件 IO 即将推出 :-)

Answer 2

如果您将 scalaz-stream 用于异步支持，它具有基于 java.nio 异步 API 构建的 file functionality - 这可能是我推荐的方法。如果您使用标准的 scala 期货，您可以使用akka-io?我认为使用 Netty 作为后端。或者您可以直接调用 NIO - 只需几行代码即可将基于回调的 API 适配到 scalaz 或 scala futures。