8

经过一周的谷歌搜索和搜索。我什至很难找到一个关于从数据库表而不是从名为 data.text 的平面文本文件中进行长轮询的教程。目前,我在 data.text 中手动编写任何内容,它会立即出现在浏览器中。

这就是问题:使用数据库进行长轮询?即使在 StackOverflow 中也没有正确回答。(我在这里找到了很多,但徒劳无功。)这个例子也是 MySQL 的 filemtime 替代品

如何修改 getdata.php 以使其能够从数据库中获取数据?

 $sql=mysqli_query($database,"SELECT * FROM messages  where time>=$curr_date ORDER by      time DESC");
  while($row=mysqli_fetch_array($sql)){
    $messages=$row['messages'];
    $id=$row['id'];
    echo $messages;
  }

消息表如下

    id     fro   to  mesg      time  status  last_modified  

我在这里列出一个例子。在此示例中,使用了三个文件。

  1. 索引.html
  2. 获取数据文件
  3. 数据.文本

是否需要制作第四个文件来从数据库(mysql)获取数据?如果不是,那么在 getdata.php 或 data.text 中需要进行哪些类型的更改才能使用数据库中的动态数据?

这是我的 Javascript

<script type="text/javascript" charset="utf-8">

        var timestamp = null;

        function waitformsg() {
            $.ajax({
                type:"Post",
                url:"getdata.php?timestamp="+timestamp,
                async:true,
                cache:false,
                success:function(data) {
                    var json = eval('(' + data + ')');
                    if(json['msg'] != "") {
                        $("#messages").append(json['msg']);

                    }
                    timestamp = json["timestamp"];

                    setTimeout("waitformsg()", 1000);
                },
                error:function(XMLhttprequest, textstatus, errorthrown) {
                    alert("error:" + textstatus + "(" + errorthrown + ")");
                    setTimeout("waitformsg()", 15000);
                }




                });

        }
        $(document).ready(function() {

            waitformsg();
        });
    </script>

这是 getdata.php 文件

<?php
include("../model/includes/classes.php");

$filename='data.php';

$lastmodif=isset($_GET['timestamp'])?$_GET['timestamp']:0;
$currentmodif=filemtime($filename);

while($currentmodif<=$lastmodif){
    usleep(10000);
    clearstatcache();
    $currentmodif=filemtime($filename);
}

$response=array();
$response['msg']=file_get_contents($filename);
$response['timestamp']=$currentmodif;
echo json_encode($response);
?>
4

1 回答 1

3

我最近做了一些非常相似的事情。我确实使用了 jQuery .ajax 调用而不是通用的 XMLhttprequest,但想法是一样的:

recentFunction(container, lastDate){
    var lastDate = "";

    return $.ajax({
        type: "POST",
        url: "getData.php",
        cache: false,
        data: { 'request': 'recent',
            'param': lastDate },
        dataType: "json",
        success: function(data){
            if(data != null){
                $.each(data, function(key, value){
                    if(key == 0){
                        lastDate = value['date_added'];
                    }
                    var html = "some html here";
                    // append html to dom element here
                                // and delete any old items here if needed
                });
            }
        },
        complete: function(){
            setTimeout(function(){recentFunction(container, lastDate)}, 7000);
        }
    });
}

getData.php文件中,我使用 where 子句进行查询,该子句从 db 中获取比最后一个元素更新的任何项目。$lastDate 的默认值设置为 0,因此如果没有提交日期,它将返回所有项目。

<?php

$lastDate = 0;
$recent = array();
$recentQuery = "SELECT id, date FROM someTable WHERE date > '" . $lastDate . "'";
$recentResults = $db->query($recentQuery);

while($r = $recentResults->fetch_array(MYSQLI_ASSOC)){
      $recentMovies[] = $r;
}

echo json_encode($recentMovies);

?>
于 2012-12-01T00:48:18.100 回答