用 Livewire 的 wire:stream 开发流式聊天机器人（Server-sent events, 百度文心一言）

我是直接用guzzle包请求，然后自己解析出结果直接返回给客户端的，目前用了半年多了，没出问题。
关键代码：

header('Content-Type: text/event-stream'); // 以事件流的形式告知浏览器进行显示
header('Cache-Control: no-cache');         // 告知浏览器不进行缓存
header('X-Accel-Buffering: no');           // 关闭加速缓冲
// 省略部分代码.......
$body = $response->getBody();
$buffer = '';
while (!$body->eof()) {
    $buffer .= $body->read(128);
    // 这里使用while是因为读取n个字节有可能同时读出n条 EventSource 消息
    while (($pos = strpos($buffer, "\n\n")) !== false) {
        $msg = substr($buffer, 0, $pos); // 一条event消息
        $buffer = substr($buffer, $pos + 2); // 去除已被解析的部分

        if (substr($msg, 0, 6) === 'data: ') { // 只解析了data，实际的EventSource还有 event、id、retry
            $obj = json_decode(substr($msg, 6));
            if (isset($obj->choices[0]->delta->content)) {
                echo $obj->choices[0]->delta->content;
                ob_flush();
                flush();
            }
        }
    }
}

我装了 Pulse 和 Telescope，可以公开访问：

• learn-qianfan-livewire.xuchunyang.... Pulse 监控面板
• learn-qianfan-livewire.xuchunyang.... Telescope 异常面板

之前写过一个通用的 sse 类 app/Support/Sse/ServerSentEvent.php，可方便的单独使用或者配合 symfony 的流响应类使用。