异步长连接遇阻塞，探索，以及解决
2011-06-10 00:33
211 查看
在试验聊天程序的时候，利用AJAX保持着一个长连接监听新的聊天信息，之后又调用了另外一个AJAX来发言，于是就发生了一个AJAX线程被阻塞的问题。
在未监听到新的聊天信息的之前，发言用的AJAX就无法发出。
于是发现，这种时候，用AJAX来做聊天并不是一个合适的选择。
拍一下脑袋，想到了直接用appendChild()的方法来远程调用一个php所编译的js文件
运行html文件，点击第一个链接，访问了a.php，在其未返回内容的时候，点击第二个链接访问b.php将会被阻塞。
而点第三个链接，利用append的方法访问了c.php，在其未返回内容的时候，点击第四个链接访问d.php也会正常返回信息。
========= 6.10日发现似乎还是会被阻塞，但上述代码似乎正常 =========
6.10号试验代码如下：
页面代码
数据库结构
CREATE TABLE IF NOT EXISTS `tester` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`words` varchar(255) NOT NULL,
`saytime` int(11) NOT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 AUTO_INCREMENT=1 ;
b.php，长连接的程序
c.php 用于接收发言信息的程序
先点击了aaa链接之后，开始保持长连接，此时点击bbb链接进行发言，则被阻塞，发言失败。
========= 6.12日解决以上问题 =========
经过无数次的试验……
发现问题所在。原来并不是JS出的问题，问题在于PHP的程序上。
因为session的出现，导致了无法正常工作。
试验着将b.php里的相关session操作都删掉……改为cookie
于是长连接就不阻塞……至于为何session会引发此问题，尚未得知……
另外，至于IE6下，绑定的两个<a />连接点击会引起后续内容中止的问题，答案在http://blog.csdn.net/guoerwei/archive/2011/06/10/6535412.aspx
将
改为
即可解决
========= 6.13日解决以上问题 =========
其实问题很浅显……但竟然没人提醒的话想不起来……
原因是长连接死循环的时候，session文件被一直打开着，处于被锁定的状态，这时来发送消息，会因为session而阻塞……
在未监听到新的聊天信息的之前，发言用的AJAX就无法发出。
于是发现，这种时候，用AJAX来做聊天并不是一个合适的选择。
拍一下脑袋，想到了直接用appendChild()的方法来远程调用一个php所编译的js文件
<!DOCTYPE html>
<head>
<meta charset="utf-8" />
</head>
<body>
<a href="javascript:void(0);" mce_href="javascript:void(0);" onclick="aa(); return false;">执行a，AJAX延时</a>
<br />
<a href="javascript:void(0);" mce_href="javascript:void(0);" onclick="bb(); return false;">执行b，AJAX不延时</a>
<br />
<a href="javascript:void(0);" mce_href="javascript:void(0);" onclick="cc(); return false;">执行c，append延时</a>
<br />
<a href="javascript:void(0);" mce_href="javascript:void(0);" onclick="dd(); return false;">执行d，append不延时</a>
<script type="text/javascript">
function getxmlhttp(){
var a;
try{a=new ActiveXObject("Msxml2.XMLHTTP");}
catch(e){
try{a=new ActiveXObject("Microsoft.XMLHTTP");}
catch(E){a=false;}
}
if(!a&&typeof XMLHttpRequest!=undefined)a=new XMLHttpRequest();
return a;
}
function aa(){
var aj = getxmlhttp();
aj.open("GET","a.php",true); // 调用a.php，被设置了延时响应
aj.setRequestHeader('Content-Type','application/x-www-form-urlencoded;charset=utf-8');
aj.onreadystatechange=function(){
if(aj.readyState==4&&aj.status==200){
alert(aj.responseText); // 返回信息
}
};
aj.send(null);
}
function bb(){
var aj = getxmlhttp();
aj.open("GET","b.php",true); // 调用b.php，没有设置延时
aj.setRequestHeader('Content-Type','application/x-www-form-urlencoded;charset=utf-8');
aj.onreadystatechange=function(){
if(aj.readyState==4&&aj.status==200){
alert(aj.responseText); // 返回信息
}
};
aj.send(null);
}
function cc(){
var head = document.getElementsByTagName("head")[0];
var creater = document.createElement("script");
creater.src = "c.php?ram="+Math.round(Math.random()*10000); // 加入随机数防止被缓存，调用的是c.php，设置了延时响应
head.appendChild(creater); // 将script添加进<head />中，里面的JS将会被执行
creater.onload = creater.onreadystatechange=function(){if(!creater.readyState || creater.readyState=="loaded"){head.removeChild(creater);}}; // 载入JS后移除，防止以后head里东西太多。不过IE直接调用removeChild会造成代码不运行。故等载入完成再移除
}
function dd(){
var head = document.getElementsByTagName("head")[0];
var creater = document.createElement("script");
creater.src = "d.php?ram="+Math.round(Math.random()*10000); // 调用的是d.php，没有设置延时
head.appendChild(creater);
creater.onload = creater.onreadystatechange=function(){if(!creater.readyState || creater.readyState=="loaded"){head.removeChild(creater);}};
}
</script>
</body>
</html><?php // a.php内容 sleep(5); echo '这是a.php'; ?>
<?php // b.php内容 echo '这是b.php'; ?>
<?php
// c.php内容
sleep(5);
echo 'alert("这是c.php");';
?><?php
// d.php内容
echo 'alert("这是d.php");';
?>运行html文件，点击第一个链接，访问了a.php，在其未返回内容的时候，点击第二个链接访问b.php将会被阻塞。
而点第三个链接，利用append的方法访问了c.php，在其未返回内容的时候，点击第四个链接访问d.php也会正常返回信息。
========= 6.10日发现似乎还是会被阻塞，但上述代码似乎正常 =========
6.10号试验代码如下：
页面代码
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">
<html xmlns="http://www.w3.org/1999/xhtml">
<head>
<meta http-equiv="Content-Type" content="text/html; charset=utf-8" />
<title>无标题文档</title>
</head>
<body>
<a href="javascript:void(0);" mce_href="javascript:void(0);" id="aaa">aaa</a>
<a href="javascript:void(0);" mce_href="javascript:void(0);" id="bbb">bbb</a>
<a href="javascript:void(0);" mce_href="javascript:void(0);" id="ccc">ccc</a>
<input type="text" id="ddd" />
<mce:script type="text/javascript"><!--
function test(a){
this.classname = a;
}
test.prototype.load_js = function(url){ // 在当前页面head里加载js
var head = document.getElementsByTagName("head")[0];
var creater = document.createElement("script");
creater.src = url;
head.appendChild(creater);
creater.onload = creater.onreadystatechange = function(){
if(!(creater.readyState) || creater.readyState == "loaded"){
head.removeChild(creater);
}
};
}
test.prototype.frame_load_js = function(url){ // 在iframe的head里加载js
var head = this.iframe.contentDocument ? this.iframe.contentDocument.getElementsByTagName("head")[0] : this.iframe.document.getElementsByTagName("head")[0];
var creater = document.createElement("script");
creater.src = url;
head.appendChild(creater);
creater.onload = creater.onreadystatechange = function(){
if(!(creater.readyState) || creater.readyState == "loaded"){
head.removeChild(creater);
}
};
}
test.prototype.listen = function(){ // 长连接
var url = "b.php?classname="+this.classname+"&ram="+Math.round(Math.random()*10000);
this.frame_load_js(url);
}
test.prototype.get_alert = function(res){ // 长连接返回的结果
this.save_result = res;
alert(res["words"]);
}
test.prototype.speak = function(){ // 发送消息的连接
var words = document.getElementById("ddd").value;
var url = "c.php?words="+encodeURIComponent(words)+"&classname="+this.classname+"&ram="+Math.round(Math.random()*10000);
this.frame_load_js(url);
}
test.prototype.init = function(){ // 初始化
var _this = this;
// 创建一个iframe，用iframe
this.iframe = document.createElement("iframe");
this.iframe.style.display = "none";
document.getElementsByTagName("body")[0].appendChild(this.iframe);
document.getElementById("aaa").onclick = function(){ _this.listen();};
document.getElementById("bbb").onclick = function(){ _this.speak();};
}
var zz = new test("zz");
zz.init();
// --></mce:script>
</body>
</html>数据库结构
CREATE TABLE IF NOT EXISTS `tester` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`words` varchar(255) NOT NULL,
`saytime` int(11) NOT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 AUTO_INCREMENT=1 ;
b.php，长连接的程序
<?php
$host = '127.0.0.1';
$user = 'root';
$pwd = '123456';
$db = 'chatter';
$charset = 'utf8';
$conn = mysql_connect($host, $user, $pwd) or die('Cannot connect database!');
mysql_set_charset($charset);
mysql_select_db($db);
session_start();
$data = array();
while (empty($data)){
$time_flag = !empty($_SESSION['time_flag']) ? $_SESSION['time_flag'] : 0;
$sql = 'SELECT * FROM tester WHERE saytime >= '.$time_flag;
$query = mysql_query($sql);
$rows = mysql_num_rows($query);
if (!empty($rows)){
$rs = mysql_fetch_assoc($query);
$data = $rs;
if (!empty($data)){
echo 'parent.'.$_GET['classname'].'.get_alert('.json_encode($data).');';
$_SESSION['time_flag'] = time();
exit();
}
}
$_SESSION['time_flag'] = time();
sleep(2);
}
?>c.php 用于接收发言信息的程序
<?php
$host = '127.0.0.1';
$user = 'root';
$pwd = '123456';
$db = 'chatter';
$charset = 'utf8';
$conn = mysql_connect($host, $user, $pwd) or die('Cannot connect database!');
mysql_set_charset($charset);
mysql_select_db($db);
session_start();
$words = trim($_GET['words']);
$sql = 'INSERT INTO tester (words, saytime) VALUES ("'.$words.'", "'.time().'")';
$query = mysql_query($sql);
echo 'alert(1);';
?>先点击了aaa链接之后，开始保持长连接，此时点击bbb链接进行发言，则被阻塞，发言失败。
========= 6.12日解决以上问题 =========
经过无数次的试验……
发现问题所在。原来并不是JS出的问题，问题在于PHP的程序上。
因为session的出现，导致了无法正常工作。
试验着将b.php里的相关session操作都删掉……改为cookie
<?php
$host = '127.0.0.1';
$user = 'root';
$pwd = '123456';
$db = 'chatter';
$charset = 'utf8';
$conn = mysql_connect($host, $user, $pwd) or die('Cannot connect database!');
mysql_set_charset($charset);
mysql_select_db($db);
$data = array();
while (empty($data)){
$time_flag = !empty($_COOKIE['time_flag']) ? $_COOKIE['time_flag'] : 0;
$sql = 'SELECT * FROM tester WHERE saytime >= '.$time_flag;
$query = mysql_query($sql);
$rows = mysql_num_rows($query);
if (!empty($rows)){
$rs = mysql_fetch_assoc($query);
$data = $rs;
if (!empty($data)){
setcookie("time_flag", time(), time()+3600);
echo 'parent.'.$_GET['classname'].'.get_alert('.json_encode($data).');';
exit();
}
}
sleep(2);
}
?>于是长连接就不阻塞……至于为何session会引发此问题，尚未得知……
另外，至于IE6下，绑定的两个<a />连接点击会引起后续内容中止的问题，答案在http://blog.csdn.net/guoerwei/archive/2011/06/10/6535412.aspx
将
test.prototype.init = function(){ // 初始化
var _this = this;
// 创建一个iframe，用iframe
this.iframe = document.createElement("iframe");
this.iframe.style.display = "none";
document.getElementsByTagName("body")[0].appendChild(this.iframe);
document.getElementById("aaa").onclick = function(){ _this.listen();};
document.getElementById("bbb").onclick = function(){ _this.speak();};
}改为
test.prototype.init = function(){ // 初始化
var _this = this;
// 创建一个iframe，用iframe
this.iframe = document.createElement("iframe");
this.iframe.style.display = "none";
document.getElementsByTagName("body")[0].appendChild(this.iframe);
document.getElementById("aaa").onclick = function(){ _this.listen(); return false;};
document.getElementById("bbb").onclick = function(){ _this.speak(); return false;};
}即可解决
========= 6.13日解决以上问题 =========
其实问题很浅显……但竟然没人提醒的话想不起来……
原因是长连接死循环的时候，session文件被一直打开着，处于被锁定的状态，这时来发送消息，会因为session而阻塞……
内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理 
相关文章推荐
- 异步长连接遇阻塞，探索，以及解决
- Ajax 是什么？Ajax 的交互模型？同步和异步的区别？如何解决跨域问题？以及 HTTP状态码
- 阻塞、非阻塞、异步、同步以及select/poll和epoll(转载)
- Java与SQL Server, MySql, Oracle, Access的连接方法以及一些异常解决
- Win 7 安装VMware Workstation Pro 14出现 “Intel VT-x禁用”问题以及“无法连接 MKS: 套接字连接尝试次数太多；正在放弃”问题的实质性解决
- 长连接 短连接 异步 同步 )阻塞与非阻塞
- 关于spss显示“试图连接远程服务器失败”的问题以及解决方法
- javascript异步代码的回调地狱以及JQuery.deferred提供的promise解决方式
- 连接MySql的时候报1130的错误解决办法以及远程登陆方法.
- 分享今天在客户那里遇到的SQLSERVER连接超时以及我的解决办法
- Redis Desktop Manager连接Redis（以及解决遇到的问题）
- Android ListView异步加载图片乱序问题以及解决
- 同步异步以及阻塞和非阻塞的区别
- 使用SQLyog远程连接mysql，以及mysql远程连接错误1130 解决方法
- Entity Framework4.3安装以及错误(基础连接已经关闭：未能为SSL/TLS……)问题解决！
- 升级到ActiveSync 4.5后“可能”遇到的网络连接问题，以及解决方法
- 简述linux同步与异步、阻塞与非阻塞概念以及五种IO模型
- 阻塞、非阻塞、异步、同步以及select/poll和epoll
- 异步压力测试探索：什么是异步非阻塞
- PLSQL Developer 9.0 下载+汉化+注册机 以及无法连接到64位数据库解决方法