我如何实现基本的“长轮询”？
我可以找到关于长轮询如何工作的很多信息（例如，这个和这个），但没有关于如何在代码中实现的简单示例。
我只能找到cometd，它依赖于Dojo JS框架和一个相当复杂的服务器系统。
基本上，我将如何使用Apache来服务请求，以及如何编写一个简单的脚本（比如说用PHP）来“长期轮询”服务器以获取新消息？
这个例子不必是可扩展的，安全的或完整的，它只需要工作！
这比我最初想象的要简单。基本上你有一个什么都不做的页面，直到你想发送的数据可用（比如说一个新的消息到达）。
这是一个非常基本的例子，它在2-10秒后发送一个简单的字符串。 三分之一的机会返回一个错误404（在未来的Javascript示例中显示错误处理）
msgsrv.php
<?php
if(rand(1,3) == 1){
/* Fake an error */
header("HTTP/1.0 404 Not Found");
die();
}
/* Send a string after a random number of seconds (2-10) */
sleep(rand(2,10));
echo("Hi! Have a random number: " . rand(1,10));
?>
注意：对于一个真实的站点，在像Apache这样的普通Web服务器上运行它会快速绑定所有“工作线程”，并使其无法响应其他请求。有办法解决这个问题，但建议写一个类似Python的扭曲的“长轮询服务器”，它不依赖于每个请求的一个线程。 cometD是一种流行的（有几种语言可用），Tornado是一个专门用于这些任务的新框架（它是为FriendFeed的长查询代码构建的）......但作为一个简单的例子，Apache已经足够了！ 这个脚本可以很容易地用任何语言编写（我选择Apache / PHP，因为它们很常见，而且我碰巧在本地运行它们）
然后，在Javascript中，您请求上述文件（ msg_srv.php ），然后等待响应。 当你得到一个，你的数据行事。 然后您请求文件并再次等待，根据数据进行操作（并重复）
接下来是这样一个页面的例子。当页面被加载时，它发送msgsrv.php文件的初始请求。如果成功，我们将消息附加到#messages div，然后在1秒钟后waitForMsg函数再次触发等待。
1秒setTimeout()是一个非常基本的速率限制器，没有这个就可以正常工作，但是如果msgsrv.php总是立即返回（例如语法错误），那么浏览器就会泛滥，并且可能会很快冻结。 最好检查文件是否包含有效的JSON响应，和/或保持每分钟/每秒的请求总数，并适当地暂停。
如果页面错误，它将错误追加到#messages div，等待15秒，然后再次尝试（与每条消息后等待1秒相同）
这种方法的好处是它非常有弹性。 如果客户端互联网连接中断，它会超时，然后尝试重新连接 - 这是轮询工作时间固有的，不需要复杂的错误处理
无论如何，使用jQuery框架的long_poller.htm代码如下：
<html>
<head>
<title>BargePoller</title>
<script src="http://ajax.googleapis.com/ajax/libs/jquery/1.2.6/jquery.min.js" type="text/javascript" charset="utf-8"></script>
<style type="text/css" media="screen">
body{ background:#000;color:#fff;font-size:.9em; }
.msg{ background:#aaa;padding:.2em; border-bottom:1px #000 solid}
.old{ background-color:#246499;}
.new{ background-color:#3B9957;}
.error{ background-color:#992E36;}
</style>
<script type="text/javascript" charset="utf-8">
function addmsg(type, msg){
/* Simple helper to add a div.
type is the name of a CSS class (old/new/error).
msg is the contents of the div */
$("#messages").append(
"<div class='msg "+ type +"'>"+ msg +"</div>"
);
}
function waitForMsg(){
/* This requests the url "msgsrv.php"
When it complete (or errors)*/
$.ajax({
type: "GET",
url: "msgsrv.php",
async: true, /* If set to non-async, browser shows page as "Loading.."*/
cache: false,
timeout:50000, /* Timeout in ms */
success: function(data){ /* called when request to barge.php completes */
addmsg("new", data); /* Add response to a .msg div (with the "new" class)*/
setTimeout(
waitForMsg, /* Request next message */
1000 /* ..after 1 seconds */
);
},
error: function(XMLHttpRequest, textStatus, errorThrown){
addmsg("error", textStatus + " (" + errorThrown + ")");
setTimeout(
waitForMsg, /* Try again after.. */
15000); /* milliseconds (15seconds) */
}
});
};
$(document).ready(function(){
waitForMsg(); /* Start the inital request */
});
</script>
</head>
<body>
<div id="messages">
<div class="msg old">
BargePoll message requester!
</div>
</div>
</body>
</html>
我有一个非常简单的聊天示例作为slosh的一部分。
编辑 :(因为每个人都在这里粘贴他们的代码）
这是使用长轮询和晃动的完整的基于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>
Tornado专为长轮询而设计，并且在/ examples / chatdemo中包含一个非常小的（几百行Python）聊天应用程序，包括服务器代码和JS客户端代码。 它是这样工作的：
客户端使用JS从（最后一条消息的编号）开始请求更新，服务器URLHandler接收这些更新并添加一个回调以响应客户端到队列。
当服务器收到新消息时，onmessage事件触发，循环遍历回调，并发送消息。
客户端JS接收到该消息，将其添加到该页面，然后询问自该新消息ID以来的更新。