Integrasi PHP dan pemprosesan aliran data

Dengan peningkatan berterusan keperluan pemprosesan data dan pempopularan aplikasi data besar, teknologi pemprosesan aliran data telah digunakan secara meluas sejak beberapa tahun kebelakangan ini. Tujuan teknologi pemprosesan aliran data adalah untuk memproses data dalam masa nyata dalam aliran data dan untuk menjana hasil aliran data baharu secara serentak semasa proses pemprosesan. PHP ialah bahasa pengaturcaraan web yang sangat popular yang menyokong pemprosesan data, dan selepas versi PHP7.0, ia telah memperkenalkan beberapa ciri baharu untuk memenuhi keperluan pemprosesan aliran data, seperti Penjana, Penutupan, Petunjuk Jenis, dsb. Artikel ini akan memperkenalkan cara PHP disepadukan dengan teknologi pemprosesan aliran data.

1. Apakah pemprosesan aliran data?

Ringkasnya, pemprosesan aliran data ialah teknologi untuk memproses aliran data Ia adalah cara memproses data dalam masa nyata, ia boleh memproses data berterusan daripada pelbagai sumber. Hasil pemprosesan pemprosesan aliran data boleh dihantar terus ke nod pemprosesan hiliran atau berterusan ke peranti storan.

2. Bagaimanakah PHP melaksanakan pemprosesan aliran data?

Dalam versi sebelumnya, PHP tidak dapat mengendalikan data strim secara langsung dan pembangun hanya boleh beroperasi melalui perpustakaan dalam bahasa lain. Tetapi selepas versi PHP7.0, PHP memperkenalkan Penjana, Penutupan dan ciri-ciri lain, membolehkan PHP menyokong pemprosesan aliran data.

1. Penjana

Penjana ialah salah satu ciri baharu PHP Ia boleh menyediakan kaedah yang lebih fleksibel untuk menjana iterator aliran. Pertimbangkan contoh berikut:

function dataGenerator($n){
    for($i=0;$i<$n;$i++){
        yield $i;
    }
}

$data = dataGenerator(10);
foreach($data as $entry){
    echo $entry.PHP_EOL;
}

Melalui kod di atas, kita dapat melihat bahawa jujukan titik data yang dijana oleh fungsi dataGenerator boleh diproses sebagai aliran data. Kelebihan menggunakan fungsi Penjana untuk mengendalikan aliran data ialah ia boleh mengoptimumkan penggunaan memori dan mengurangkan overhed memori semasa memproses set data.

2. Penutupan

Penutupan ialah satu lagi ciri baharu PHP Ia adalah fungsi tanpa nama yang boleh menangkap pembolehubah yang ditakrifkan dalam skop luaran, dan kemudian semasa proses pelaksanaan sebenar, Gunakan pembolehubah ini. Penutupan biasanya digunakan bersama Generator untuk memproses aliran data.

Pertimbangkan contoh berikut:

$data = [1, 2, 3, 4];

$mapper = function($value){
    return $value * $value;
};

$closure = function($data,$mapper){
    foreach($data as $entry) {
        yield $mapper($entry);
    }
};

$stream = $closure($data,$mapper);
foreach($stream as $entry){
    echo $entry.PHP_EOL;
}

Kod di atas menggunakan Closure untuk melaksanakan aliran data, kuasa dua nilai dalam sumber data $data dan kembalikannya. Penutupan menyediakan mekanisme yang berkuasa untuk menganggap fungsi sebagai objek dan memudahkan penghantarannya antara aliran data.

3. Rangka kerja pemprosesan aliran data

Walaupun PHP 7.0 sudah boleh menyokong pemprosesan aliran data, untuk memproses aliran data dengan lebih mudah, anda boleh menggunakan rangka kerja pemprosesan aliran data pihak ketiga. Di bawah ini kami akan memperkenalkan dua rangka kerja pemprosesan aliran data klasik dalam PHP.

1. ReactPHP

ReactPHP ialah rangka kerja pengaturcaraan dipacu peristiwa yang boleh digunakan untuk membina aplikasi tak segerak berprestasi tinggi dan menyokong aplikasi web, pelayan HTTP dan pelayan Soket. ReactPHP adalah berdasarkan model gelung acara berbenang tunggal, memproses berbilang permintaan selari dan menjana data penstriman dengan bertindak balas kepada acara.

Kod untuk menggunakan ReactPHP untuk melaksanakan pemprosesan aliran data adalah seperti berikut:

$stream = new ReactStreamReadableResourceStream(
    fopen(__DIR__ . '/../fixture/lorem-ipsum.txt', 'r'),
    $loop
);

$stream->on('data', function($data) use ($output) {
    $output->write($data);
    echo $data;
});

Dalam kod di atas, kami menggunakan mekanisme gelung peristiwa ReactPHP untuk mencipta aliran data. Dalam gelung peristiwa, $stream membaca data dan secara berterusan mencetuskan fungsi panggil balik untuk mengendalikan aliran masuk data.

2. Fractal

Fractal ialah perpustakaan yang melaksanakan pemprosesan aliran data dalam PHP. Pustaka ini digunakan terutamanya untuk memformat dan menukar data .

Fraktal sering digunakan untuk mengendalikan dua situasi berikut yang memerlukan sokongan yang lebih besar untuk pemprosesan aliran data:

(1) Apabila anda ingin membina format respons khusus langkah demi langkah, Fractal boleh mengendalikan kekurangan Simpan kod, walau bagaimanapun data atau atribut yang dikumpulkan akan menjadi sangat berbeza; aliran data boleh diproses dengan kerumitan dan fleksibiliti.

Contoh:

$books = [
    [
        "id" => 1,
        "title" => 'A Game of Thrones',
        "author_name" => 'George R. R. Martin',
        "currency" => 'USD',
        "price" => 19.99
    ]
];
$manager = new LeagueFractalManager();
$resource = new LeagueFractalResourceCollection($books, function ($book) {
    return [
        'id' => (int) $book['id'],
        'title' => $book['title'],
        'author' => [
            "name" => $book['author_name'],
        ],
        'price' => [
            'currency' => $book['currency'],
            'amount' => $book['price']
        ]
    ];
});

$manager->setSerializer(new LeagueFractalSerializerJsonApiSerializer());
$json = $manager->createData($resource)->toJson();
echo $json.PHP_EOL;

Dalam kod di atas, kami menggunakan Pengurus dan Pengumpulan Fractal untuk melaksanakan pemprosesan aliran data. Pengurus digunakan untuk mengendalikan butiran bersiri data, dan Pengumpulan digunakan untuk membina format penghantaran. Di sini, kami menggunakan JsonApiSerializer sebagai alat bersiri untuk menjana aliran data dalam format JSON.

4. Kesimpulan

Inovasi dan mempopularkan teknologi aliran data adalah sangat penting untuk pembangunan selanjutnya bidang pemprosesan data pada masa hadapan. Artikel ini terutamanya memperkenalkan kaedah menggunakan teknologi pemprosesan aliran data dalam PHP, termasuk ciri baharu PHP7.0, penggunaan Penutupan dan Penjana, dan aplikasi praktikal rangka kerja pemprosesan aliran data seperti Fractal dan ReactPHP. Dengan kemajuan berterusan aplikasi data besar, adalah dipercayai bahawa teknologi pemprosesan aliran data akan digunakan dengan lebih meluas pada masa hadapan.

Atas ialah kandungan terperinci Integrasi PHP dan pemprosesan aliran data. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!