请问，webman能向浏览器发送流数据（多次发送数据）吗

深林孤鹰 2023-02-18

问题描述

最近在研究openai的接口，它有一个steam功能，就是在curl时设置 CURLOPT_WRITEFUNCTION 属性，可以不停的回调这个函数并输出流到浏览器，官方示例差不多是这样子：
$open_ai->completion($opts, function ($curl_info, $data) {
echo $data . "<br>"; //不停输出数据
ob_flush();
flush();
return strlen($data);
});
用php原生，浏览器会不停的输出数据，但webman的echo是输出到控制台的，所以请问如何在这个回调函数里向浏览器实时发送数据流呢？
谢谢各路大神驻留帮助~

 1441  2 9

2个回答

北月 2023-02-18

可以搜索一下 sse（Server-sent events)，在 workerman 中可以采用定时器的方式来实现

深林孤鹰 2023-02-18

谢谢，不过我的是webman，是不是webman实现不了还得借助workerman来？
北月 2023-02-18

webman 属于 workerman 环境，也是一样的道理，做的时候需要保存链接，可以先搜索一下有一个 php-sse 的包，先看看他是如何实现的，然后自己改造一下，原理很简单
深林孤鹰 2023-02-19

好的谢谢~

walkor 2023-02-23

webman SSE方案

参考 https://www.workerman.net/q/10107

以下是 webman Http Chunk 方案

创建 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)
    {
        // 首先发送一个带Transfer-Encoding: chunked头的Response响应
        $total_count = 10;
        $connection->send(new Response(200, array('Transfer-Encoding' => 'chunked'), "共{$total_count}段数据<br>"));
        $timer_id = Timer::add(2, function () use ($connection, &$timer_id, $total_count){
            static $count = 0;
            // 连接关闭的时候要将定时器删除，避免定时器不断累积导致内存泄漏
            if ($connection->getStatus() !== TcpConnection::STATUS_ESTABLISHED) {
                Timer::del($timer_id);
                return;
            }
            if ($count++ >= $total_count) {
                // 发送一个空的''代表结束响应
                $connection->send(new Chunk(''));
                return;
            }
            // 发送chunk数据
            $connection->send(new Chunk("第{$count}段数据<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 页面会定时输出数据