PROSAGA码农传奇-Xedge-facebook，gmail如何发送实时通知？

0# 满目山河 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”>
  
    长轮询的一个重要问题是错误处理。
有两种类型的错误：
  
  <OL>
    <LI>
      
        请求可能会超时，在这种情况下，客户端应立即重新建立连接。当没有消息到达时，这是长轮询中的正常事件。
      
    </LI>
    <LI>
      
        网络错误或执行错误。这是客户端应该优雅接受的实际错误，并等待服务器重新联机。
      
    </LI>
  </醇>
  
    的
      主要问题是，如果您的错误处理程序也立即重新建立连接以发生类型2错误，则客户端将DOS服务器。
    </强>
  
  
    代码示例的两个答案都错过了。
  
   <pre>
 <code>
 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

</code>
 </pre>
</DIV>

1# 明天会更好 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”>
  
    Facebook这样做的方式非常有趣。
  
  
    执行此类通知的常用方法是在给定时间间隔（可能每隔几秒）轮询服务器上的脚本（使用AJAX），以检查是否发生了某些事情。但是，这可能是网络密集型的，并且您经常提出无意义的请求，因为什么也没发生。
  
  
    Facebook所采用的方式是使用彗星方法，而不是轮询间隔，一旦一个民意调查完成，它就会发出另一个民意调查。但是，对服务器上的脚本的每个请求都具有极长的超时，并且服务器仅在发生某些事件时才响应该请求。如果你在Facebook上调出Firebug的控制台选项卡，你可以看到这种情况发生，对脚本的请求可能需要几分钟。它真的非常巧妙，因为这种方法会立即减少请求数量，以及发送它们的频率。您现在有效地拥有一个允许服务器“触发”事件的事件框架。
  
  
    在此背后，就这些民意调查返回的实际内容而言，它是一个JSON响应，其中包含的事件列表和相关信息。它虽然缩小了，所以有点难以阅读。
  
  
    就实际技术而言，AJAX是前往此处的方式，因为您可以控制请求超时等许多其他事情。我建议使用jQuery来执行AJAX（这里的堆栈溢出陈词滥调），它会带来很多交叉兼容性问题。就PHP而言，您可以简单地轮询PHP脚本中的事件日志数据库表，并仅在发生某些事情时返回到客户端？我希望有很多方法可以实现这一点。
  
  
    的
      实现：
    </强>
  
  
    服务器端：
  
  
    在PHP中似乎有一些彗星库的实现，但说实话，它真的很简单，可能像下面的伪代码：
  
   <pre>
 <code>
 while(!has_event_happened()) {
 sleep(5);
}

echo json_encode(get_events());

</code>
 </pre>
  <UL>
    <LI>
      
        has_event_happened函数只检查事件表中是否发生过任何事情，然后get_events函数将返回表中新行的列表？真的取决于问题的背景。
      
    </LI>
    <LI>
      
        不要忘记更改PHP最大执行时间，否则会提前超时！
      
    </LI>
  </UL>
  
    客户端：
  
  
    看看用于进行Comet交互的jQuery插件：
  
  <UL>
    <LI>
      项目主页：
      <a href="http://plugins.jquery.com/project/Comet" rel="noreferrer">
        http://plugins.jquery.com/project/Comet
      </A>
    </LI>
    <LI>
      Google代码：
      <a href="https://code.google.com/archive/p/jquerycomet/" rel="noreferrer">
        https://code.google.com/archive/p/jquerycomet/
      </A>
        - 似乎在subversion存储库中有某种示例用法。
    </LI>
  </UL>
  
    也就是说，插件似乎增加了一些复杂性，它在客户端上非常简单，也许（使用jQuery）类似于：
  
   <pre>
 <code>
 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
});

</code>
 </pre>
  
    整个过程很大程度上取决于您现有架构的组合方式。
  
</DIV>

