向时事通讯的订阅者发送大量消息

Question

cron 作业每天都会执行一个 PHP 脚本来向订阅者发送电子邮件。

脚本运行良好，但问题是订阅者增加并且脚本在 100 秒后超时。

所以我需要分批运行进程。

我的问题：如何让脚本从某个 id 开始，然后下次从这个 id 开始？ 我不能把脚本分成不同的文件，因为我不知道有多少订户有。

/* Get all subscribers from DB */
$stmt = $pdo->query("SELECT * FROM subscribers");

/* Loop through subscribers and get email */
foreach(){

    /* Create a new PHPMailer object. */
    $mail = new PHPMailer();

    /* Set the mail sender. */
    $mail->setFrom('myemail@domain.com', 'John Doe');

    /* Add a recipient. */
    $mail->addAddress('recipient@recipient.com', 'recipient');

    /* Set the subject. */
    $mail->Subject = 'New article';

    /* Set the mail message body. */
    $mail->Body = 'This is a new article.';

    /* Finally send the mail. */
    if (!$mail->send())
    {
       /* PHPMailer error. */
       echo $mail->ErrorInfo;
    }

}

更新：

其中一种方法行得通吗？

1- 我不是一次获取所有订阅者 SELECT * FROM subscribers ，而是使用循环每次获取 500 行，并且可能在每次之后使用 sleep()。

/* Loop with increment of 500 */
for($i = 0; $i <= $rowsCount; $i += 500){

    /* Select 500 subscribers */
    $query = ("SELECT * FROM `subscribers` LIMIT $i, 500");

    /* Send Emails to 500 subscribers */

    sleep(60);

}

2- 将最后一个订阅者 id 保存在表中，每次执行脚本时，从该 id 开始：

/* Get the last subscriber id from previous time */
$last_subscriber_id = `SELECT id FROM last_subscriber_id`;

/* Select the next 500 subscribers starting from the previous time last id */
$query = "SELECT * FROM `subscribers` WHERE `id` > $last_subscriber_id LIMIT 500";

/* Send Emails to 500 subscribers */
..

/* Update  last_subscriber_id with the last id */
..

但在这种情况下，我会每 x 分钟运行一次脚本，因为我不知道有多少订阅者

而且我不认为我可以用 PHP 更新 cron 作业，所以如果所有订阅者都收到了电子邮件，则停止执行脚本。

Answer 1

我推荐几种可能的方法。

一个是remove lines from the file as you process it

另一种是异步执行，使用像Kafka 或RabbitMQ 这样的系统。

最后，您可以在持久存储中记录您正在处理的行号，读取该行号，然后跳转到文件的该行。