Pembangunan pekerja: Bagaimana untuk melaksanakan pemprosesan tugas tak segerak

Pembangunan pekerja: Cara melaksanakan pemprosesan tugas tak segerak memerlukan contoh kod khusus

Workerman ialah rangka kerja rangkaian dipacu peristiwa tak segerak PHP yang bukan sahaja menyokong pembangunan program rangkaian berprestasi tinggi dan konkurensi tinggi, tetapi juga boleh digunakan untuk pemprosesan tugas tak segerak. Dalam pembangunan web, terdapat banyak tugas yang memerlukan pemprosesan tak segerak, seperti menghantar e-mel, pemberitahuan SMS, transcoding video, dan sebagainya. Artikel ini akan memperkenalkan cara menggunakan Workerman untuk memproses tugas tak segerak dan memberikan contoh kod khusus.

1. Tugas tak segerak dan kaedah pemprosesan

Dalam pembangunan web, terdapat banyak tugas yang memerlukan pemprosesan tak segerak, seperti menghantar e-mel, pemberitahuan SMS, transkod video, dll. Tugasan ini memerlukan banyak masa dan sumber untuk diselesaikan Jika selesai dalam program utama, masa tindak balas akan menjadi terlalu lama dan pengalaman pengguna akan terjejas. Oleh itu, menggunakan pemprosesan tugas tak segerak, tugasan ini boleh diselesaikan di latar belakang tanpa menjejaskan pelaksanaan program utama.

Dalam pemprosesan tugas tak segerak, ia biasanya dilaksanakan melalui baris gilir mesej atau tugasan berjadual. Antaranya, baris gilir mesej ialah teknologi pengaturcaraan serentak yang merangkum tugas tak segerak ke dalam mesej dan menyimpannya dalam baris gilir. Kemudian melalui pemproses tugas tak segerak, mesej diambil dari baris gilir dan tugasan dilaksanakan. Selain itu, tugas berjadual merujuk kepada melaksanakan tugas secara berkala dalam selang masa yang telah ditetapkan.

2. Workerman melaksanakan pemprosesan tugas tak segerak

1. Memperkenalkan rangka kerja Workerman

Sebelum anda mula menggunakan rangka kerja Workerman untuk pemprosesan tugas tak segerak, anda perlu memasangnya terlebih dahulu. Anda boleh menggunakan komposer untuk memasang, atau memuat turun dan unzip Workerman ke direktori yang ditentukan.

Apabila memperkenalkan rangka kerja Workerman, anda perlu menggunakan fail autoload composer.json atau autoload.php, pilih mengikut penggunaan anda.

Sebagai contoh, cara menggunakan composer.json:

{
    "require": {
        "workerman/workerman": "4.0.*"
    }
}

Cara untuk menggunakan autoload.php:

<?php
require_once __DIR__ . '/workerman/autoload.php';

2. Buat pemproses tugas tak segerak

Apabila menggunakan Workerman untuk pemprosesan tugasan tak segerak, anda perlu pemproses tugas dahulu. Pemproses tugas asynchronous boleh dilaksanakan dengan mentakrifkan kelas dan mewarisi kelas Worker dalam Workerman Kelas Worker ialah kelas perkhidmatan dipacu peristiwa yang boleh membolehkan berbilang proses untuk mengendalikan sambungan, acara, dsb. pada masa yang sama.

Sebagai contoh, cipta kelas MyTask dan warisi kelas Pekerja:

use WorkermanWorker;

class MyTask extends Worker
{
    public function __construct()
    {
        //设置异步任务使用的进程数，默认为1
        parent::__construct('text://0.0.0.0:2345');
        $this->name = 'MyTask';
    }

    public function onWorkerStart()
    {
        //异步任务处理逻辑
        $this->addFunction('mytask', function($task_data){
            //处理异步任务
            //...
        })
    }
}

Dalam kod di atas, kelas MyTask ditakrifkan dan bilangan proses yang digunakan oleh tugas tak segerak ditetapkan dalam pembinanya. Selepas itu, tugas tak segerak diproses dalam fungsi onWorkerStart, dan fungsi pemprosesan ditambahkan pada baris gilir tugas tak segerak melalui fungsi addFunction.

3. Tentukan penghantar tugas tak segerak

Dalam pemprosesan tugas tak segerak, secara amnya perlu menghantar tugasan tak segerak ke baris gilir dahulu dan biarkan pemproses tugas tak segerak memprosesnya. Oleh itu, adalah perlu untuk menentukan penghantar tugas tak segerak.

Sebagai contoh, tentukan kelas MyTaskSender:

use WorkermanWorker;

class MyTaskSender
{
    public static function send($task_data)
    {
        $client = new WorkermanClientAsyncTcpConnection('text://127.0.0.1:2345');
        $client->onConnect = function()use($task_data, $client){
            $client->send(json_encode(['task'=>'mytask', 'data'=>$task_data]));
            $client->close();
        };
        $client->connect();
    }
}

Dalam kod di atas, kelas MyTaskSender ditakrifkan dan fungsi hantar ditakrifkan, yang menggunakan kelas AsyncTcpConnection untuk menyambungkan pemproses tugas tak segerak dan menghantar tugas tak segerak yang perlu diproses untuk beratur.

4. Gunakan penghantar tugas tak segerak untuk menghantar tugas tak segerak

Dalam langkah di atas, pemproses tugas tak segerak dan penghantar tugas tak segerak telah ditentukan. Seterusnya, anda boleh menghantar tugas tak segerak melalui penghantar tugas tak segerak.

Sebagai contoh, apabila menggunakan kelas MyTaskSender untuk menghantar tugas tak segerak, anda boleh menggunakan kaedah berikut:

$task_data = ['task_param1'=>'value1', 'task_param2'=>'value2'];
MyTaskSender::send($task_data);

Dalam kod di atas, parameter $task_data tugas tak segerak ditakrifkan dan tugas tak segerak dihantar ke beratur melalui fungsi hantar di tengah kelas MyTaskSender.

3. Ringkasan

Artikel ini memperkenalkan cara menggunakan rangka kerja Workerman untuk melaksanakan pemprosesan tugas tak segerak dan menyediakan contoh kod khusus. Dalam pemprosesan tugas tak segerak, menggunakan rangka kerja Workerman boleh memudahkan pemprosesan berbilang proses dan mempunyai kecekapan pemprosesan yang tinggi. Pengguna boleh membuat pengubahsuaian dan pelarasan yang sepadan mengikut keperluan dan keadaan sebenar mereka sendiri.

Atas ialah kandungan terperinci Pembangunan pekerja: Bagaimana untuk melaksanakan pemprosesan tugas tak segerak. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!