使用workerman http異步流式請求,消息長了,progress會拿到一半消息,如何處理?

954815278 更新于2025-03-25

$options = [
    'max_conn_per_addr' => 128,
    'keepalive_timeout' => 15,
    'connect_timeout' => 30,
    'timeout' => 600,
];
$client = new Client($options);
$client->request($uri, [
    'method' => 'POST',
    'version' => '1.1',
    'data' => json_encode($data),
    'headers' => [
        'Authorization' => "Bearer {$appKey}",
        'X-DashScope-SSE' => 'enable',
    ],
    'progress' => function ($buffer) use ($onMessage) {
        $this->debug && $this->stdoutLogger->info($buffer);
    },
]);

遇到問題

以上代碼的buffer有時候會是不完整的消息,我發(fā)現(xiàn)這個情況是出現(xiàn)在消息很長的情況下

錯誤數(shù)據(jù)

...內(nèi)，表明?

會出現(xiàn)這種數(shù)據(jù),消息短沒有問題,消息長了看起來應(yīng)該是不完整,請問如何處理?

 244  2 0

2個回答

walkor 2025-03-25

打賞

參數(shù)有個超時時間，設(shè)置長一些

954815278 2025-03-25

你好,walkor
我測了2次
出現(xiàn)不完整消息
1次出現(xiàn)在 72s
2次出現(xiàn)再 33s

但是被截斷的消息長度都是一樣的
2次用strlen($message),截斷時候長度均為1455

walkor 2025-03-25

打賞

buffer 本身就是收到的片段，不是完整的。
比如對方發(fā)來的數(shù)據(jù)是 ABCD, progress假設(shè)觸發(fā)了3次，那么三次buffer可能是這樣的 A BC D，每次都是一個片段，加起來是完整的 ABCD。
你要完整數(shù)據(jù)用 success 回調(diào)