PHP SSE代理开发求助：如何实现Facebook API Server Sent Events的转发代理

看起来你的代码在处理SSE流的时候踩了几个常见的坑，我来帮你梳理问题并给出修复方案：

原代码的核心问题 #

• 输出缓冲未完全处理：只调用flush()可能不够，PHP默认有输出缓冲层，需要配合ob_flush()才能把内容真正发送到客户端。
• 流读取方式错误：stream_get_contents()会尝试一次性读取整个流，但SSE是持续的事件流，应该逐行读取并转发，否则会一直等待流结束（而SSE流通常是永久的）。
• 缺少可靠的客户端断开检测：原代码的connection_status()检测不够精准，应该用connection_aborted()来判断客户端是否已经关闭连接。
• 可能未正确传递API参数：你代码里的...url...需要包含完整的Facebook SSE端点（比如带access_token、指定字段等必要参数），否则请求会失败，自然没有数据返回。

修复后的完整代码 #

<?php
// 1. 设置正确的响应头，确保SSE格式和CORS支持
header('Content-Type: text/event-stream');
header('Cache-Control: no-cache, no-store, max-age=0, must-revalidate');
header('Access-Control-Allow-Origin: *');
header('X-Accel-Buffering: no'); // 禁用Nginx等反向代理的缓冲，非常重要！

// 禁用PHP自身的输出缓冲
ob_implicit_flush(true);
ob_end_flush();

// 替换为你的Facebook SSE完整请求URL（包含必要的access_token等参数）
$facebookSseUrl = 'https://streaming-graph.facebook.com/...';

// 2. 打开SSE流，设置超时避免无限等待
$handle = fopen($facebookSseUrl, 'r', false, stream_context_create([
    'http' => [
        'timeout' => 30, // 设置30秒超时，避免长时间无响应挂起
        'header' => 'Accept: text/event-stream' // 明确告诉服务器我们要SSE格式
    ]
]));

if (!$handle) {
    // 如果流打开失败，发送错误事件给客户端
    echo "event: error\n";
    echo "data: Failed to connect to Facebook SSE endpoint\n\n";
    exit;
}

// 3. 持续读取并转发SSE事件
while (!connection_aborted()) {
    // 逐行读取流内容，符合SSE的行分隔格式
    $line = fgets($handle);
    if ($line === false) {
        // 流读取失败或超时，等待1秒后重试
        usleep(1000000);
        continue;
    }

    // 直接转发读取到的内容
    echo $line;

    // 确保内容立即发送到客户端
    flush();
}

// 关闭流释放资源
fclose($handle);

关键修复点说明 #

• 彻底禁用缓冲：ob_implicit_flush(true)和ob_end_flush()关闭PHP的输出缓冲，加上X-Accel-Buffering: no可以防止Nginx等反向代理把内容缓冲起来，确保事件实时推送给客户端。
• 逐行读取流：fgets()每次读取一行，完美匹配SSE的事件格式（每个字段一行，空行分隔事件），避免一次性读取整个流导致的阻塞。
• 客户端断开检测：connection_aborted()会在客户端关闭页面或断开连接时返回true，此时循环终止，避免浪费服务器资源。
• 流超时设置：给HTTP请求设置超时，防止因为Facebook服务器无响应导致PHP进程一直挂起。

额外注意事项 #

• 确保服务器PHP配置允许allow_url_fopen（如果禁用了，需要用cURL代替fopen来打开流）。
• Facebook的SSE API通常需要有效的access_token，请确认你的请求URL包含了正确的认证参数，否则会返回401或403错误，自然没有数据返回。
• 某些服务器可能会限制长时间运行的PHP脚本，你可能需要调整max_execution_time或者使用set_time_limit(0)来允许脚本持续运行（注意服务器资源限制）。

内容的提问来源于stack exchange，提问作者Alexis C.