个人中心
gpt4 book ai didi

PHP 和事件 - 在脚本终止之前不会发生刷新到客户端

转载 作者：行者123 更新时间：2023-12-02 03:09:42 26 4
gpt4 key购买 nike

我正在尝试创建一个将事件发送到网页的简单页面，但在页面终止之前我无法让 PHP 发送输出。

我正在使用 PHP-FPM 和 php5.6.27。

这是我的简单 HTML 页面:

<html>
    <head>
        <title>test events</title>
    </head>
    <body>
        testing events
        <ul id="pingEventList" style="float: left"></ul>
        <ul id="messageEventList" style="float: left"></ul>
        <script>
            var evtSource=new EventSource("./s_events.php?auth=e3b164ef33d802c45da829b8f1240d16");
            var pingEventList=document.getElementById('pingEventList');
            var messageEventList=document.getElementById('messageEventList');
            evtSource.onmessage=function (e){
                var newElement=document.createElement("li");
                newElement.innerHTML="message: "+e.data;
                messageEventList.appendChild(newElement);
            };
            evtSource.addEventListener("initial", function (e){
                var newElement=document.createElement("li");
//              var obj=JSON.parse(e.data);
                newElement.innerHTML="initial info "+e.data;
                console.log("initial info "+e.data);
                pingEventList.appendChild(newElement);
            }, false);
            evtSource.addEventListener("modified", function (e){
                var newElement=document.createElement("li");
//              var obj=JSON.parse(e.data);
                newElement.innerHTML="modified info "+e.data;
                console.log("modified info "+e.data);
                pingEventList.appendChild(newElement);
            }, false);
            evtSource.onerror=function (e){
                console.log("EventSource failed.", e);
//              while(pingEventList.firstChild){
//                  pingEventList.removeChild(pingEventList.firstChild);
//              }
//              alert("EventSource failed.");
            };
//          evtSource.close();
        </script>
    </body>
</html>

这是我的 PHP 页面: 
<?php

@set_time_limit(0); // Disable time limit
// Prevent buffering
if(function_exists('apache_setenv')){
    @apache_setenv('no-gzip', 1);
}
@ini_set('zlib.output_compression', 0);
@ini_set('implicit_flush', 1);
while(ob_get_level() !=0){
    ob_end_flush();
}
ob_implicit_flush(1);
ignore_user_abort(false);
header('Access-Control-Allow-Origin: *');
header('Access-Control-Allow-Credentials: true');
header('Content-Type: text/event-stream');
header('Cache-Control: no-cache'); // recommended to prevent caching of event data.
header('X-Accel-Buffering: off'); // Disables FastCGI Buffering on Nginx
$sleep_time          = 1; //0.5  // seconds to sleep after the data has been sent
$exec_limit_time     = 15; //600;  // the time limit of the script in seconds
$keep_alive_time     = 30; //300;  // The interval of sending a signal to keep the connection alive
$client_reconnect    = 1;  // the time client to reconnect after connection has lost in seconds
$keep_alive_start    = time();
$exec_limit_start    = time();


$ts_last_used    = intval(isset($_SERVER["HTTP_LAST_EVENT_ID"])?$_SERVER["HTTP_LAST_EVENT_ID"]:0);
echo 'retry:'.($client_reconnect*1000)."\n";
$event           = [
    'id'     => $ts_last_used++,
    'event'  => 'initial',
    'data'   => "[\ndata:".'INITIAL DATA'."\ndata:]",
];
_send_event_data($event);
while(1){
    // Did the connection fail?
    if(connection_status() !=CONNECTION_NORMAL){
        break;
    }else{
        $event = [
            'id'     => $ts_last_used++,
            'event'  => 'modified',
            'data'   => '{"id":"stuff here too"}',
        ];
        _send_event_data($event);
    }
    // Sleep for x seconds
    usleep($sleep_time*1000000);
    if($exec_limit_start+$exec_limit_time<time()){
        break;
    }
    if($keep_alive_start+$keep_alive_time<time()){
        $keep_alive_start = time();
        echo ': '.sha1(mt_rand())."\n\n";
    }
}
// If this is reached, then the 'break'
// was triggered from inside the while loop
//
// So here we can log, or perform any other tasks
// we need without actually being dependent on the
// browser.

function _send_event_data($info){
    global $keep_alive_start;
    if(isset($info['id'])){
        echo 'id:'.$info['id']."\n";
    }
    if(isset($info['event'])){
        echo 'event:'.$info['event']."\n";
    }
    echo 'data:'.$info['data']."\n";
    if(!isset($info['more_to_come'])||!$info['more_to_come']){
        echo "\n";
    }
    $keep_alive_start = time();
    @ob_end_flush();
    flush();
}

我尝试了各种可能的解决方案，但我无法弄清楚。我还将 PHP-FPM 更改为 mod_php(我正在使用 apache)，以防万一它是 PHP_FPM，但我没有成功。

我愿意接受建议

最佳答案

我想通了......它是保存输出的 apache，这是我对 fast-cgi 使用 php-fpm 的新配置:

<IfModule fastcgi_module>
   #php-fpm
   AddHandler php5-fcgi .php .html
   Action php5-fcgi /php5-fcgi
   Alias /php5-fcgi /usr/local/www/cgi-bin/php5-fcgi
   FastCgiExternalServer /usr/local/www/cgi-bin/php5-fcgi -flush -socket /var/run/php-fpm.sock -pass-header Authorization -idle-timeout 600
   <Directory /usr/local/www/cgi-bin>
       Require all granted
   </Directory>
</IfModule>

与众不同的是 -flush添加到 FastCgiExternalServer ，现在输出不再缓冲，它立即输出(感谢这个页面，我能够找到答案: http://www.jeffgeerling.com/blog/2016/streaming-php-disabling-output-buffering-php-apache-nginx-and-varnish)

关于PHP 和事件 - 在脚本终止之前不会发生刷新到客户端，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/40661277/

26 4 0
文章推荐： angularjs - 在 shadow dom 中运行 Angular 应用程序
文章推荐： build - 如何在 "visual studio team services"中使用来自多个 "Team Projects"的源代码创建构建定义？
文章推荐： sql - 更新触发器仅在数据更改时更新
文章推荐： logging - tensorflow log_softmax tf.nn.log(tf.nn.softmax(predict)) tf.nn.softmax_cross_entropy_with_logits
行者123
个人简介

我是一名优秀的程序员,十分优秀！

滴滴打车优惠券免费领取
滴滴打车优惠券
全站热门文章
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com