facebook、gmail如何发送实时通知？

Question

我读过一些关于这个主题的帖子，答案是 comet、反向 ajax、http 流、服务器推送等。

Gmail 上的传入邮件通知如何工作？

GMail Chat 如何在没有客户端交互的情况下发出 AJAX 请求？

我想知道是否有任何代码参考可以让我编写一个非常简单的例子。 许多帖子或网站只是谈论该技术。 很难找到完整的示例代码。 另外，似乎有很多方法可以用来实现comet，例如Hidden IFrame、XMLHttpRequest。 在我看来，使用 XMLHttpRequest 是更好的选择。 您如何看待不同方法的优缺点？ Gmail 使用哪一款？

我知道它需要在服务器端和客户端都执行此操作。 有 PHP 和 Javascript 示例代码吗？

Answer 1

Facebook 的做法非常有趣。

执行此类通知的常见方法是按照给定的时间间隔（可能每隔几秒）轮询服务器上的脚本（使用 AJAX），以检查是否发生了某些情况。 然而，这可能是相当网络密集的，并且您经常发出毫无意义的请求，因为什么也没有发生。

Facebook 的做法是使用彗星方法，而不是按一定时间间隔进行轮询，一旦一项轮询完成，它就会发布另一项轮询。 但是，对服务器上脚本的每个请求都有极长的超时时间，并且服务器只有在发生某些情况时才会响应请求。 如果您在 Facebook 上打开 Firebug 的“控制台”选项卡，您就会看到这种情况的发生，其中对脚本的请求可能需要几分钟的时间。 这确实非常巧妙，因为这种方法立即减少了请求的数量以及发送请求的频率。 您现在实际上拥有了一个允许服务器“触发”事件的事件框架。

在这背后，就这些民意调查返回的实际内容而言，它是一个 JSON 响应，其中似乎是事件列表以及有关事件的信息。 虽然它被缩小了，所以阅读起来有点困难。

就实际技术而言，AJAX 是可行的方法，因为您可以控制请求超时和许多其他事情。 我建议（这里是堆栈溢出陈词滥调）使用 jQuery 来执行 AJAX，它将消除很多交叉兼容性问题。 就 PHP 而言，您可以简单地在 PHP 脚本中轮询事件日志数据库表，并且仅在发生某些情况时才返回客户端？ 我预计有很多方法可以实现这一点。

实现：

服务器端：

PHP 中似乎有一些 Comet 库的实现，但说实话，它确实非常简单，可能类似于以下伪代码：

while(!has_event_happened()) {
   sleep(5);
}

echo json_encode(get_events());

• has_event_happened 函数将只需检查事件表中是否发生了任何事情或其他事情，然后 get_events 函数将返回表中新行的列表？ 实际上取决于问题的上下文。

• 不要忘记更改你的 PHP 最大执行时间，否则它会提前超时！

  不要

客户端：

看一下用于进行 Comet 交互的 jQuery 插件：

• 项目主页： http://plugins.jquery .com/project/Comet
• Google 代码：https://code.google.com /archive/p/jquerycomet/ - 似乎在 subversion 存储库中有某种示例用法。

也就是说，该插件似乎增加了相当多的复杂性，它在客户端上确实非常简单，也许（使用 jQuery）类似于：

function doPoll() {
   $.get("events.php", {}, function(result) {
      $.each(result.events, function(event) { //iterate over the events
          //do something with your event
      });
      doPoll(); 
      //this effectively causes the poll to run again as
      //soon as the response comes back
   }, 'json'); 
}

$(document).ready(function() {
    $.ajaxSetup({
       timeout: 1000*60//set a global AJAX timeout of a minute
    });
    doPoll(); // do the first poll
});

整个事情在很大程度上取决于您现有的架构是如何组合在一起的。

Answer 2

更新

随着我继续收到对此的支持，我认为有理由记住这个答案已经有 4 年了。 网络的发展速度非常快，所以请注意这个答案。

---

我最近遇到了同样的问题并研究了该主题。

给出的解决方案称为长轮询，要正确使用它，您必须确保 AJAX 请求具有“大”超时，并且始终在当前结束后（超时、错误或成功）发出此请求。

长轮询 - 客户端

在这里，为了保持代码简短，我将使用 jQuery：

