Reka bentuk idea dan rancangan pelaksanaan untuk pengedaran mesej dan penjadualan tugas bagi baris gilir dalam PHP dan MySQL

Reka bentuk idea dan penyelesaian pelaksanaan untuk pengedaran mesej dan penjadualan tugas bagi baris gilir dalam PHP dan MySQL

1 Pengenalan
Dengan pengembangan berterusan skala aplikasi Internet dan keperluan pengguna yang semakin meningkat, pemprosesan serentak dan penjadualan tugas. sistem Kecekapan menjadi pertimbangan penting. Baris gilir ialah penyelesaian yang biasa digunakan yang boleh mengedarkan mesej dan menjadualkan tugas dengan berkesan. Artikel ini akan memperkenalkan cara mereka bentuk dan melaksanakan pengedaran mesej baris gilir dan penjadualan tugas dalam PHP dan MySQL. Idea Reka Bentuk , dsb., artikel MySQL ini akan digunakan sebagai contoh storan mesej.

Pemprosesan mesej: Reka logik pemprosesan mesej yang munasabah, termasuk penerbitan mesej, langganan dan pemprosesan.

Penjadualan tugas: Laksanakan penjadualan dan pelaksanaan tugas untuk memastikan tugasan dapat dilaksanakan dengan teratur dan mengikut logik yang telah ditetapkan.

1. Pengendalian ralat: Kendalikan ralat dengan betul semasa pelaksanaan, seperti mencuba semula, mengelog, dsb.
2. 3. Pelan pelaksanaan
4. Storan mesej

Buat jadual penyimpanan mesej dalam MySQL dengan struktur berikut:

CREATE TABLE queue (
 id INT AUTO_INCREMENT PRIMARY KEY,
 data TEXT,
 created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);

Apabila mesej dihantar, masukkan kandungan mesej dan masa semasa ke dalam jadual.

Apabila mesej diterima, mesej yang tidak diproses dibaca daripada jadual mengikut urutan masa penciptaan.

1. 
   Pemprosesan mesej

   Penerbitan dan langganan mesej boleh menggunakan mod Terbit-Langgan dan mesej boleh mempunyai berbilang pelanggan.

   Dalam PHP, anda boleh menggunakan Redis sebagai perkhidmatan baris gilir mesej, dan menerbitkan serta melanggan mesej melalui arahan langgan dan terbitkan Redis.
   

Contoh kod untuk penerbitan mesej:

2. $redis = new Redis();
   $redis->connect('127.0.0.1', 6379);
   $redis->publish('channel', 'message');

   
   Contoh kod untuk melanggan mesej:
   

   $redis = new Redis();
   $redis->connect('127.0.0.1', 6379);
   $redis->subscribe(['channel'], function ($redis, $channel, $message) {
       // 处理消息的逻辑
       echo $message;
   });

Penjadualan tugas

Penjadualan tugas boleh dilaksanakan menggunakan tugasan berjadual, seperti skrip PHP secara teratur.crontab

Buat jadual tugas dalam MySQL dengan struktur berikut:

CREATE TABLE tasks (
 id INT AUTO_INCREMENT PRIMARY KEY,
 command VARCHAR(255),
 created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);

Contoh kod untuk menambah tugasan:

3. $command = 'php /path/to/script.php';
   $pdo = new PDO('mysql:host=localhost;dbname=mydb', 'username', 'password');
   $stmt = $pdo->prepare('INSERT INTO tasks (command) VALUES (?)');
   $stmt->execute([$command]);

   Contoh kod untuk tugas yang dijadualkan:
   
   

4. • • • • 
           
           
           
           php
           

           schedule.php的代码示例：

           
           $pdo = PDO baharu('mysql:host=localhost;dbname=mydb', 'username', 'password');
           $stmt = $pdo->query('SELECT * FROM tasks ORDER BY created_at ASC');
         $tasks = $stmt->fetchAll(PDO::FETCH_ASSOC);
         foreach ($tasks as $task) {
       exec($task['command']);
       $pdo->query ('DELETE FROM tasks WHERE id = ' . $task['id']);
     }
5. 
   
   

Ralat pengendalian

Semasa pemprosesan mesej dan proses penjadualan tugas mungkin berlaku kesilapan itu perlu ditangani dengan sewajarnya. 🎜Anda boleh menggunakan pernyataan cuba-tangkap dalam kod untuk menangkap pengecualian dan melaksanakan pengendalian ralat yang sepadan, seperti mengelog, mencuba semula, dsb. 🎜🎜🎜4. Summary🎜Queue ialah penyelesaian yang biasa digunakan untuk pengedaran mesej dan penjadualan tugas. Artikel ini memperkenalkan idea dan penyelesaian untuk mereka bentuk dan melaksanakan pengedaran mesej baris gilir dan penjadualan tugas dalam PHP dan MySQL, serta memberikan contoh kod yang berkaitan. Melalui reka bentuk dan pelaksanaan yang munasabah, keupayaan pemprosesan serentak sistem dan kecekapan penjadualan tugas boleh dipertingkatkan, sekali gus meningkatkan pengalaman pengguna dan prestasi sistem. 🎜

Atas ialah kandungan terperinci Reka bentuk idea dan rancangan pelaksanaan untuk pengedaran mesej dan penjadualan tugas bagi baris gilir dalam PHP dan MySQL. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!