Cara menggunakan rangka kerja Hyperf untuk pengurusan berbilang proses

Cara menggunakan rangka kerja Hyperf untuk pengurusan pelbagai proses

Ikhtisar:
Apabila membangunkan aplikasi web, anda sering menghadapi senario yang memerlukan pemprosesan serentak, seperti keperluan untuk mengendalikan berbilang tugas pada masa yang sama, merangkak serentak halaman web, dsb. Untuk meningkatkan prestasi dan kecekapan aplikasi, kami perlu mengagihkan tugas kepada berbilang proses untuk diproses secara serentak. Rangka kerja Hyperf ialah rangka kerja PHP berprestasi tinggi yang menyediakan fungsi pengurusan berbilang proses dan boleh melaksanakan pemprosesan tugasan serentak dengan mudah.

Langkah penggunaan:

1. Pastikan rangka kerja Hyperf dan sambungan bergantungnya dipasang;
2. Buat projek Hyperf baharu
3. Pasang pakej sambungan proses Hyperf:

Write kod

4. 🜎

composer require hyperf/process dev-master

Jalankan kod ujian:

<?php

use HyperfProcessAnnotationProcess;
use HyperfProcessProcessCollector;
use SwooleProcess as SwooleProcess;

// 注册多进程任务
class MyProcess
{
    /**
     * @Process(name="my_process")
     */
    public function handle(): void
    {
        // 处理具体的任务逻辑
        while (true) {
            file_put_contents('process.log', 'Hello World' . PHP_EOL, FILE_APPEND);
            sleep(1);
        }
    }
}

// 启动多进程任务
$processBuilder = new HyperfProcessProcessBuilder();
$process = $processBuilder->getProcess(MyProcess::class);
$process->start();

// 收集已注册的进程任务
$processCollector = new ProcessCollector();
$processes = $processCollector->getProcesses();

// 等待所有进程任务结束
foreach ($processes as $process) {
    $process->wait();
}

Lihat proses fail log.log, anda boleh melihat bahawa berbilang proses sedang melaksanakan tugas pada masa yang sama.

Analisis kod:

Dalam kod di atas, kami mula-mula mentakrifkan kelas bernama MyProcess Kaedah pemegang dalam kelas ini digunakan untuk pemprosesan logik tugasan tertentu. Dengan menggunakan anotasi @Process, kami mendaftarkan kaedah sebagai tugas berbilang proses.

Seterusnya, kami menggunakan kelas ProcessBuilder untuk mencipta contoh proses. Parameter kaedah getProcess ialah nama kelas kelas proses MyProcess yang kami takrifkan sebelum ini.

Kemudian, gunakan kaedah mula untuk memulakan proses.

Melalui kelas ProcessCollector, kita boleh mendapatkan semua tugas proses berdaftar. Selanjutnya, kami menggunakan gelung foreach untuk menunggu selesai semua tugasan proses.

Akhir sekali, kita boleh memulakan tugas berbilang proses dengan menjalankan php bin/hyperf.php start. Semasa pelaksanaan tugas, fail log process.log akan terus merekodkan hasil pelaksanaan setiap proses.

Nota:

Dalam pembangunan sebenar, pelbagai tugas proses yang berbeza boleh didaftarkan mengikut keperluan, dan dimulakan serta diuruskan mengikut keperluan.
1. Parameter seperti bilangan dan selang masa tugas berbilang proses boleh dilaraskan dan dioptimumkan mengikut keperluan sebenar.
2. Adalah disyorkan untuk menambah pengecam proses pada fail log untuk memudahkan lokasi masalah seterusnya dan penyahpepijatan.

Ringkasan:

Rangka kerja Hyperf menyediakan fungsi pengurusan pelbagai proses yang mudah yang boleh membantu kami mengendalikan tugas serentak dengan cepat. Dengan mendaftar dan melancarkan pelbagai tugas proses, kami dapat mengendalikan berbilang tugas pada masa yang sama, meningkatkan prestasi dan kecekapan aplikasi. Pada masa yang sama, melaraskan bilangan dan selang masa tugas serentak secara rasional boleh mengoptimumkan lagi proses pemprosesan serentak. Saya harap artikel ini akan membantu anda memahami cara menggunakan rangka kerja Hyperf untuk pengurusan berbilang proses.

Atas ialah kandungan terperinci Cara menggunakan rangka kerja Hyperf untuk pengurusan berbilang proses. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!