如何在 Laravel 中使用分块传输编码？

Question

美好的一天。我想知道我是否可以在 API 响应中使用分块传输编码（进一步的 CTE）？我在数据库中有大量数据，我需要在一个请求中将其传输给客户端。我已经阅读了很多关于 CTE 机制的内容，但很遗憾，我找不到如何实现这一点。

要提到的重要一点：没有分页。它应该是一个自治系统，将数据返回到客户端的端点，而不是返回到网页。

正如我所提到的，数据存储在数据库中。唯一的问题是如何将数据拆分成段（块）并在一个 API 响应中（一个接一个）发送。

谢谢。

Answer 1

在我的具体情况下，我通过使用以下代码（示例）解决了我的问题：

use Symfony\Component\HttpFoundation\StreamedResponse;

$response = new StreamedResponse();
$response->setCallback(function () {
    var_dump('Hello World');
    flush();
    sleep(2);
    var_dump('Hello World');
    flush();
});
$response->send();

Answer 2

我想你可能对查询生成器上的 chunk 方法感兴趣。

分块结果

如果您需要处理数千条数据库记录，请考虑使用 块方法。此方法检索一小部分结果 一次并将每个块馈送到闭包中进行处理。这 方法对于编写处理的 Artisan 命令非常有用 数千条记录。例如，让我们与整个用户一起工作 一次包含 100 条记录的表：

$response = new \Symfony\Component\HttpFoundation\StreamedResponse(function() {
    $handle = fopen('php://output', 'w');

    DB::table('users')->orderBy('id')->chunk(100, function ($users) use($handle) {
        foreach ($users as $user) {
            fputs($handle, json_encode($user));
        }
    });

    fclose($handle);
});

return $response;

延伸阅读：https://laravel.com/docs/master/queries#chunking-results

分块传输编码

据我所知，如果您返回 JSON 响应，Laravel does this by default。

更新：

我的解决方案过于复杂和复杂。我已经删除了StreamedResponse，因为真的不需要它。请参阅下面的更新示例。

$json_response = collect();

DB::table('users')->orderBy('id')->chunk(100, function ($users) use($json_response) {
    foreach ($users as $user) {
        $json_response->push($user);
    }
});

return $json_response->toJson();