PHP에서 메일 대기열의 실패 재시도 메커니즘을 구현하는 방법은 무엇입니까?

CREATE TABLE email_queue (
    id INT AUTO_INCREMENT PRIMARY KEY,
    to_email VARCHAR(255),
    subject VARCHAR(255),
    message TEXT,
    retry_count INT DEFAULT 0
);

<?php
// 配置邮件服务器
$host = 'smtp.example.com';
$port = 587;
$username = 'your_username';
$password = 'your_password';

// 连接数据库
$mysqli = new mysqli('localhost', 'db_username', 'db_password', 'db_name');
if ($mysqli->connect_errno) {
    die('数据库连接失败: ' . $mysqli->connect_error);
}

// 查询待发送的邮件队列
$result = $mysqli->query('SELECT * FROM email_queue');
if (!$result) {
    die('邮件获取失败: ' . $mysqli->error);
}

// 循环发送邮件
while ($row = $result->fetch_assoc()) {
    $to = $row['to_email'];
    $subject = $row['subject'];
    $message = $row['message'];

    // 发送邮件
    $success = mail($to, $subject, $message);
    
    if ($success) {
        // 发送成功，从队列中删除邮件
        $mysqli->query('DELETE FROM email_queue WHERE id = ' . $row['id']);
    } else {
        // 发送失败，增加重试次数
        $retryCount = $row['retry_count'] + 1;
        $mysqli->query('UPDATE email_queue SET retry_count = ' . $retryCount . ' WHERE id = ' . $row['id']);
        
        // 如果重试次数超过10次，则放弃发送
        if ($retryCount > 10) {
            $mysqli->query('DELETE FROM email_queue WHERE id = ' . $row['id']);
            continue;
        }
    }
}

$mysqli->close();