workerman websocket协议 send 怎么流式发送数据，为什么都是一起返回的

问题描述

workerman websocket协议 send 怎么流式发送数据，为什么都是一起返回的；
windows 本地测试正常，可以流式输出， linux 服务器上不行， 都是一起输出的。

为此你搜索到了哪些方案及不适用的原因

<?php
use Workerman\Connection\TcpConnection;
use Workerman\Worker;
use Workerman\Lib\Timer;
use Workerman\Protocols\Http\Request;
require_once __DIR__ . '/vendor/autoload.php';

$worker = new Worker('websocket://0.0.0.0:5556');
//$worker = new Worker('websocket://0.0.0.0:5556', ['ssl' => ['local_cert' => __DIR__."/dm299.pem", 'local_pk' => __DIR__."/dm299.key", 'verify_peer' => false]]);
//$worker->transport = 'ssl';

$worker->onMessage = function(TcpConnection $connection, $data) {

$url = 'https://demo.xxxxxxxxxxxx.com/ai.php';
$postData = []; // 假设这是你要发送的数据
$headers = [];  // 假设这是你的请求头

// 定义回调函数，并通过 use 关键字传递 $connection
$writeCallback = function($ch, $data) use ($connection) {
    // 处理接收到的数据块
    $length = strlen($data); // 获取数据块的长度
    $connection->send($data."<br>",true); // 将数据发送给客户端
    return $length; // 返回处理的数据长度
};

// 发起 cURL 请求
$response = curlPost($url, json_encode($postData), $headers, $writeCallback);

// 检查是否有错误
if (isset($response['error'])) {
    $connection->send("请求失败: " . $response['error']['message']);
} else {
    $connection->send("传输完成");
}

};

function curlPost($url, $params, $headers = [], $writeCallback = null) {
$ch = curl_init();
curl_setopt($ch, CURLOPT_URL, $url);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
curl_setopt($ch, CURLOPT_HEADER, false);
curl_setopt($ch, CURLOPT_FOLLOWLOCATION, true);
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
curl_setopt($ch, CURLOPT_HTTP_VERSION, CURL_HTTP_VERSION_1_1);
curl_setopt($ch, CURLOPT_POSTFIELDS, $params);
curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);

// 如果提供了回调函数，则设置 CURLOPT_WRITEFUNCTION
if ($writeCallback) {
    curl_setopt($ch, CURLOPT_WRITEFUNCTION, $writeCallback);
}

curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 120); // 连接超时时间
curl_setopt($ch, CURLOPT_TIMEOUT, 120);        // 请求超时时间

$response = curl_exec($ch);
if (curl_errno($ch)) {
    return ['error' => ['message' => curl_error($ch)]];
}
curl_close($ch);
return $response;

}

Worker::runAll();
?>