PHP および MySQL でのメッセージ永続化とメッセージ再生におけるキュー テクノロジーの応用

pecl install redis

<?php
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);

// 将消息推送到队列
$redis->lpush('message_queue', 'Hello World');
$redis->lpush('message_queue', 'Welcome to Redis');

// 从队列中获取消息
$message = $redis->brpop('message_queue', 0)[1];
echo $message; // 输出：Hello World

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

CREATE TABLE message_queue (
    id INT AUTO_INCREMENT PRIMARY KEY,
    message VARCHAR(255) NOT NULL,
    status TINYINT NOT NULL DEFAULT 0
);

<?php
$db_host = 'localhost';
$db_user = 'your_username';
$db_pass = 'your_password';
$db_name = 'your_database';

// 连接到MySQL数据库
$conn = mysqli_connect($db_host, $db_user, $db_pass, $db_name);

// 检查连接是否成功
if (!$conn) {
    die("连接失败: " . mysqli_connect_error());
}

// 将消息保存到表格中
$message = 'Hello World';
$query = "INSERT INTO message_queue (message) VALUES ('$message')";
mysqli_query($conn, $query);

// 关闭数据库连接
mysqli_close($conn);
?>

<?php
$db_host = 'localhost';
$db_user = 'your_username';
$db_pass = 'your_password';
$db_name = 'your_database';

// 连接到MySQL数据库
$conn = mysqli_connect($db_host, $db_user, $db_pass, $db_name);

// 检查连接是否成功
if (!$conn) {
    die("连接失败: " . mysqli_connect_error());
}

// 从表格中获取未处理的消息
$query = "SELECT * FROM message_queue WHERE status = 0";
$result = mysqli_query($conn, $query);

// 循环遍历并重新发送消息
while ($row = mysqli_fetch_assoc($result)) {
    $message = $row['message'];

    // 重播消息的逻辑处理代码
    echo "重新发送消息：$message
";

    // 更新消息状态为已处理
    $id = $row['id'];
    mysqli_query($conn, "UPDATE message_queue SET status = 1 WHERE id = $id");
}

// 关闭数据库连接
mysqli_close($conn);
?>