Reka bentuk idea dan rancangan pelaksanaan untuk pengedaran mesej dan penjadualan tugas bagi baris gilir dalam PHP dan MySQL-tutorial php-php.cn

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

WBOY

Lepaskan： 2023-10-15 14:08:02

asal

1109 orang telah melayarinya

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.

Pengendalian ralat: Kendalikan ralat dengan betul semasa pelaksanaan, seperti mencuba semula, mengelog, dsb.
3. Pelan pelaksanaan
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
);

Salin selepas log masuk

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

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.

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

Salin selepas log masuk

Contoh kod untuk melanggan mesej:

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

Salin selepas log masuk

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
);

Salin selepas log masuk

$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]);

Salin selepas log masuk

Contoh kod untuk tugas yang dijadualkan:

- - - - php
        schedule.php的代码示例：
        Salin selepas log masuk
        
        $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']);}