如何解决PHP大数据量JSON编码内存溢出问题，violet/streaming-json-encoder助你轻松搞定

json_encode()

json_encode()

Allowed memory size of X bytes exhausted

violet/streaming-json-encoder

violet/streaming-json-encoder

violet/streaming-json-encoder

<pre class="brush:php;toolbar:false;">composer require "violet/streaming-json-encoder:^1.1"

require 'vendor/autoload.php';

violet/streaming-json-encoder

BufferJsonEncoder

Iterator

<pre class="brush:php;toolbar:false;"><?php

require 'vendor/autoload.php';

use Violet\StreamingJsonEncoder\BufferJsonEncoder;

// 模拟一个从数据库或其他源获取大量数据的生成器
// 实际应用中，这里会是你的数据库查询结果迭代器或其他数据源
function fetchDataGenerator($count) {
    for ($i = 0; $i < $count; $i++) {
        yield [
            'id' => $i + 1,
            'name' => 'Item ' . ($i + 1),
            'description' => 'This is a description for item ' . ($i + 1) . '.',
            'timestamp' => microtime(true)
        ];
        // 模拟每次获取数据可能存在的延迟
        // usleep(100); 
    }
}

// 创建 BufferJsonEncoder 实例，传入生成器
// 假设我们需要处理10万条数据，如果用json_encode()，很可能内存溢出
$encoder = new BufferJsonEncoder(fetchDataGenerator(100000)); 

// 设置美化输出选项，方便阅读。在生产环境中通常会省略以减小输出大小。
$encoder->setOptions(JSON_PRETTY_PRINT);

// 设置响应头，告知客户端返回的是 JSON 数据
header('Content-Type: application/json'); 

// 逐块输出 JSON
foreach ($encoder as $jsonChunk) {
    echo $jsonChunk;
    // 在某些Web服务器配置下，可能需要手动调用 flush() 来强制立即发送缓冲区内容
    // 但大多数情况下，Web服务器会自动处理，尤其是在响应头设置正确时
    // flush(); 
}

// 如果需要记录内存使用，可以在这里查看峰值内存使用情况
// echo PHP_EOL . 'Peak memory usage: ' . round(memory_get_peak_usage() / 1024 / 1024, 2) . ' MB';

?>

fetchDataGenerator

yield

BufferJsonEncoder

foreach

violet/streaming-json-encoder

StreamJsonEncoder

JsonStream

StreamJsonEncoder

JsonStream

violet/streaming-json-encoder

violet/streaming-json-encoder