当前位置：首页 > 文章列表 > 文章 > php教程 > PHP批量发邮件：模板替换与SMTP并发控制

PHP批量发邮件：模板替换与SMTP并发控制

2026-01-27 23:20:48 0浏览收藏

对于一个文章开发者来说，牢固扎实的基础是十分重要的，golang学习网就来带大家一点点的掌握基础知识点。今天本篇文章带大家了解《PHP批量发邮件：模板变量替换与SMTP并发控制》，主要介绍了，希望对大家的知识积累有所帮助，快点收藏起来吧，否则需要时就找不到了！

使用模板引擎渲染个性化内容并结合SMTP批量发送邮件，通过分批处理、延迟和队列机制控制并发，确保高效稳定投递。

php如何批量发送个性化邮件_php模板引擎替换变量与smtp并发发送控制

在实际项目中，批量发送个性化邮件是常见需求，比如营销推广、通知提醒等。PHP 实现这一功能需要解决两个核心问题：一是如何动态填充模板中的变量生成个性化内容；二是如何通过 SMTP 高效并发发送大量邮件，同时避免服务器被封或性能瓶颈。

使用模板引擎替换变量实现个性化内容

为了给每位收件人发送带有其姓名、订单号等信息的定制化邮件，不能直接写死内容，而应采用“模板 + 数据”方式渲染。

最简单的方式是使用原生 PHP 字符串替换，例如：

\$template = "亲爱的{\$name}，您的订单 {\$order_id} 已发货，请注意查收。";
\$body = str_replace(['{\$name}', '{\$order_id}'], ['张三', '20231001'], \$template);

对于更复杂的场景，推荐使用轻量级模板引擎如 Twig 或 Plates，它们支持条件判断、循环和过滤器，提升可维护性。

以 Twig 为例：

require_once 'vendor/autoload.php';
\$loader = new \Twig\Loader\ArrayLoader();
\$twig = new \Twig\Environment(\$loader);

\$templateContent = "亲爱的{{ name }}，您购买的 {{ items|join(', ') }} 即将送达。";
\$rendered = \$twig->render(\$templateContent, [
    'name' => '李四',
    'items' => ['手机', '充电器']
]);

将模板文件分离后还可提高复用性，只需传入不同数据即可生成千人千面的内容。

基于 SMTP 的邮件发送与并发控制

发送邮件建议使用 PHPMailer 或 Swift Mailer，配合企业邮箱或第三方 SMTP 服务（如阿里云、SendGrid）确保投递率。

示例使用 PHPMailer 发送单封邮件：

use PHPMailer\PHPMailer\PHPMailer;
use PHPMailer\PHPMailer\SMTP;

\$mail = new PHPMailer(true);
\$mail->isSMTP();
\$mail->Host       = 'smtp.exmail.qq.com';
\$mail->SMTPAuth   = true;
\$mail->Username   = 'notice@company.com';
\$mail->Password   = 'your-smtp-password';
\$mail->SMTPSecure = PHPMailer::ENCRYPTION_STARTTLS;
\$mail->Port       = 587;

\$mail->setFrom('notice@company.com', '系统通知');
\$mail->addAddress('user@example.com', '王五');
\$mail->isHTML(true);
\$mail->Subject = '订单更新提醒';
\$mail->Body    = \$rendered; // 渲染后的模板
\$mail->send();

控制并发数量防止资源耗尽

一次性发送数千封邮件容易导致内存溢出或触发 SMTP 服务商限流。必须进行流量控制。

常用策略包括：

分批处理：每次处理 50~100 封，结合数据库标记已发送状态
延迟发送：每发送几封后 sleep(1)，降低请求频率
队列机制：将待发任务写入 Redis 或数据库，由后台 Worker 异步消费

简单实现一个可控的发送批次：

\$recipients = [
    ['email' => 'a@ex.com', 'name' => 'A'],
    ['email' => 'b@ex.com', 'name' => 'B'],
];

\$batchSize = 50;
\$sentCount = 0;

foreach (array_chunk(\$recipients, \$batchSize) as \$batch) {
    foreach (\$batch as \$user) {
        try {
            \$mail = clone \$baseMail; // 注意克隆实例避免冲突
            \$mail->clearAddresses();
            \$mail->addAddress(\$user['email'], \$user['name']);
            \$mail->Body = renderTemplate(\$template, \$user);
            \$mail->send();
            \$sentCount++;
        } catch (Exception \$e) {
            error_log("Failed to send to {\$user['email']}: " . \$mail->ErrorInfo);
        }
    }
    // 批次间暂停，减轻服务器压力
    sleep(2);
}
echo "共成功发送 {\$sentCount} 封邮件。\n";