webman能不能像前端那樣拿到stream流中的數(shù)據(jù)

原地起飛 更新于2024-05-29

類似這種前端可以輕易拿到data里面的值
webman有沒有什么方法實(shí)現(xiàn)呢有知道的大神還望不吝賜教

測試的代碼是

 public function c3(Request $request)
    {
        $http = new \Workerman\Http\Client();
        $result = [];
        $connection = $request->connection;
        $http->request('http://0.0.0.0:8806/api/Test/c5', [
            'method' => 'POST',
            'data' => json_encode([
                'stream' => true,
                'messages' => [['role' => 'user', 'content' => 'hello']],
            ]),
            'progress' => function($buffer) use ($connection,&$result) {
                var_dump($buffer);
                $result[] = $buffer;

            },
            'success' => function($response) use ($connection,&$result) {
                var_dump($result);
                //處理 result
                //處理邏輯
                //集中返回
                $connection->send(new Chunk($result));
                $connection->send(new Chunk(''));
            },
        ]);
        $connection->send(new Response(200, [
            //"Content-Type" => "application/octet-stream",
            "Transfer-Encoding" => "chunked",
        ], '123'));
    }

里面的東西打印不到有懂這個的麻煩給指點(diǎn)指點(diǎn) 還是我這么干本來就是錯的

 1357  4 1

4個回答

Gin 2024-05-29

http://wtbis.cn/q/10511

原地起飛 2024-05-29

我想讀取里面的數(shù)據(jù)整理好再發(fā)送出去要怎么實(shí)現(xiàn)呢
Gin 2024-05-29

參考 http://wtbis.cn/plugin/157
原地起飛 2024-05-29

參考這個我測試那不到內(nèi)容你有沒有做過這方面的給我示例代碼感謝

yongdao35 2024-05-29

http://wtbis.cn/doc/workerman/components/workerman-http-client.html

好像這個progress能拿到stream流

原地起飛 2024-05-29

好的我試一下
原地起飛 2024-05-29

還是拿不到不知道哪里的問題
yongdao35 2024-05-29

http://0.0.0.0:8806/api/Test/c5
0.0.0.0改成具體的ip
原地起飛 2024-05-30

改成127.0.0.1了也不行就是一請求立馬就結(jié)束了好像里面的代碼都沒走

Gin 2024-05-29

$http = new Client();
    $result = [];
    $http->request('https://api.ai.com/v1/chat/completions', [
        'method' => 'POST',
        'data' => json_encode([
            'model' => 'gpt-3.5-turbo',
            'temperature' => 1,
            'stream' => true,
            'messages' => [['role' => 'user', 'content' => 'hello']],
        ]),
        'headers' => [
            'Content-Type' => 'application/json',
            'Authorization' => 'Bearer sk-xxx',
        ],
        'progress' => function($buffer) use ($connection,&$result) {
            $result[] = $buffer;

        },
        'success' => function($response) use ($connection,&$result) {
            //處理 result  
            //處理邏輯
            //集中返回
            $connection->send(new Chunk($result));
            $connection->send(new Chunk(''));
        },
    ]);
    $connection->send(new Response(200, [
        //"Content-Type" => "application/octet-stream",
        "Transfer-Encoding" => "chunked",
    ], ''));

原地起飛 2024-05-29

感謝
原地起飛 2024-05-29

還是拿不到不知道哪里的問題

walkor 2024-05-30

打賞

    public function c3(Request $request)
    {
        $http = new \Workerman\Http\Client();
        $connection = $request->connection;
        $http->request('https://baidu.com', [
            'method' => 'POST',
            'data' => json_encode([
                'stream' => true,
                'messages' => [['role' => 'user', 'content' => 'hello']],
            ]),
            'progress' => function($buffer) use ($connection) {
                echo $buffer;
                $connection->send(new Chunk($buffer));
            },
            'success' => function($response) use ($connection) {
                $connection->send(new Chunk(''));
            },
        ]);
        return (new Response(200, [
            //"Content-Type" => "application/octet-stream",
            "Transfer-Encoding" => "chunked",
        ]));
    }

webman里代碼類似這樣