这是我的sse_server.php文件

include_once 'server_files/init2.php'; //this file includes the connection file to the database and some functions

header('Content-Type: text/event-stream');
header('Cache-Control: no-cache');

$assocArray = array();

$fetch_article = $dbh->prepare("SELECT 
                                        article_author_id, 
                                        article_author_un,
                                        article_id, 
                                        article_cover,
                                        article_title,
                                        article_desc
                                    FROM articles ORDER BY article_id DESC");
$fetch_article->execute();

while ($fetch = $fetch_article->fetch(PDO::FETCH_ASSOC)) 
{
    $article_author_id    = $fetch['article_author_id'];
    $article_author_u     = $fetch['article_author_un'];
    $article_id           = $fetch['article_id']; 
    $article_cover        = $fetch['article_cover'];
    $article_title        = $fetch['article_title'];
    $article_desc         = $fetch['article_desc'];


    $randomNum = rand(0,500);

    //Insert the Random Number along with the article's info | Random Number as a Value and the contents as a Key
                $assocArray[
                            'randomNum'.'|'.                    //0
                            $article_author_id.'|'.             //1
                            $article_author_u.'|'.              //2
                            $article_id.'|'.                    //3
                            $article_cover.'|'.                 //4
                            $article_title.'|'.                 //5
                            $article_desc                       //6

                            ]  = $randomNum;
}

//sort the array
arsort($assocArray, 1); 
//echo '<pre>';
//print_r($assocArray);

//while(true){

    $var = '';
    foreach ($assocArray as $key => $value) {

        $var .=  $value .' => ' . $key . '`|||`<br>';
    }
    echo "retry: 6000\n";
    echo "data: {$var}\n\n";
    ob_flush();
    flush();

//}

这就是我如何处理 client.php 文件中的数据

    <div id="feeds"></div>
    <script>

        if(typeof(EventSource)!=="undefined") {

            var eSource = new EventSource("sse_server.php");


            //detect message received
            eSource.addEventListener('message', function(event) {


            var jsV_feeds = event.data;
            var eventList = document.getElementById("feeds");


            var jsV_feedsArray = jsV_feeds.split('`|||`');  //Seperator



            eventList.innerHTML = jsF_ToFetch(jsV_feedsArray); 

            }, false);
        }
        else {
            document.getElementById("feeds").innerHTML="Whoops! Your browser doesn't receive server-sent events.";
        }


        function jsF_ToFetch(jsP_array) 
        {
            var string = ''; //an empty string 
            for (var i = 0; i < jsP_array.length-1; i++) 
            {

                jsV_Feed = jsP_array[i].split('|');

                jsV_randomNum           = jsV_Feed[0];
                jsV_article_author_id   = jsV_Feed[1];
                jsV_article_author_u    = jsV_Feed[2];
                jsV_article_id          = jsV_Feed[3];
                jsV_article_cover       = jsV_Feed[4];
                jsV_article_title       = jsV_Feed[5];
                jsV_article_desc        = jsV_Feed[6];


                string += jsV_randomNum +'<li><b>'+jsV_article_author_u+'</b><!--process the rest in a similar way--> </li>';


            } // for loop ENDS here
            return '<ol>' + string + '</ol>';
        }

    </script>

问题是如果我只使用 foreach 循环，它每 6 秒重新连接一次。
如果我将 foreach 包装在 while 循环中，它会保持连接处于事件状态，但继续发送数据。这最终会在几秒钟内加载大量数据。它还使通过另一个页面同时执行的 AJAX Post 请求非常慢。

为什么会这样？
我怎样才能让它保持连接打开、不发送数据并且不减慢 AJAX post 请求。

PS:我访问过这些链接-
http://www.html5rocks.com/en/tutorials/eventsource/basics/
PHP Event Source keeps executing

可能是我对它们的理解不够透彻。如果可以将其归结为更简单的术语，请这样做!

提前致谢!

最佳答案

您想使用在 sse_server.php 中注释掉的 while(true){} 循环。您的 SSE 脚本永远不应该退出(直到套接字关闭，这将在客户端发生，即您的 JavaScript 脚本关闭它，或关闭浏览器窗口)。

使用 while 循环时遇到问题的原因是 while 循环内没有 sleep() 或等待操作。因此，您正在以最大速率向客户端发送数据(一遍又一遍地发送相同的数据!)。

从概念上讲，我猜您想要的是这段代码:

$lastID = 0;
while(true){
  $fetch_article = $dbh->prepare("SELECT something FROM somewhere WHERE conditions AND articleID > ?");
  $results = $fetch_article->execute($lastID);
  if(has 1+ results) {
     foreach($results){
        echo result formatted for SSE
        $lastID = ...;
     }
     flush();ob_flush();
  }
  sleep(5);
}

这是说它将每 5 秒轮询一次数据库以获取新记录。如果没有新记录，它什么都不做——只是再睡 5 秒。但如果有新记录，它会将它们通过 SSE 推送给客户端。

您可以调整 5 秒 sleep 以找到服务器 CPU 使用率和延迟之间的平衡。更短的 sleep 意味着更低的延迟(您的客户端更快地获取新数据)，但服务器上的 CPU 更高。

旁白:上面的lastID 方法只是检测您已经看到和还没有看到哪些记录的某种方法。如果您的表中有一个唯一的 ID 就好了，它是 AUTO_INCREMENT。但是，或者，如果使用 created 时间戳插入数据库记录，则查询变为:

$now = 0;
while(true){
    $stmt = prepare( "SELECT ... AND created > ?" );
    $stmt->execute( $now );
    $now = time();
    ...process results ...
    sleep(5);
}

(稍微安全一点的是将 $now 设置为在结果中找到的最大 created 时间戳，而不是为每个 time()时间；否则记录可能会漏掉而无法发送给客户。)

关于javascript - SSE 加载大量数据并使 AJAX post 请求瘫痪，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/30174557/