我正在通过 scala /w akka 中的套接字接收数据——可能是非常大的文件。所以我想知道将这些数据块写入本地文件的更高性能的最佳方法是什么?
这就是我接收数据的方式:
def processRequest(implicit socket: IO.SocketHandle): IO.Iteratee[Unit] = {
IO.repeat {
for {
all <- IO.takeUntil(EOL)
}
yield {
val stuffIWantToSave = all.decodeString("UTF-8")
//how do handle this string?
}
}
}
谢谢,马丁