Play! 的 Comet 支持如何运作？

Question

我看到 Akka 模块的描述说 Play 有很好的 Comet 支持，但我从未使用过 Comet 之前，我在 Play 的文档中找不到任何提及它的内容。它在 Play 中如何运作？

---

我花了两天多的时间来解决这个问题，所以我想与其他 Play 初学者分享这些信息。

Answer 1

Play 包含一个示例聊天应用程序，演示如何使用 Comet。这个例子并没有解释发生了什么，所以这就是我所想到的。

模型

为了让其他人找到您发送的新更新，它们需要存储在某个地方。可以想象，这可能位于缓存中，甚至位于控制器本身中，但数据库将是最安全的选择，因此您需要一个模型。他们还需要一种方法来确定哪些更新对他们来说是新的，这意味着您可能需要一个日期字段（另请参阅：上次使用 JPA 更新时间戳）。 Chat 示例使用一个简单的模型：

@Entity
public class Message extends Model {     
    public String user;
    public Date date;
    public String text;

    public Message(String user, String text) {
        this.user = user;
        this.text = text;
        this.date = new Date();
    }       
}

控制器

控制器需要两种方法来方便 Comet。一种用于发布新数据，不会执行任何特殊操作：

public static void postMessage(String message) {
    new Message(session.get("nick"), message).save();
}

另一种用于检索更新：

public static void newMessages() {
    List<Message> messages = Message.find("date > ?", request.date).fetch();
    if (messages.isEmpty()) {
        suspend("1s");
    }
    renderJSON(messages);
}

这里的关键位是 suspend("1s")，它使 HTTP 请求保持打开状态，检查每秒一次新数据。

视图

视图具有三个职责——发送新数据、获取更新然后呈现这些更新。

与相应的控制器操作一样，发送不会执行任何特殊操作：

$('#send').click(function(e) {
    var message = $('#message').val();
    $('#message').val('');
    $.post('@{postMessage()}', {message: message}); 
});

获取更新是神奇的一点：调用

// Retrieve new messages
var getMessages = function() {
    $.ajax({
        url: '@{newMessages()}',
        success: function(messages) {
            $(messages).each(function() {
                display(this);
            });
        },
        complete: function() {
            getMessages();
        },
        dataType: 'json'
    });
}
getMessages();

一次 getMessages() 即可开始工作，然后在每次成功请求后递归地调用自身。它获取 newMessages() 操作来查找新消息，如果没有任何消息，它会保持请求打开，直到有需要报告的内容为止。找到新消息时，JSON 数据将传递给 display 函数：

var display = function(message) {
    $('#thread').append(tmpl('message_tmpl', {message: message}));
}

display 函数应用 JavaScript 微模板到 JSON 数据以呈现新消息。使用微模板不是必需的，但它确实工作得很好。它们直接包含在将要使用它们的页面模板中：

<script type="text/html" id="message_tmpl">
    <div class="message <%= message.user == '${session.nick}' ? 'you' : '' %> <%= message.user == 'notice' ? 'notice' : '' %>">
        <h2><%= message.user %></h2>
        <p><%= message.text.replace('\n', '<br/>') %></p>
    </div>
</script>

type="text/html" 导致浏览器、搜索引擎和屏幕阅读器忽略整个脚本块。结果比使用 jQuery 构建节点或连接字符串更容易阅读和维护。总的来说，一旦您知道哪些部分是相关的，事情就非常简单了。

Answer 2

在 Web 应用程序中实现服务器推送或 Comet 的方法有很多，最常见的方法之一是长轮询，因为它在大多数现代浏览器中得到了很好的支持。

Play主要通过suspend(time);函数实现长轮询。该函数做了两件非常重要的事情

1. 它保持 HTTP 请求打开并在指定的时间内重试该操作。这允许您保留 HTTP 请求并继续重试该操作，直到发生您想要通知浏览器的事情

   ，

2. 的事情，并且非常重要的是，当请求挂起时，线程将被释放。这意味着 http 请求不会为每个挂起的请求保留一个打开的线程。

当游戏处于 DEV 模式时，它仅在单个线程上运行，但您可以（并且我已经尝试过）在示例聊天应用程序上运行数十个用户，而不会导致服务器挂起或用户请求被阻止。

然而，挂起方法是 play 真正对 Comet 提供帮助的唯一方法。如果您运行示例聊天应用程序并使客户端保持打开状态，您会注意到 120 秒后，请求将超时。示例应用程序不会重试该请求。您必须自己构建长轮询技术的客户端。

Guillaume 在论坛中提到，示例聊天应用程序只是轮询可以使用多长时间的演示。所以我不认为 Play 可以证明拥有强大的 Comet 支持，这只是朝着正确方向迈出的一步。

Answer 3

您可以在 Akka 中使用 Mist 进行由 Servlet 3.00 或 Jetty7 Continuations 支持的服务器推送 (Comet)： http://doc.akkasource.org/http#Mist%20-%20Lightweight%20Asynchronous%20HTTP