scala - akka.io 在 2.3 中逐行接收

Question

我正在使用 Akka 2.3(因为这是 Play 附带的版本)并且想连接到某个 TCP 套接字。我知道 akka.io 包。但是，我看不到任何方法可以将接收到的数据作为 UTF-8 字符串逐行处理(反对只接收字节 block )。

在网上搜索时，有很多对 Akka 2.2 的实验性 Pipeline API 的引用。然而，这个 API 在 Akka 中又被删除了。

我正在寻找的是在大多数缓冲区类中称为 readLine 的内容，但对于 Akka I/O Framework。

Answer 1

Akka Stream看起来很有希望，但是由于它仍未发布，我决定通过简单地联系缓冲区中的所有数据并等待分隔符来自己实现它。

  private val separatorBytes = // like CRLF
  private var buffer = ByteString.empty
  private var nextPossibleMatch = 0

  // when receiving chunks of bytes they are appended to buffer and doParseLines is executed

  private def doParseLines(parsedLinesSoFar: Vector[String] = Vector()): Vector[String] = {
    val possibleMatchPos = buffer.indexOf(separatorBytes.head, from = nextPossibleMatch)
    if (possibleMatchPos == -1) {
      parsedLinesSoFar
    } else {
      if (possibleMatchPos + separatorBytes.size > buffer.size) {
        nextPossibleMatch = possibleMatchPos
        parsedLinesSoFar
      } else {
        if (buffer.slice(possibleMatchPos, possibleMatchPos + separatorBytes.size) == separatorBytes) {
          // Found a match
          val parsedLine = buffer.slice(0, possibleMatchPos).utf8String
          buffer = buffer.drop(possibleMatchPos + separatorBytes.size)
          nextPossibleMatch -= possibleMatchPos + separatorBytes.size
          doParseLines(parsedLinesSoFar :+ parsedLine)
        } else {
          nextPossibleMatch += 1
          doParseLines(parsedLinesSoFar)
        }
      }
    }
  }