关于（SSE: Server-Sent Events）的代码实现

本贴结合分享和问答，由问答贴 Laravel + SSE（Server-Sent Events）消息未连续发送转化
（原帖由于问题定位不明以及多次编辑，导致逻辑有些混乱）

结论

实现：在纯 PHP 代码和 Laravel 代码都可实现；

运行：builtin-server (php -S) 可行，Nginx 可行，Apache 不正常

实现代码

前端

query();
function query() {
    if (!window.EventSource) {
        alert("浏览器不支持 EventSource");
        return;
    }

    var eventSource = new EventSource("/");

    eventSource.onopen = function (e) {
        console.log("onEventSourceOpen")
    }
    eventSource.onmessage = function (e) {
        console.log("onEventSourceMessage: " + e.data);
    }
    eventSource.onerror = function (e) {
        console.log("onEventSourceError: ", e);
    }
}

后端

后端代码仅在 php -S 和 Nginx 测试通过，Apache 方式暂未测试通过

PHP

header("Cache-Control: no-cache");
header("Content-Type: text/event-stream");
header("Connection: keep-alive");
header("X-Accel-Buffering: no");

while (true) {
    if(connection_aborted()) exit();

    $ts = microtime(true);

    // echo str_repeat("\n", 100000);
    echo "event: message\ndata: $ts\nid: $ts\n\n";

    ob_end_flush(); // 或 ob_flush()
    flush();

    sleep(1);
}

Laravel

// 这里加 return 或者末尾加 ->send() 都可以
return (new \Symfony\Component\HttpFoundation\StreamedResponse(function () {
    while (true) {
        if (connection_aborted()) return;

        $ts = microtime(true);
        echo str_repeat("\n", 50000);
        echo "event: message\ndata: $ts $ts\nid: $ts\n\n";

        // Laravel 中不加以下两个 flush 也能测试成功
        ob_flush();
        flush();

        sleep(1);
    }
}, 200, [
    "Content-Type" => "text/event-stream",
    "Cache-Control" => "no-cache",
    "Connection" => "Keep-Alive",
    "X-Accel-Buffering" => "no",
]))->send();