我正在尝试使用服务器发送事件从数据库中获取信息并更新我的html页面,一条新消息立即进入,这些是我的代码
function update()
{
if(typeof(EventSource) !="undefined")
{
var source=new EventSource("update.php");
source.onmessage=function(event)
{
$scope.my_messages=JSON.parse(event.data)
}
}
}
update();
<div ng-repeat="x in my_messages">
<div>{{x.sender_username}}</div>
<div>{{x.title}}</div>
<p>{{x.messages}}</p>
</div>
在update.php,我有这个
<?php
include 'first.php';
$newUser= new Participant();
$newUser->connect();
$newUser->call_new_message();
?>
首先,我有这个
public function call_new_message()
{
$sender=$_SESSION['username'];
$receiver=$_SESSION['receiverUsername'];
$a = mysqli_query($this->con, "SELECT * from messages_tb WHERE sender_username= '$sender' and receiver_username='$receiver' ");
if ($a) {
$s=$a->fetch_all(MYSQLI_ASSOC);
header('Content-Type: text/event-stream');
header('Cache-Control: no-cache');
echo"data:".json_encode($s)."\n\n";
flush();
// echo json_encode($s);
}
else{
echo "An error occurred";
}
}
它工作得很好,只是我希望它能在html页面的div中更新数据,当一条新消息出现在消息\u tb中时,但它不是那样工作的,我必须刷新页面才能在div中获得新消息。请,帮助。谢谢
1条答案
按热度按时间iezvtpos1#
我想加上
$scope.$apply()
在on scope()中。消息处理程序应该适合您。原因是,angular可能不知道纯java脚本更新数据。所以你可以告诉angular更新范围。