我已经在这里发布了一个类似的问题,但未能得到解决我问题的回复,而且问题也发生了一些变化,所以我正在重新发布,并迫切希望得到一些帮助!
链接到上一个问题:
mysql 的ajax长轮询
当前代码:
JS(我从php运行):
$oldIDq = mysql_query("SELECT * FROM messages ORDER BY id DESC LIMIT 1");
while($oldrow = mysql_fetch_array($oldIDq)){
$oldID = $oldrow['id'];
}
$func = '
var oldID = '.$oldID.';
function wait() {
$.ajax({
type: "GET",
url: "../scripts/msg_scripts/msg.php?oldid=" + oldID,
async: true,
cache: false,
success: function (data){
if(data != ''1''){
var json = eval(''('' + data + '')'');
if (json[''msg_content''] != "") {
alert("new meassage added");
}
oldID = json[''oldID''];
setTimeout(''wait()'',1000); }
},
disconnect: function()
{
return false;
setTimeout(''wait()'',1000);
},
error: function(XMLHttpRequest, textStatus, errorThrown){
alert("error: " + textStatus + "(" + errorThrown + ")");
setTimeout(''wait()'',1000);
}
});
}
$(document).ready(function(){
wait();
});
';
服务器:
$connect = mysql_connect ("localhost", "root", "")
or die ("couldnt connect");
mysql_select_db ("***") or die ("not found"); //if db was not found die
mysql_query("SET NAMES 'utf8'");
$oldID = $_GET['oldid'];
if($oldID == "") {
die('timeout');
}
else{
$result = mysql_query("SELECT id FROM messages ORDER BY id DESC LIMIT 1");
while($row = mysql_fetch_array($result))
{
$last_msg_id = $row['id'];
}
while($last_msg_id <= $oldID)
{
usleep(10000);
clearstatcache();
$result = mysql_query("SELECT id FROM messages ORDER BY id DESC LIMIT 1");
while($row = mysql_fetch_array($result))
{
$last_msg_id = $row['id'];
}
}
$response = array();
$response['msg_content'] = 'new';
$response['oldID'] = $last_msg_id;
echo json_encode($response);
}
现在,我有一个会话在进程的服务器端运行,我暂时删除了它,因为我知道长时间轮询会话有问题。我也有会话在发送ajax请求的页面上运行,因为我删除了会话,我的问题在某种程度上得到了改善,现在发生的是,我基本上可以点击我网站上的一个链接,然后退出页面,然后出现错误,但如果我做了4-5次以上,浏览器会冻结任何链接上的每次点击,只需重新运行ajax函数,就会得到不同的错误。如果我刷新请求的页面,我会立即得到第二个错误,浏览器会冻结。如果这是有用的信息,如果我关闭浏览器并尝试重新打开我的网站的任何页面,它根本不会加载,除非我重新运行我的服务器(现在在本地主机上工作)
有人能告诉我解决办法吗?
-再次更新以检索所有新消息
在阅读代码时,您只希望返回最后一条消息,如果是这样,那么while循环在这种情况下是非常无用的。请记住,在旧ID和插入数据库的最后一个ID之间可能会有更多的"新"消息,您可以跳过这些消息,我提供的也是如此
$connect = mysql_connect ("localhost", "root", "")
or die ("couldnt connect");
mysql_select_db ("***") or die ("not found"); //if db was not found die
mysql_query("SET NAMES 'utf8'");
$oldID = trim($_GET['oldid']);
// empty response, you may fill it with a default msg
$response = array(
'msg_content' => 'none',
'oldID' => $oldID
);
// this if statement will prevent to return a valid
// JSON string to the ajax request
if(empty($oldID)) {
die('timeout');
}
else {
$result = mysql_query("SELECT id FROM messages WHERE id > ".addslashes($oldID)." ORDER BY id DESC");
$index = 1;
// check if results have new messages
if(($num_rows = mysql_num_rows($result) > 0) {
$response['msg_content'] = 'new';
while($row = mysql_fetch_array($result)) {
$response['new_msgs'][] = $row['id']
if($index == $num_rows)
$response['oldID'] = $row['id']; // set oldID to last record
}
}
echo json_encode($response);
--
致您对如何正确使用session_write_close的评论。
session_start();
$var_id = $_SESSION['id'];
$var_fn = $_SESSION['firstname'];
$var_ln = $_SESSION['lastname'];
$var_mail = $_SESSION['email'];
// close write to session here to release it for other sources
session_write_close();
if (!loggedin()){
header ("Location: index.php");}
if ($_GET['id']) {
$id = mysql_real_escape_string($_GET['id']);}
// you are using session here, use the localized $var_id
else if (isset($var_id)) {
$id = mysql_real_escape_string($var_id);
}
当调用session_start()
时,该点上的会话被锁定,以便写入任何其他源,除了它所在的当前作用域(.php执行文件)。这是为了确保在读取会话值的过程中不会更改任何值。
从文件
会话数据通常在脚本终止后存储,无需调用Session_write_close(),但由于会话数据被锁定以防止并发写入,因此任何时候只有一个脚本可以在会话上操作。当将框架集与会话一起使用时,由于此锁定,您将经历一个接一个的框架加载。您可以在完成对会话变量的所有更改后立即结束会话,从而减少加载所有帧所需的时间。
对于被卡住的问题,我认为while循环是无休止的,请从浏览器http://example.com/pathto/scripts/msg_scripts/msg.php
请求页面,然后看看会发生什么
$counter = 0;
while($last_msg_id <= $oldID)
{
usleep(10); // changing to be a bit faster
clearstatcache();
$result = mysql_query("SELECT id FROM messages ORDER BY id DESC LIMIT 1");
$row = mysql_fetch_array($result);
$last_msg_id = $row['id'];
$counter++;
if($counter > 100)
break;
}
echo "counted: {$counter}";
exit();