原文：Comet

使用Comet的块应答

块应答的一个常见的用法是创建Comet套接字。

Comet 套接字是仅包含<script>元素的 text/html应答块。对于每一个块，我们写一个<script> 标签，这个标签包含了通过Web浏览器立即执行的JavaScript 。这样我们就可以实时的把事件从服务器发送到Web浏览器：对每一个消息，把它封装进调用JavaScript 回调函数的<script>标签，并把它写进块应答。

由于 Ok.chunked 利用 Akka Streams获取Flow[ByteString],因此我们可以发送Flow元素并转换它，如此每一个元素会被转义并封装到JavaScript方法中。Comet助手自动完成Comet套接字，根据浏览器的兼容性推送初始的空白缓存，并支持字符串和JSON消息。

Comet Imports

为了使用Comet 助手，导入下面的类：

1import akka.stream.Materializer
2import akka.stream.scaladsl.Source
3import play.api.http.ContentTypes
4import play.api.inject.guice.GuiceApplicationBuilder
5import play.api.libs.Comet
6import play.api.libs.iteratee.Enumerator
7import play.api.libs.json._
8import play.api.libs.streams.Streams
9import play.api.mvc._

你也需要一个从你的 DI system中获取akka.stream.Materializer的最好的实现者。

String流使用Comet

像下面这样通过Flow推送字符串信息：

1def cometString = Action {
2implicit val m = materializer
3def stringSource: Source[String, _] = Source(List("kiki", "foo", "bar"))
4Ok.chunked(stringSource via Comet.string("parent.cometMessage")).as(ContentTypes.HTML)
5}

JSON流使用Comet

像下面这样通过Flow推送JSON信息：

1def cometJson = Action {
2implicit val m = materializer
3def jsonSource: Source[JsValue, _] = Source(List(JsString("jsonString")))
4Ok.chunked(jsonSource via Comet.json("parent.cometMessage")).as(ContentTypes.HTML)
5}

Iframe使用Comet

Comet助手通常应该和forever-iframe 技术一起使用，与HTML页面一样：

1<script type="text/javascript">
2var cometMessage = function(event) {
3console.log('Received event: ' + event)
4}
5</script>
6
7<iframe src="https://my.oschina.net/comet"></iframe>

Comet助手的例子，见Play 2.5 Clock Template.

调试Comet

调试有问题的Comet流的最简单的方式是使用log()操作显示通过流的映射数据所涉及的任何错误。

Comet遗留的Enumerator

先前存在的Comet功能通过Enumeratee 使用 Comet.apply仍然有效，但是它已经被废弃了，推荐使用基于Akka Streams流的版本。

如果你现有的代码在很大程度上依赖了 Enumerator, 你可以使用play.api.libs.streams.Streams 与Reactive Streams 相互协作把Enumerator 转换成流：

1implicit val m = materializer
2val enum = Enumerator("one", "two", "three")
3val publisher = Streams.enumeratorToPublisher(enum)
4def stringSource: Source[String, _] = Source.fromPublisher(publisher)
5Ok.chunked(stringSource via Comet.string("parent.cometMessage")).as(ContentTypes.HTML)
6}

也可参考 Streams Migration Guide.

Comet[翻译]