dbr*_*dbr 507
这比我最初的想法简单.基本上你有一个什么都不做的页面,直到你想要发送的数据可用(比如,新消息到达).
这是一个非常基本的例子,它在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文件的初始请求..如果成功,我们将消息附加到#messagesdiv,然后在1秒后我们再次调用waitForMsg函数,这会触发等待.
1秒setTimeout()是一个非常基本的速率限制器,如果没有这个,它可以正常工作,但如果msgsrv.php 总是立即返回(例如语法错误) - 你淹没浏览器,它可以快速冻结.最好检查文件是否包含有效的JSON响应,和/或保持每分钟/秒的运行总计请求,并适当地暂停.
如果页面错误,它会将错误附加到#messagesdiv,等待15秒然后再次尝试(与每条消息后等待1秒的方式相同)
这种方法的好处是它非常有弹性.如果客户端互联网连接中断,它将超时,然后尝试重新连接 - 这是轮询工作多长时间所固有的,不需要复杂的错误处理
无论如何,long_poller.htm代码,使用jQuery框架:
<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>
Dus*_*tin 41
作为晃动的一部分,我有一个非常简单的聊天示例.
编辑 :(因为每个人都在这里粘贴他们的代码)
这是使用长轮询和晃动的完整的基于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>
Gre*_*reg 24
我认为客户端看起来像是一个普通的异步AJAX请求,但是你希望它需要"很长时间"才能回来.
然后服务器看起来像这样.
while (!hasNewData())
usleep(50);
outputNewData();
因此,AJAX请求进入服务器,可能包括上次更新时间的时间戳,以便您hasNewData()知道已经获得了哪些数据.然后服务器处于休眠状态,直到新数据可用.一直以来,你的AJAX请求仍然是连接的,只是挂在那里等待数据.最后,当有新数据可用时,服务器会将其提供给您的AJAX请求并关闭连接.
Sea*_*n O 16
这是一个很好的5分钟截屏视频,介绍如何使用PHP和jQuery进行长轮询:http: //screenr.com/SNH
代码与上面的dbr示例非常相似.
Jas*_*lsa 12
以下是Erik Dubbelboer在PHP中使用Content-type: multipart/x-mixed-replace标题的简单长轮询示例:
<?
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
下面是我为Inform8 Web开发的一个长轮询解决方案.基本上,您重写该类并实现loadData方法.当loadData返回一个值或操作超时时,它将打印结果并返回.
如果脚本处理时间超过30秒,则可能需要将set_time_limit()调用更长时间.
Apache 2.0许可证.github上的最新版本 https://github.com/ryanhend/Inform8/blob/master/Inform8-web/src/config/lib/Inform8/longpoll/LongPoller.php
瑞安
abstract class LongPoller {
protected $sleepTime = 5;
protected $timeoutTime = 30;
function __construct() {
}
function setTimeout($timeout) {
$this->timeoutTime = $timeout;
}
function setSleep($sleep) {
$this->sleepTime = $sleepTime;
}
public function run() {
$data = NULL;
$timeout = 0;
set_time_limit($this->timeoutTime + $this->sleepTime + 15);
//Query database for data
while($data == NULL && $timeout < $this->timeoutTime) {
$data = $this->loadData();
if($data == NULL){
//No new orders, flush to notify php still alive
flush();
//Wait for new Messages
sleep($this->sleepTime);
$timeout += $this->sleepTime;
}else{
echo $data;
flush();
}
}
}
protected abstract function loadData();
}
小智 8
谢谢你的代码,dbr.这条线路上的long_poller.htm只是一个小错字
1000 /* ..after 1 seconds */
我认为应该是
"1000"); /* ..after 1 seconds */
它的工作原理.
对于那些感兴趣的人,我尝试了一个Django等价物.启动一个新的Django项目,比如lp用于长轮询:
django-admin.py startproject lp
为消息服务器调用app 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中定义您的网址格式:
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)))
最后,模板/ long_poller.htm应该与上面相同,并更正拼写错误.希望这可以帮助.
这是PHP是一个非常糟糕的选择的场景之一.如前所述,您可以非常快速地绑定所有Apache工作人员.PHP是为启动,执行,停止而构建的.它不是为了开始而构建的,等待......执行,停止.你会很快陷入服务器,发现你有令人难以置信的扩展问题.
也就是说,您仍然可以使用PHP执行此操作,并且不要使用nginx HttpPushStreamModule来杀死您的服务器:http://wiki.nginx.org/HttpPushStreamModule
你在Apache(或其他任何东西)面前设置nginx,它将负责保持打开并发连接.您只需通过将数据发送到您可以使用后台作业执行的内部地址来响应有效负载,或者只是将消息发送给在新请求进入时等待的人员.这可以防止PHP进程在长轮询期间保持打开状态.
这不是PHP独有的,可以使用任何后端语言的nginx来完成.并发开放连接负载等于Node.js,因此最大的好处是它可以让你离开NEEDING Node这样的事情.
你看到很多其他人提到其他语言库来完成长时间的轮询,这是有充分理由的.PHP本身并不适合这种类型的行为.
| 归档时间： |
|
| 查看次数： |
275085 次 |
| 最近记录： |