使用PHP和AJAX不刷新页面的新事件通知
•浏览 1
New event notification without refreshing a page using PHP and AJAX
每次将新事件添加到我的数据库时,我都会向我的用户显示通知。我的首页上有一个小图标,还有一个红色方块来显示添加的新事件的数量。现在我只想知道在不刷新页面的情况下显示新事件的最佳方法是什么。
这是我的代码
<li>
<i class="fa fa-warning fa-2x">
<?php if ($totalRows_event > 0) { ?>
<span class="label label-danger blink"><?php echo $totalRows_event ?></span>
<?php } ?>
</li>
function testAjax() {
var result ="";
$.ajax({
url:"data.php",
async: false,
success: function (data, textStatus) {
$("#preview").html(data);
},
error: function () {
alert('Not OKay');
}
});
return result;
}
<li>
<i class="fa fa-warning fa-2x">
<span class="label label-danger blink" id="preview"></span>
</li>
public function index()
{
if (!$_GET['timed']) exit();
if (!$_GET['uid']) exit();
date_default_timezone_set("PRC");
set_time_limit(0);
$uid = $_GET['uid'];
while (true) {
sleep(3);
$lastReadTime = M('readtime')->where(array('uid'=>$uid))->field('lasttime')->select();
$result = M('message')->where(array('send_time'=>array('gt',$lastReadTime),'touid'=>$uid))->count();
if($result){
$data = array(
'message' => $result,
);
echo json_encode($data);
exit();
} else {
usleep(1000);
exit();
//return;
}
}
session_write_close();
}
var cometURL ="{:U(GROUP_NAME.'/Comet/index')}"
$(function () {
(function longPolling() {
//alert(Date.parse(new Date())/1000);
$.ajax({
url: cometURL,
data: {"timed": Date.parse(new Date())/1000,"uid":$("#uid-hidden").val()},
dataType:"json",
timeout: 5000,
error: function (XMLHttpRequest, textStatus, errorThrown) {
if (textStatus =="timeout") {
longPolling();
} else {
longPolling();
}
},
success: function (data, textStatus) {
if(data.message != 0){
$(document.body).append("<i class='iconfont'style='position: fixed;top: 28px;right: 30px;color: #2fa8ec;font-size: 20px'>");
$("#messagenum").html('message('+data.message+')');
}
if(data.image != 0){
$(document.body).append("<i class='iconfont'style='position: fixed;top: 28px;right: 30px;color: #2fa8ec;font-size: 20px'>");
$("#imagenum").html('New Image('+data.image+')');
}
if (textStatus =="success") {
longPolling();
}
}
});
})();
});
我的PHP查询基本上是事件总数>0的时候,显示一个<span>和里面的总数,但是这只在页面刷新或者加载的时候显示。
我正在查看一个类似于下面的 AJAX 请求,它将 PHP 查询结果显示到内部 html 中。
<li>
<i class="fa fa-warning fa-2x">
<?php if ($totalRows_event > 0) { ?>
<span class="label label-danger blink"><?php echo $totalRows_event ?></span>
<?php } ?>
</li>
function testAjax() {
var result ="";
$.ajax({
url:"data.php",
async: false,
success: function (data, textStatus) {
$("#preview").html(data);
},
error: function () {
alert('Not OKay');
}
});
return result;
}
<li>
<i class="fa fa-warning fa-2x">
<span class="label label-danger blink" id="preview"></span>
</li>
public function index()
{
if (!$_GET['timed']) exit();
if (!$_GET['uid']) exit();
date_default_timezone_set("PRC");
set_time_limit(0);
$uid = $_GET['uid'];
while (true) {
sleep(3);
$lastReadTime = M('readtime')->where(array('uid'=>$uid))->field('lasttime')->select();
$result = M('message')->where(array('send_time'=>array('gt',$lastReadTime),'touid'=>$uid))->count();
if($result){
$data = array(
'message' => $result,
);
echo json_encode($data);
exit();
} else {
usleep(1000);
exit();
//return;
}
}
session_write_close();
}
var cometURL ="{:U(GROUP_NAME.'/Comet/index')}"
$(function () {
(function longPolling() {
//alert(Date.parse(new Date())/1000);
$.ajax({
url: cometURL,
data: {"timed": Date.parse(new Date())/1000,"uid":$("#uid-hidden").val()},
dataType:"json",
timeout: 5000,
error: function (XMLHttpRequest, textStatus, errorThrown) {
if (textStatus =="timeout") {
longPolling();
} else {
longPolling();
}
},
success: function (data, textStatus) {
if(data.message != 0){
$(document.body).append("<i class='iconfont'style='position: fixed;top: 28px;right: 30px;color: #2fa8ec;font-size: 20px'>");
$("#messagenum").html('message('+data.message+')');
}
if(data.image != 0){
$(document.body).append("<i class='iconfont'style='position: fixed;top: 28px;right: 30px;color: #2fa8ec;font-size: 20px'>");
$("#imagenum").html('New Image('+data.image+')');
}
if (textStatus =="success") {
longPolling();
}
}
});
})();
});
<li>
<i class="fa fa-warning fa-2x">
<?php if ($totalRows_event > 0) { ?>
<span class="label label-danger blink"><?php echo $totalRows_event ?></span>
<?php } ?>
</li>
function testAjax() {
var result ="";
$.ajax({
url:"data.php",
async: false,
success: function (data, textStatus) {
$("#preview").html(data);
},
error: function () {
alert('Not OKay');
}
});
return result;
}
<li>
<i class="fa fa-warning fa-2x">
<span class="label label-danger blink" id="preview"></span>
</li>
public function index()
{
if (!$_GET['timed']) exit();
if (!$_GET['uid']) exit();
date_default_timezone_set("PRC");
set_time_limit(0);
$uid = $_GET['uid'];
while (true) {
sleep(3);
$lastReadTime = M('readtime')->where(array('uid'=>$uid))->field('lasttime')->select();
$result = M('message')->where(array('send_time'=>array('gt',$lastReadTime),'touid'=>$uid))->count();
if($result){
$data = array(
'message' => $result,
);
echo json_encode($data);
exit();
} else {
usleep(1000);
exit();
//return;
}
}
session_write_close();
}
var cometURL ="{:U(GROUP_NAME.'/Comet/index')}"
$(function () {
(function longPolling() {
//alert(Date.parse(new Date())/1000);
$.ajax({
url: cometURL,
data: {"timed": Date.parse(new Date())/1000,"uid":$("#uid-hidden").val()},
dataType:"json",
timeout: 5000,
error: function (XMLHttpRequest, textStatus, errorThrown) {
if (textStatus =="timeout") {
longPolling();
} else {
longPolling();
}
},
success: function (data, textStatus) {
if(data.message != 0){
$(document.body).append("<i class='iconfont'style='position: fixed;top: 28px;right: 30px;color: #2fa8ec;font-size: 20px'>");
$("#messagenum").html('message('+data.message+')');
}
if(data.image != 0){
$(document.body).append("<i class='iconfont'style='position: fixed;top: 28px;right: 30px;color: #2fa8ec;font-size: 20px'>");
$("#imagenum").html('New Image('+data.image+')');
}
if (textStatus =="success") {
longPolling();
}
}
});
})();
});
但是,每次将新事件添加到我的数据库时,我如何调用该函数而不刷新或加载页面?我认为使用设置的时间间隔或延迟会因为频繁的服务器查询而减慢我的页面,所以我正在寻找其他选项。
php:
<li>
<i class="fa fa-warning fa-2x">
<?php if ($totalRows_event > 0) { ?>
<span class="label label-danger blink"><?php echo $totalRows_event ?></span>
<?php } ?>
</li>
function testAjax() {
var result ="";
$.ajax({
url:"data.php",
async: false,
success: function (data, textStatus) {
$("#preview").html(data);
},
error: function () {
alert('Not OKay');
}
});
return result;
}
<li>
<i class="fa fa-warning fa-2x">
<span class="label label-danger blink" id="preview"></span>
</li>
public function index()
{
if (!$_GET['timed']) exit();
if (!$_GET['uid']) exit();
date_default_timezone_set("PRC");
set_time_limit(0);
$uid = $_GET['uid'];
while (true) {
sleep(3);
$lastReadTime = M('readtime')->where(array('uid'=>$uid))->field('lasttime')->select();
$result = M('message')->where(array('send_time'=>array('gt',$lastReadTime),'touid'=>$uid))->count();
if($result){
$data = array(
'message' => $result,
);
echo json_encode($data);
exit();
} else {
usleep(1000);
exit();
//return;
}
}
session_write_close();
}
var cometURL ="{:U(GROUP_NAME.'/Comet/index')}"
$(function () {
(function longPolling() {
//alert(Date.parse(new Date())/1000);
$.ajax({
url: cometURL,
data: {"timed": Date.parse(new Date())/1000,"uid":$("#uid-hidden").val()},
dataType:"json",
timeout: 5000,
error: function (XMLHttpRequest, textStatus, errorThrown) {
if (textStatus =="timeout") {
longPolling();
} else {
longPolling();
}
},
success: function (data, textStatus) {
if(data.message != 0){
$(document.body).append("<i class='iconfont'style='position: fixed;top: 28px;right: 30px;color: #2fa8ec;font-size: 20px'>");
$("#messagenum").html('message('+data.message+')');
}
if(data.image != 0){
$(document.body).append("<i class='iconfont'style='position: fixed;top: 28px;right: 30px;color: #2fa8ec;font-size: 20px'>");
$("#imagenum").html('New Image('+data.image+')');
}
if (textStatus =="success") {
longPolling();
}
}
});
})();
});
js:
<li>
<i class="fa fa-warning fa-2x">
<?php if ($totalRows_event > 0) { ?>
<span class="label label-danger blink"><?php echo $totalRows_event ?></span>
<?php } ?>
</li>
function testAjax() {
var result ="";
$.ajax({
url:"data.php",
async: false,
success: function (data, textStatus) {
$("#preview").html(data);
},
error: function () {
alert('Not OKay');
}
});
return result;
}
<li>
<i class="fa fa-warning fa-2x">
<span class="label label-danger blink" id="preview"></span>
</li>
public function index()
{
if (!$_GET['timed']) exit();
if (!$_GET['uid']) exit();
date_default_timezone_set("PRC");
set_time_limit(0);
$uid = $_GET['uid'];
while (true) {
sleep(3);
$lastReadTime = M('readtime')->where(array('uid'=>$uid))->field('lasttime')->select();
$result = M('message')->where(array('send_time'=>array('gt',$lastReadTime),'touid'=>$uid))->count();
if($result){
$data = array(
'message' => $result,
);
echo json_encode($data);
exit();
} else {
usleep(1000);
exit();
//return;
}
}
session_write_close();
}
var cometURL ="{:U(GROUP_NAME.'/Comet/index')}"
$(function () {
(function longPolling() {
//alert(Date.parse(new Date())/1000);
$.ajax({
url: cometURL,
data: {"timed": Date.parse(new Date())/1000,"uid":$("#uid-hidden").val()},
dataType:"json",
timeout: 5000,
error: function (XMLHttpRequest, textStatus, errorThrown) {
if (textStatus =="timeout") {
longPolling();
} else {
longPolling();
}
},
success: function (data, textStatus) {
if(data.message != 0){
$(document.body).append("<i class='iconfont'style='position: fixed;top: 28px;right: 30px;color: #2fa8ec;font-size: 20px'>");
$("#messagenum").html('message('+data.message+')');
}
if(data.image != 0){
$(document.body).append("<i class='iconfont'style='position: fixed;top: 28px;right: 30px;color: #2fa8ec;font-size: 20px'>");
$("#imagenum").html('New Image('+data.image+')');
}
if (textStatus =="success") {
longPolling();
}
}
});
})();
});
我正在使用 THINKPHP 和 Jquery,你可以将其更改为你的方式。(AJAX LONG PULLING)。或者如果你的工作区在 linux 中,你可以使用 swoole 或 workerman 或 websocket 来制作。