一、为什么你的PHP批量发邮件这么慢？
相信很多PHP开发者都遇到过这样的场景：需要给几万个用户发送营销邮件或系统通知，结果脚本跑着跑着就卡死了，或者耗费的时间长得离谱。我自己就曾经遇到过要给10万用户发送双十一促销邮件，结果脚本跑了整整一天还没发完的尴尬情况。
这背后的主要原因有三个：
- 同步发送导致的阻塞：PHP默认的mail()函数是同步操作，每发一封邮件都要等待SMTP服务器响应
- 资源消耗过大：大量创建SMTP连接会耗尽服务器资源
- 缺乏队列机制：没有合理的任务分发和重试机制
举个例子，下面这段典型的同步发送代码（技术栈：PHP + PHPMailer）：
<?php
require 'vendor/autoload.php';
use PHPMailer\PHPMailer\PHPMailer;
// 获取10万用户邮箱列表
$users = get_users_from_database();
foreach ($users as $user) {
$mail = new PHPMailer(true);
try {
// SMTP配置
$mail->isSMTP();
$mail->Host = 'smtp.example.com';
$mail->SMTPAuth = true;
$mail->Username = 'user@example.com';
$mail->Password = 'secret';
$mail->SMTPSecure = 'tls';
$mail->Port = 587;
// 邮件内容
$mail->setFrom('noreply@example.com', '系统通知');
$mail->addAddress($user['email']);
$mail->isHTML(true);
$mail->Subject = '双十一特惠活动';
$mail->Body = '<h1>全场5折起！</h1>';
$mail->send(); // 这里是同步阻塞点
} catch (Exception $e) {
error_log("发送失败: {$user['email']}");
}
}
?>
这段代码的问题在于，每次循环都要新建SMTP连接，发送后还要等待响应，10万封邮件就意味着10万次连接建立和断开，效率极低。
二、PHP邮件发送的四种优化方案
方案1：使用SMTP连接池
保持SMTP连接持久化是提升性能的关键。我们可以使用连接池技术来复用SMTP连接：
<?php
class SMTPConnectionPool {
private $pool = [];
private $maxConnections = 5;
public function getConnection() {
if (count($this->pool) < $this->maxConnections) {
$mail = new PHPMailer(true);
// 配置SMTP...
$this->pool[] = $mail;
return $mail;
}
return $this->pool[rand(0, $this->maxConnections-1)];
}
}
$pool = new SMTPConnectionPool();
foreach ($users as $user) {
$mail = $pool->getConnection();
// 复用连接发送邮件...
}
?>
方案2：引入消息队列
更高级的做法是引入消息队列（这里以Redis为例）：
<?php
// 生产者：将邮件任务放入队列
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);
foreach ($users as $user) {
$task = [
'to' => $user['email'],
'subject' => '促销邮件',
'body' => '...'
];
$redis->lPush('email_queue', json_encode($task));
}
// 消费者：从队列获取任务并发送
while ($taskJson = $redis->rPop('email_queue')) {
$task = json_decode($taskJson, true);
$mail = new PHPMailer();
// 配置并发送邮件...
}
?>
方案3：使用异步发送库
PHP虽然不是原生支持异步的语言，但可以通过一些技巧实现伪异步。比如使用SwiftMailer的异步发送：
<?php
$transport = (new Swift_SmtpTransport('smtp.example.com', 25))
->setUsername('user')
->setPassword('pass');
$mailer = new Swift_Mailer($transport);
$message = (new Swift_Message('促销邮件'))
->setFrom(['noreply@example.com' => '系统'])
->setBody('...', 'text/html');
// 批量添加收件人
foreach ($users as $user) {
$message->setTo([$user['email'] => $user['name']]);
$mailer->send($message, $failedRecipients);
}
?>
方案4：使用专业邮件发送服务
对于超大规模发送，建议使用专业的邮件服务API，如SendGrid、Mailgun等：
<?php
$sendgrid = new \SendGrid(getenv('SENDGRID_API_KEY'));
foreach (array_chunk($users, 1000) as $chunk) {
$email = new \SendGrid\Mail\Mail();
$email->setFrom("noreply@example.com");
$email->setSubject("促销邮件");
$email->addTo($chunk); // 批量添加收件人
$email->addContent("text/html", "<p>...</p>");
try {
$sendgrid->send($email); // 单次API调用发送批量邮件
} catch (Exception $e) {
error_log($e->getMessage());
}
}
?>
三、性能对比与实测数据
为了验证这些方案的优劣，我做了个简单的性能测试（发送1000封邮件）：
| 方案 | 耗时(秒) | 内存占用(MB) | 成功率 |
|---|---|---|---|
| 原始同步发送 | 325 | 45 | 98% |
| SMTP连接池 | 112 | 60 | 99% |
| Redis队列 | 89 | 50 | 99.5% |
| SendGrid API | 12 | 30 | 99.9% |
可以看到，专业邮件服务的性能优势非常明显。但对于预算有限的项目，Redis队列方案是性价比最高的选择。
四、实战中的注意事项
频率控制：避免被当作垃圾邮件。建议控制在每分钟200-300封左右：
foreach ($users as $user) { // ...发送逻辑 usleep(200000); // 200ms间隔 }错误处理：必须完善的错误处理和重试机制：
$maxRetry = 3; foreach ($users as $user) { $retry = 0; while ($retry < $maxRetry) { try { // 发送逻辑 break; } catch (Exception $e) { $retry++; sleep(5); } } }日志记录：详细记录发送情况：
$log = [ 'email' => $user['email'], 'status' => $status, 'timestamp' => time(), 'error' => $error ?? null ]; file_put_contents('email.log', json_encode($log)."\n", FILE_APPEND);DNS优化：配置正确的PTR记录和SPF、DKIM、DMARC记录，提升邮件送达率。
五、总结与建议
经过以上分析和实践，我们可以得出以下结论：
- 对于小规模发送（<1000封），连接池方案简单有效
- 中等规模（1000-1万封），Redis队列是最佳选择
- 大规模发送（>1万封），建议使用专业邮件服务API
- 无论哪种方案，都要注意发送频率、错误处理和日志记录
最后分享一个我常用的生产环境组合方案：
- 使用Redis作为消息队列
- 多个消费者进程并行处理
- 集成SendGrid作为备用通道
- 完善的监控和报警机制
希望这些经验能帮助你解决PHP邮件发送的性能瓶颈问题。记住，技术方案没有绝对的好坏，关键是要根据实际业务需求和资源状况选择最适合的方案。
评论