私はここ数日から同じ問題に取り組んでおり、次のサンプルコードになりました。
必要なのは、最後に更新されtime-stamp
たものを新しいリクエストに渡し、それに従って、渡されたものと現在のもののtime-stamp
間のレコードを検索することです。time-stamp
time-stamp
インデックス.php
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.1//EN" "http://www.w3.org/TR/xhtml11/DTD/xhtml11.dtd">
<html xmlns="http://www.w3.org/1999/xhtml">
<head>
<title>testing comet</title>
<meta http-equiv="Content-Type" content="text/html; charset=utf-8" />
<link rel="stylesheet" href="css/style.css" />
<script type="text/javascript" src="js/jquery.js"></script>
</head>
<body>
<div id="content"></div>
<script type="text/javascript">
var Comet = function (data_url)
{
this.timestamp = 0;
this.url = data_url;
this.noerror = true;
this.connect = function()
{
var self = this;
$.ajax(
{
type : 'post',
url : this.url,
dataType : 'json',
data :
{
'timestamp' : self.timestamp
},
success : function(response)
{
self.timestamp = response.timestamp;
self.handleResponse(response);
self.noerror = true;
},
complete : function(response)
{
if (!self.noerror)
{
setTimeout(function(){ comet.connect(); }, 5000);
}
else
{
self.connect();
}
self.noerror = false;
}
});
}
this.disconnect = function() {}
this.handleResponse = function(response)
{
$('#content').append('<div>' + response.msg + '</div>');
}
this.doRequest = function(request) {
$.ajax(
{
type : 'post',
url : "index.php",
data :
{
'msg' : request,
'submit' : "Send"
}
});
}
}
var comet = new Comet('./backend.php');
comet.connect();
</script>
</body>
</html>
backend.php
<?php
$filename = dirname(__FILE__).'/data.txt';
$msg = isset($_GET['msg']) ? $_GET['msg'] : '';
if ($msg != '')
{
file_put_contents($filename,$msg);
die();
}
$lastmodif = isset($_GET['timestamp']) ? $_GET['timestamp'] : 0;
$currentmodif = filemtime($filename);
while ($currentmodif <= $lastmodif) // check if the data file has been modified
{
usleep(10000); // sleep 10ms to unload the CPU
clearstatcache();
$currentmodif = filemtime($filename);
}
$response = array();
$response['msg'] = file_get_contents($filename);
$response['timestamp'] = $currentmodif;
echo json_encode($response);
flush();
?>
あなたがする必要があるのはtxt file time modification
、mysql
クエリに置き換えることだけです。
txtファイルをmysqlに置き換えるサンプルコード
<?php
date_default_timezone_set('Asia/Kolkata');
$connection = mysql_connect('localhost','root','')or die(mysql_error());
$database = mysql_select_db('stackoverflow')or die(mysql_error());
function get_date()
{
$query = mysql_query("show table status from stackoverflow like 'last_update'")or die(mysql_error());
$row = array();
while($result = mysql_fetch_assoc($query))
{
$row[] = $result;
}
return strtotime($row[0]['Update_time']);
}
$lastmodif = isset($_POST['timestamp']) ? $_POST['timestamp'] : 0;
$currentmodif = get_date();
while ($currentmodif <= $lastmodif)
{
usleep(10000);
clearstatcache();
$currentmodif = get_date();
}
$query_db = mysql_query("SELECT UNIX_TIMESTAMP(last_update.created) AS DATE,last_update.* FROM last_update WHERE UNIX_TIMESTAMP(last_update.created) BETWEEN '".$lastmodif."' AND '".$currentmodif."'")or die(mysql_error());
$row_db = array();
$response = array();
while($result_db = mysql_fetch_assoc($query_db))
{
$response['msg'][] = $result_db['title'];
}
$response['timestamp'] = $currentmodif;
$response['lastmodif'] = $lastmodif;
echo json_encode($response);
flush();
これがあなたを助けることを願っています。