Bagaimana untuk melaksanakan tugas berjadual teragih dan penjadualan dalam perkhidmatan mikro PHP

Cara melaksanakan tugas berjadual teragih dan penjadualan dalam perkhidmatan mikro PHP

Dalam seni bina perkhidmatan mikro moden, tugas berjadual teragih dan penjadualan adalah komponen yang sangat penting. Mereka boleh membantu pembangun mengurus, menjadualkan dan melaksanakan tugas berjadual dengan mudah dalam berbilang perkhidmatan mikro, meningkatkan kebolehpercayaan dan kebolehskalaan sistem. Artikel ini akan memperkenalkan cara menggunakan PHP untuk melaksanakan tugas pemasaan dan penjadualan yang diedarkan, serta menyediakan contoh kod untuk rujukan.

1. Menggunakan sistem baris gilir

Untuk melaksanakan tugasan berjadual yang diedarkan dan penjadualan, anda perlu menggunakan sistem baris gilir yang boleh dipercayai. Sistem baris gilir boleh membantu kami mengurus dan menjadualkan tugas dengan ketersediaan dan prestasi yang tinggi.

Pada masa ini, terdapat banyak sistem baris gilir yang sangat baik untuk dipilih, seperti RabbitMQ, ZeroMQ dan Redis. Dalam artikel ini, kami akan menggunakan Redis sebagai sistem baris gilir kami.

2. Buat penerbit tugas

Dalam PHP, kami boleh beroperasi melalui perpustakaan sambungan Redis. Pertama, kita perlu mencipta penerbit tugasan untuk menambahkan tugasan pada baris gilir.

// Sambung ke Redis
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);

// Tambahkan tugasan pada baris gilir
$ task = [

'name' => 'task_name',
'params' => ['param1', 'param2'],
'time' => time() + 60, // 任务执行时间为当前时间后60秒

];
$redis->lpush('task_queue', json_encode($task));

// Tutup sambungan Redis
$redis->close();

?>

Kod di atas akan menambah tugasan yang mengandungi nama tugas, parameter dan masa pelaksanaan pada baris gilir.

3. Buat pengguna tugas

Seterusnya, kita perlu mencipta pengguna tugas untuk mendapatkan tugas daripada baris gilir dan melaksanakannya.

// Sambung ke Redis
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);

// Gelung untuk mendapatkan tugasan dalam giliran dan Laksanakan
sementara (benar) {

$task = $redis->brpop('task_queue', 0); // 从队列尾部获取任务，如果队列为空则进行阻塞等待
$task = json_decode($task, true);

// 执行任务
if ($task) {
    $name = $task['name'];
    $params = $task['params'];

    // 根据任务名称执行对应的任务逻辑
    switch ($name) {
        case 'task_name':
            // 执行任务逻辑
            // ...
            break;
        // 添加其他任务的逻辑...
    }
}

}

// Tutup sambungan Redis
$redis->close();

?>

Kod di atas akan terus mendapat tugas daripada baris gilir dan berasaskan pada nama tugas Laksanakan logik tugasan yang sepadan.

4. Tambah fungsi penjadualan tugas

Untuk mengurus masa pelaksanaan dan kekerapan tugas dengan lebih baik, kami boleh menggunakan penjadual untuk mengawal penjadualan tugas.

penjadual kelas
{

private $redis;

public function __construct()
{
    $this->redis = new Redis();
    $this->redis->connect('127.0.0.1', 6379);
}

// 将任务添加到调度器中
public function addTask($task, $time)
{
    $this->redis->zadd('task_schedule', $time, $task);
}

// 从调度器中移除任务
public function removeTask($task)
{
    $this->redis->zrem('task_schedule', $task);
}

// 调度任务
public function schedule()
{
    $now = time();
    $tasks = $this->redis->zrangebyscore('task_schedule', '-inf', $now);

    foreach ($tasks as $task) {
        $this->redis->lpush('task_queue', $task);
        $this->redis->zrem('task_schedule', $task);
    }
}

// 关闭Redis连接
public function __destruct()
{
    $this->redis->close();
}

}

?>

Kita boleh menggunakan kelas Penjadual untuk menambah, mengalih keluar dan menjadualkan tugas. Penjadual menambah tugas pada baris gilir tugas dan mengalih keluarnya daripada penjadual berdasarkan masa pelaksanaan tugas.

5. Menggunakan penerbit tugasan dan pengguna tugasan

Kini, kami boleh menggabungkan penerbit tugasan dan pengguna tugasan untuk melaksanakan tugas pemasaan teragih dan fungsi penjadualan.

//Buat penerbit tugasan
$penerbit = new TaskPublisher();
$publisher->addTask('task_name', ['param1', 'param2'], time() + 60 ) ;

// Cipta pengguna tugas
$consumer = new TaskConsumer();
$consumer->start();

// Cipta penjadual tugas
$scheduler = new Scheduler();
$scheduler- > ;addTask('task_name', time() + 60);

//Schedule task
$scheduler->schedule();

?>

Kod di atas menambahkan tugas pada baris gilir tugas dan memulakannya Pengguna tugas dan penjadual tugas.

Melalui langkah di atas, kami boleh melaksanakan tugas berjadual teragih dan fungsi penjadualan dalam perkhidmatan mikro PHP. Dengan cara ini, kami boleh mengurus, menjadualkan dan melaksanakan tugas berjadual dengan mudah dalam berbilang perkhidmatan mikro, meningkatkan kebolehpercayaan dan kebolehskalaan sistem.

Nota: Kod di atas hanyalah contoh Dalam aplikasi sebenar, ia mungkin perlu diubah suai dan dioptimumkan mengikut keperluan tertentu. Sila sesuaikan mengikut situasi sebenar.

Atas ialah kandungan terperinci Bagaimana untuk melaksanakan tugas berjadual teragih dan penjadualan dalam perkhidmatan mikro PHP. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!