file - 使用 scala&akka 从 tcp 套接字到文件的高性能写入

Question

我正在通过 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?
        }
    }
}

谢谢，马丁

Answer 1

Have you tried Chronicle?

It provides both: low latency and high throughput when storing stuff to files.