如何实现基本的“长轮询”？

我可以找到很多关于长轮询如何工作的信息（例如，这个和这个），但没有简单的例子说明如何在代码中实现这一点。

我能找到的只有cometd，它依赖DojoJS框架和一个相当复杂的服务器系统。。

基本上，我将如何使用Apache来服务请求，以及我将如何编写一个简单的脚本（例如，用PHP）来“长轮询”服务器以获取新消息？

该示例不一定是可扩展的、安全的或完整的，它只需要工作即可！

当前回答

我认为客户端看起来像一个普通的异步AJAX请求，但您希望它需要“很长时间”才能返回。

然后服务器看起来像这样。

while (!hasNewData())
    usleep(50);

outputNewData();

因此，AJAX请求将发送到服务器，可能包括上次更新的时间戳，以便hasNewData（）知道您已经获得了哪些数据。然后，服务器在循环中休眠，直到新数据可用。一直以来，您的AJAX请求仍然连接，只是挂在那里等待数据。最后，当新数据可用时，服务器将其提供给AJAX请求并关闭连接。

2008-12-02 11:39:37

其他回答

我有一个非常简单的聊天示例作为晃动的一部分。

编辑：（因为每个人都在这里粘贴代码）

这是使用长轮询和晃动的完整的基于JSON的多用户聊天。这是一个如何进行调用的演示，因此请忽略XSS问题。任何人都不应该在不首先清理它的情况下部署它。

请注意，客户端始终与服务器保持连接，一旦有人发送消息，每个人都应该立即大致看到。

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Strict//EN"
  "http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd">
<!-- Copyright (c) 2008 Dustin Sallings <dustin+html@spy.net> -->
<html lang="en">
  <head>
    <title>slosh chat</title>
    <script type="text/javascript"
      src="http://code.jquery.com/jquery-latest.js"></script>
    <link title="Default" rel="stylesheet" media="screen" href="style.css" />
  </head>

  <body>
    <h1>Welcome to Slosh Chat</h1>

    <div id="messages">
      <div>
        <span class="from">First!:</span>
        <span class="msg">Welcome to chat. Please don't hurt each other.</span>
      </div>
    </div>

    <form method="post" action="#">
      <div>Nick: <input id='from' type="text" name="from"/></div>
      <div>Message:</div>
      <div><textarea id='msg' name="msg"></textarea></div>
      <div><input type="submit" value="Say it" id="submit"/></div>
    </form>

    <script type="text/javascript">
      function gotData(json, st) {
        var msgs=$('#messages');
        $.each(json.res, function(idx, p) {
          var from = p.from[0]
          var msg = p.msg[0]
          msgs.append("<div><span class='from'>" + from + ":</span>" +
            " <span class='msg'>" + msg + "</span></div>");
        });
        // The jQuery wrapped msgs above does not work here.
        var msgs=document.getElementById("messages");
        msgs.scrollTop = msgs.scrollHeight;
      }

      function getNewComments() {
        $.getJSON('/topics/chat.json', gotData);
      }

      $(document).ready(function() {
        $(document).ajaxStop(getNewComments);
        $("form").submit(function() {
          $.post('/topics/chat', $('form').serialize());
          return false;
        });
        getNewComments();
      });
    </script>
  </body>
</html>

2008-12-03 21:08:11

这里是Erik Dubelboer使用Content类型：multipart/x-mixed-replace-header在PHP中的一个简单的长轮询示例：

<?

header('Content-type: multipart/x-mixed-replace; boundary=endofsection');

// Keep in mind that the empty line is important to separate the headers
// from the content.
echo 'Content-type: text/plain

After 5 seconds this will go away and a cat will appear...
--endofsection
';
flush(); // Don't forget to flush the content to the browser.


sleep(5);


echo 'Content-type: image/jpg

';

$stream = fopen('cat.jpg', 'rb');
fpassthru($stream);
fclose($stream);

echo '
--endofsection
';

下面是一个演示：

http://dubbelboer.com/multipart.php

2012-12-08 12:23:13

这是PHP非常糟糕的选择之一。如前所述，您可以很快地将所有Apache工作人员绑在一起，这样做。PHP是为启动、执行和停止而构建的。它不是为开始而建造的，等等。。。执行，停止。你会很快让你的服务器陷入困境，并发现你有难以置信的扩展问题。

也就是说，您仍然可以使用PHP执行此操作，并且不会使用nginxHttpPushStreamModule杀死您的服务器：http://wiki.nginx.org/HttpPushStreamModule

您在Apache（或任何其他）前面设置nginx，它将负责保持并发连接的开放。您只需通过将数据发送到一个内部地址来响应有效负载，该地址可以通过后台作业来完成，也可以在收到新请求时将消息发送给正在等待的人。这可以防止PHP进程在长时间轮询期间处于打开状态。

这不是PHP独有的，可以使用nginx和任何后端语言来完成。并发开放连接的负载等于Node.js，所以最大的好处是它可以让你从NEEDING Node中解脱出来。

你会看到很多人提到其他语言库来完成长时间的投票，这是有充分理由的。PHP天生就不适合这种类型的行为。

2014-04-09 17:54:34

谢谢你的代码，dbr。只有long_poller.htm中的一个小错别字

1000 /* ..after 1 seconds */

我想应该是

"1000"); /* ..after 1 seconds */

让它发挥作用。

对于那些感兴趣的人，我尝试了Django的等效版本。开始一个新的Django项目，比如说长轮询：

django-admin.py startproject lp

调用消息服务器的应用程序msgsrv：

python manage.py startapp msgsrv

将以下行添加到settings.py以创建模板目录：

import os.path
PROJECT_DIR = os.path.dirname(__file__)
TEMPLATE_DIRS = (
    os.path.join(PROJECT_DIR, 'templates'),
)

在urls.py中定义URL模式如下：

from django.views.generic.simple import direct_to_template
from lp.msgsrv.views import retmsg

urlpatterns = patterns('',
    (r'^msgsrv\.php$', retmsg),
    (r'^long_poller\.htm$', direct_to_template, {'template': 'long_poller.htm'}),
)

msgsrv/views.py应该如下所示：

from random import randint
from time import sleep
from django.http import HttpResponse, HttpResponseNotFound

def retmsg(request):
    if randint(1,3) == 1:
        return HttpResponseNotFound('<h1>Page not found</h1>')
    else:
        sleep(randint(2,10))
        return HttpResponse('Hi! Have a random number: %s' % str(randint(1,10)))

最后，templates/long_poller.htm应与上面相同，并更正了拼写错误。希望这有帮助。

2009-09-15 12:30:50

你可以试试icomet(https://github.com/ideawu/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等。

2013-10-01 02:19:56

如何实现基本的“长轮询”？

推荐文章

最新文章

标签