Scénarios d'application de persistance des messages de file d'attente et de déduplication des messages en PHP et MySQL

Scénarios d'application de persistance des messages de file d'attente et de déduplication de messages en PHP et MySQL

La file d'attente est une structure de données courante largement utilisée dans le traitement asynchrone des messages, la planification des tâches, la collecte de journaux, etc. dans la scène du développement logiciel. Parmi elles, la persistance des messages et la déduplication des messages sont deux fonctionnalités importantes de la file d'attente, qui peuvent garantir la fiabilité des messages et la cohérence des données. En PHP et MySQL, les applications de file d'attente peuvent utiliser Redis comme middleware de messages et MySQL pour stocker et gérer les métadonnées de la file d'attente. Des exemples spécifiques sont les suivants.

Tout d'abord, vous devez installer et configurer Redis et MySQL pour prendre en charge les opérations de file d'attente. Nous supposons que l'installation et la configuration de Redis et MySQL sont terminées et que les extensions Redis et MySQL ont été installées en PHP.

Ce qui suit est un exemple de code qui utilise PHP et Redis pour implémenter une file d'attente :

<?php

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

// 将消息插入队列
$redis->rpush('queue', 'message1');
$redis->rpush('queue', 'message2');
$redis->rpush('queue', 'message3');

// 从队列中读取消息
$message = $redis->lpop('queue');
while ($message) {
    echo $message . PHP_EOL;
    $message = $redis->lpop('queue');
}
?>

Dans le code ci-dessus, nous utilisons la méthode rpush de Redis pour insérer le message dans la queue de la file d'attente, utilisons la méthode lpop pour lire le message de la tête de file d'attente, et Lire en boucle jusqu'à ce que la file d'attente soit vide.

Ensuite, nous devons utiliser MySQL pour obtenir la persistance et la déduplication des messages. Tout d'abord, créez une table pour stocker les métadonnées du message, y compris des champs tels que l'ID du message et l'état de traitement.

CREATE TABLE `queue` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `message` varchar(255) DEFAULT NULL,
  `status` tinyint(1) DEFAULT '0',
  PRIMARY KEY (`id`),
  UNIQUE KEY `message` (`message`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

Ensuite, nous pouvons écrire du code PHP pour conserver le message dans MySQL et effectuer un jugement de déduplication avant l'insertion pour empêcher l'insertion répétée du même message.

<?php

// 链接MySQL
$mysqli = new mysqli('localhost', 'root', 'password', 'database');

// 将消息插入队列
$message = 'message1';
$exists = $mysqli->query("SELECT * FROM queue WHERE message = '$message'");
if ($exists->num_rows == 0) {
    $mysqli->query("INSERT INTO queue (message) VALUES ('$message')");
}

// 从队列中读取消息
$result = $mysqli->query("SELECT * FROM queue WHERE status = 0");
while ($row = $result->fetch_assoc()) {
    echo $row['message'] . PHP_EOL;
    
    // 标记消息为已处理
    $id = $row['id'];
    $mysqli->query("UPDATE queue SET status = 1 WHERE id = $id");
}

// 关闭连接
$mysqli->close();
?>

Dans le code ci-dessus, nous utilisons l'extension mysqli pour nous connecter à la base de données MySQL et déterminer si le message existe déjà dans la file d'attente via une requête. S'il n'existe pas, le message est inséré dans la file d'attente. Lors de la lecture des messages, nous recherchons les messages non traités, lisons chaque message via une boucle et marquons son statut comme traité.

En résumé, la persistance des messages en file d'attente et la déduplication des messages sont des technologies couramment utilisées en développement, qui peuvent garantir la fiabilité des messages et la cohérence des données. Cet article présente des exemples de code permettant d'utiliser PHP et Redis pour implémenter des files d'attente, et les combine avec MySQL pour obtenir la persistance et la déduplication des messages. J'espère que cet article pourra vous aider à comprendre les scénarios d'application et les méthodes de mise en œuvre des files d'attente.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!