function pollTask() { 

    $.ajax({

        url: '/api/Polling',
        async: true,            // by default, it's async, but...
        dataType: 'json',       // or the dataType you are working with
        timeout: 10000,          // IMPORTANT! this is a 10 seconds timeout
        cache: false

    }).done(function (eventList) {  

       // Handle your data here
       var data;
       for (var eventName in eventList) {

            data = eventList[eventName];
            dispatcher.handle(eventName, data); // handle the `eventName` with `data`

       }

    }).always(pollTask);

}

记住这一点很重要（来自 jQuery 文档）：

在 jQuery 1.4.x 及更低版本中，XMLHttpRequest 对象将位于
如果请求超时，则状态无效； 访问任何对象成员
可能会抛出异常。 仅在 Firefox 3.0+ 中，脚本和 JSONP
请求不能因超时而取消； 该脚本将运行，即使
它在超时时间后到达。

长轮询 - 服务器

它不是用任何特定的语言，但它会是这样的：

function handleRequest () {  

     while (!anythingHappened() || hasTimedOut()) { sleep(2); }

     return events();

} 

这里，hasTimedOut将确保您的代码不会永远等待，并且anythingHappened，将检查是否发生任何事件。 sleep 用于在没有任何反应的情况下释放线程以执行其他操作。 events 将以 JSON 格式（或您喜欢的任何其他数据结构）返回事件字典（或您可能喜欢的任何其他数据结构）。

它确实解决了问题，但是，如果您像我在研究时一样担心可扩展性和性能，您可能会考虑我发现的另一个解决方案。

解决方案

使用套接字！

在客户端，为避免任何兼容性问题，请使用 socket.io。 它尝试直接使用套接字，并在套接字不可用时使用其他解决方案。

在服务器端，使用 NodeJS 创建一个服务器（示例 此处）。 客户端将订阅服务器创建的这个通道（观察者）。 每当需要发送通知时，都会在此通道中发布通知，并且订阅者（客户端）会收到通知。

如果您不喜欢此解决方案，请尝试 APE (Ajax Push Engine)。

希望我有所帮助。

Answer 3

根据有关 Facebook 消息系统的幻灯片，Facebook 使用彗星技术将消息“推送”到网络浏览器。 Facebook 的 comet 服务器基于开源 Erlang Web 服务器 mochiweb 构建。

下图中，“通道集群”一词的意思是“彗星服务器”。

许多其他大网站都建立了自己的comet服务器，因为每个公司的需求都有差异。 但在开源彗星服务器上构建自己的彗星服务器是一个好方法。

您可以尝试 icomet，这是一个使用 libevent 构建的 C1000K C++ comet 服务器。 icomet还提供了一个JavaScript库，使用起来很简单：

var comet = new iComet({
    sign_url: 'http://' + app_host + '/sign?obj=' + obj,
    sub_url: 'http://' + icomet_host + '/sub',
    callback: function(msg){
        // on server push
        alert(msg.content);
    }
});

icomet支持多种浏览器和操作系统，包括Safari(iOS、Mac)、IE(Windows)、Firefox、Chrome等。

Answer 4

Facebook 使用 MQTT 而不是 HTTP。 推送比轮询更好。
通过 HTTP，我们需要不断轮询服务器，但通过 MQTT 服务器将消息推送到客户端。

MQTT 和 HTTP 之间的比较：http://www.youtube.com/watch?v=-KNPXPmx88E

注意：我的答案最适合移动设备。

Answer 5

长轮询的一个重要问题是错误处理。
有两种类型的错误：

1. 请求可能超时，在这种情况下客户端应立即重新建立连接。 这是长轮询中没有消息到达时的正常事件。

2. 网络错误或执行错误。 这是一个实际错误，客户端应该优雅地接受并等待服务器重新上线。

主要问题是，如果您的错误处理程序也针对类型 2 错误立即重新建立连接，则客户端将对服务器进行 DOS。

带有代码示例的两个答案都忽略了这一点。

function longPoll() { 
        var shouldDelay = false;

        $.ajax({
            url: 'poll.php',
            async: true,            // by default, it's async, but...
            dataType: 'json',       // or the dataType you are working with
            timeout: 10000,          // IMPORTANT! this is a 10 seconds timeout
            cache: false

        }).done(function (data, textStatus, jqXHR) {
             // do something with data...

        }).fail(function (jqXHR, textStatus, errorThrown ) {
            shouldDelay = textStatus !== "timeout";

        }).always(function() {
            // in case of network error. throttle otherwise we DOS ourselves. If it was a timeout, its normal operation. go again.
            var delay = shouldDelay ? 10000: 0;
            window.setTimeout(longPoll, delay);
        });
}
longPoll(); //fire first handler