scala - PlayFramework 2.2 scala关闭WebSocket连接

Question

如何关闭 WebSocket 连接？如果您想立即关闭它，文档上的示例有效。

但是以下情况如何：我想在将来发生某些情况时关闭连接。例如，当我收到来自客户端的某个消息时。

def indexWS = WebSocket.using[String] {
    request => {

      var channel: Option[Concurrent.Channel[String]] = None
      var outEnumerator: Enumerator[String] = Concurrent.unicast(c => channel = Some(c))

      val myIteratee: Iteratee[String, Unit] = Iteratee.foreach[String] {gotString => {
        // received a string from the client

        if (gotString == "close_me") {
          // outEnumerator = Enumerator.eof // doesn't work
          // outEnumerator >>> Enumerator.eof // doesn't work
        }

      }}

      (myIteratee, outEnumerator)
    }
  }

谢谢您的帮助！

Answer 1

我明白了：我必须通过我打开的频道

var outEnumerator: Enumerator[String] = Concurrent.unicast(c => channel = Some(c))

并且注释掉的块将变为

if (gotString == "close_me") {
    channel.foreach(_.eofAndEnd())      
}

这将通过枚举器推送 EOF 并关闭连接。