2# 你瞎啊！撞我心了 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”>
  <H2>
    更新
  </H2>
  
    随着我继续接受这方面的评价，我认为有理由记住这个答案是4岁。网络的发展速度非常快，所以请注意这个答案。
  
  <HR />
  
    我最近遇到了同样的问题，并对这个问题进行了研究。
  
  
    给出的解决方案称为长轮询，要正确使用它，您必须确保您的AJAX请求具有“大”超时，并且在当前结束（超时，错误或成功）之后始终发出此请求。
  
  <H2>
    长轮询 - 客户
  </H2>
  
    在这里，为了保持代码简短，我将使用jQuery：
  
   <pre>
 <code>
 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);

}

</code>
 </pre>
  
    重要的是要记住（来自
    <a href="https://api.jquery.com/jquery.ajax/" rel="nofollow noreferrer">
      jQuery文档
    </A>
    ）：
  
  <BLOCKQUOTE>
    
      在jQuery 1.4.x及更低版本中，XMLHttpRequest对象将在
  请求超时的状态无效;访问任何对象成员
  可能会抛出异常。仅限Firefox 3.0+，脚本和JSONP
  超时请求无法取消;即使脚本将运行
  它会在超时后到达。
    
  </BLOCKQUOTE>
  <H2>
    长轮询 - 服务器
  </H2>
  
    它不是任何特定的语言，但它会是这样的：
  
   <pre>
 <code>
 function handleRequest () {

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

return events();

}

</code>
 </pre>
  
    这里，
     <code>
 hasTimedOut
 </code>
     将确保您的代码不会永远等待，并且
     <code>
 anythingHappened
 </code>
    ，将检查是否有任何事件发生。该
     <code>
 sleep
 </code>
     用于在没有任何反应的情况下释放你的线程来做其他事情。该
     <code>
 events
 </code>
     将以JSON格式（或您喜欢的任何其他格式）返回事件字典（或您可能更喜欢的任何其他数据结构）。
  
  
    它确实解决了这个问题，但是，如果你像我在研究时一样关注可扩展性和性能，你可能会考虑我发现的另一个解决方案。
  
  <H2>
    解
  </H2>
  
    使用套接字！
  
  
    在客户端，为避免任何兼容性问题，请使用
    <a href="https://socket.io" rel="nofollow noreferrer">
      socket.io
    </A>
    。它尝试直接使用套接字，并在套接字不可用时回退到其他解决方案。
  
  
    在服务器端，使用NodeJS创建服务器（示例
    <a href="http://www.stoimen.com/blog/2010/12/02/diving-into-node-js-a-long-polling-example/" rel="nofollow noreferrer">
      这里
    </A>
    ）。客户端将订阅使用服务器创建的此通道（观察者）。每当必须发送通知时，都会在此通道中发布通知，并通知下标（客户端）。
  
  
    如果你不喜欢这个解决方案，试试APE（
    <a href="http://www.ape-project.org/" rel="nofollow noreferrer">
      Ajax推送引擎
    </A>
    ）。
  
  
    希望我帮忙。
  
</DIV>

3# Coolkid | 2019-08-31 10-32

4# 张三岁 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”>
  
    根据a
    <a href="http://www.erlang-factory.com/upload/presentations/31/EugeneLetuchy-ErlangatFacebook.pdf" rel="noreferrer">
      关于Facebook的消息系统的幻灯片
    </A>
    ，Facebook使用彗星技术将信息“推送”到网络浏览器。 Facebook的彗星服务器建立在开源的Erlang网络服务器mochiweb上。
  
  
    在下图中，短语“频道群集”表示“彗星服务器”。
  
  
    <img src =“https://i.stack.imgur.com/9Craq.jpg”alt =“系统概述”/>
  
  
    许多其他大型网站都建立了自己的彗星服务器，因为每个公司的需求都存在差异。但是在开源彗星服务器上构建自己的彗星服务器是一种很好的方法。
  
  
    你可以试试
    <a href="https://github.com/ideawu/icomet" rel="noreferrer">
      icomet
    </A>
    ，一个用libevent构建的C1000K C ++彗星服务器。 icomet还提供了一个JavaScript库，它易于使用，简单如下：
  
   <pre>
 <code>
 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);
 }
});

</code>
 </pre>
  
    icomet支持各种浏览器和操作系统，包括Safari（iOS，Mac），IE（Windows），Firefox，Chrome等。
  
</DIV>