請問，webman能向瀏覽器發(fā)送流數(shù)據(jù)（多次發(fā)送數(shù)據(jù)）嗎

深林孤鷹 2023-02-18

問題描述

最近在研究openai的接口，它有一個steam功能，就是在curl時設置 CURLOPT_WRITEFUNCTION 屬性，可以不停的回調(diào)這個函數(shù)并輸出流到瀏覽器，官方示例差不多是這樣子：
$open_ai->completion($opts, function ($curl_info, $data) {
echo $data . "<br>"; //不停輸出數(shù)據(jù)
ob_flush();
flush();
return strlen($data);
});
用php原生，瀏覽器會不停的輸出數(shù)據(jù)，但webman的echo是輸出到控制臺的，所以請問如何在這個回調(diào)函數(shù)里向瀏覽器實時發(fā)送數(shù)據(jù)流呢？
謝謝各路大神駐留幫助~

 2632  1 12

1個回答

walkor 2023-02-23

打賞

webman SSE方案

參考 http://wtbis.cn/q/10107

以下是 webman Http Chunk 方案

創(chuàng)建 process/HttpChunk.php

<?php
namespace process;

use Workerman\Connection\TcpConnection;
use Workerman\Protocols\Http\Request;
use Workerman\Protocols\Http\Chunk;
use Workerman\Protocols\Http\Response;
use Workerman\Timer;

class HttpChunk
{
    public function onMessage(TcpConnection $connection, Request $request)
    {
        // 首先發(fā)送一個帶Transfer-Encoding: chunked頭的Response響應
        $total_count = 10;
        $connection->send(new Response(200, array('Transfer-Encoding' => 'chunked'), "共{$total_count}段數(shù)據(jù)<br>"));
        $timer_id = Timer::add(2, function () use ($connection, &$timer_id, $total_count){
            static $count = 0;
            // 連接關(guān)閉的時候要將定時器刪除，避免定時器不斷累積導致內(nèi)存泄漏
            if ($connection->getStatus() !== TcpConnection::STATUS_ESTABLISHED) {
                Timer::del($timer_id);
                return;
            }
            if ($count++ >= $total_count) {
                // 發(fā)送一個空的''代表結(jié)束響應
                $connection->send(new Chunk(''));
                return;
            }
            // 發(fā)送chunk數(shù)據(jù)
            $connection->send(new Chunk("第{$count}段數(shù)據(jù)<br>"));
        });
    }
}

config/process.php 怎加配置

<?php
return [
    // ... 其它配置 ...

    'http-chunk' => [
        'listen' => 'http://0.0.0.0:8585',
        'handler' => \process\HttpChunk::class,
    ]
];

瀏覽器訪問 http://127.0.0.1:8585 頁面會定時輸出數(shù)據(jù)