我希望在我的社交网站上实现实时通知更新。我对 cometd 做了一些研究，我真的很着迷。

据我所知，这是 cometd 服务器上发生的事情的基本流程。

Webpage: 
Sends an ajax request to server when the document is ready. 

Server:
Queries the database every x amount of seconds and returns a json string containing results if any are found.

Webpage:
Receives the result of the json string from the server and sends out another ajax request  to do the above process again.

通过了解 comet 的工作流程，我编写了一些 PHP 和 Javascript 代码。

JavaScript 代码使用 jQuery 库，并以 unix 时间戳格式将当前时间作为 GET 参数发送到服务器。

    $(document).ready(function(){
       var timestamp = Math.round(new Date().getTime() / 1000);

        function comet2(){
            $.ajax({
                type : 'GET',
                url  : 'comet.activities.php?timestamp=' + timestamp,
                async : true,
                cache : false,

                success : function(data) {
                    alert("current timestamp "+timestamp)

                    var json = JSON.parse(data);
                    if(json !== null){
                        alert(data);
                    }

                    timestamp  = json[0].timestamp;
                    setTimeout('comet2()', 1000);

                },
                error : function(XMLHttpRequest, textstatus, error) { 
                    setTimeout('comet2()', 15000);
                }       
            });
        }

        //call the comet function because the page has loaded.
        comet2();

    });

PHP 代码将通过使用时间戳参数(在本例中为查询中的 unix 时间戳)在数据库中搜索新行来查询新事件。对于此示例，我已将结果数量限制为 1。

<?php 
    set_time_limit(0);
    include("models/config.php");
    global $mysqli,$db_table_prefix;

    $last = isset($_GET['timestamp']) ? $_GET['timestamp'] : 0;
    $results = null;
    $flag=true;

    $stmt = $mysqli->prepare("SELECT id,timestamp FROM uc_user_activity WHERE timestamp > ? ORDER BY timestamp DESC LIMIT 0,1");
    $stmt->bind_param("i", $last);
    $stmt->bind_result($id,$timestamp);

    while($flag){
        $stmt -> execute();    

        while ($row = $stmt->fetch()){
            $flag = false;
            $results[] = array(
                "id" => $id,       
                "timestamp" => $timestamp  
            );
        }

        $stmt -> close();  

        usleep(100000);
        clearstatcache();
    }

    echo json_encode($results);    

?> 

上面的代码实际上并没有“工作” 问题是，如果用户发布了一条新评论，那么当 comet 脚本运行时，它将无法添加到数据库中。这意味着 comet 脚本永远不会返回任何 json 结果，因为永远不会满足 sql 查询中的语句(没有添加具有更新时间戳的新事件)。我用于发布新评论的 ajax 代码 100% 正常工作，所以我知道这不是问题所在。只是“什么都没有发生”，也就是说 - 没有任何(没有错误)被警告或输出到浏览器控制台。

编辑编号 3: 我非常努力地解释我所说的“什么都没发生”是什么意思，所以我上传了一张图片，显示当从 jquery 调用 comet 脚本时数据库插入失败(注意在评论时文本框是如何被禁用的通过 ajax 发布)。

我该怎么办？我花了几个小时在互联网上搜索试图解决这个问题/找到一个类似的工作示例但无济于事。

如果我将 PHP 代码中的查询更改为:

$stmt = $mysqli->prepare("SELECT id,timestamp FROM uc_user_activity WHERE timestamp **<** ? ORDER BY timestamp DESC LIMIT 0,1");

代替:

 $stmt = $mysqli->prepare("SELECT id,timestamp FROM uc_user_activity WHERE timestamp > ? ORDER BY timestamp DESC LIMIT 0,1");

结果立即提醒到浏览器窗口，可以再次发布评论，再次调用脚本并显示新帖子。这表明我的代码毕竟“工作正常”并且看起来查询导致了问题......

谁能看到这里发生了什么？我现在已经对这个问题进行了 7 次编辑，任何指导都会很棒，因为我一无所获。

只是为了让这不会结束，这里是我的问题来总结我上面讨论的内容:

Are there any better ways of implementing a comet server? I'm not the most experienced guy ever, but I would really like to learn how to do this. It seems StackOverflow has this functionality and it works perfectly - how are they doing it?

我不可能写出比这更详细的帖子，我真的很感谢你们这些了不起的人提供的指导。关于为什么我的代码“不工作”的建议或任何解释如何实现它的教程的链接将是惊人的!提前感谢并为这个怪物问题和所有编辑道歉!

最佳答案

我的预感是您传递的时间戳值不会返回任何结果。您可以通过 Javascript 获取当前时间。查询查询此时间戳后的所有帖子。

您能否尝试打印查询并手动运行相同的查询以确保它从数据库中检索数据？

关于php - 使用 comet 和 PHP 进行实时数据更新？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/15869519/