队列的消息持久化和消息去重在PHP与MySQL中的应用场景

<?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');
}
?>

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;

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