Go高性能批量邮件发送需连接复用、合理并发、错误隔离与MTA降级：复用SMTP长连接避免握手开销，采用“连接池×每连接串行”模式控制并发度，对4xx/5xx错误分级处理，并支持sendmail本地MTA自动fallback。
Go语言实现高性能批量邮件发送，关键不在“写多少行代码”，而在于连接复用、并发控制、错误隔离和投递可靠性。直接用单连接串行发1000封邮件，慢且易中断；盲目开1000个goroutine并发发，又可能被SMTP服务器限流或触发反垃圾机制。真正高效的方案是组合使用连接池、合理并发、批量复用与本地MTA备用路径。
复用SMTP连接，避免反复握手
每次调用 d.DialAndSend()（如gomail）或新建 client 并发送，都会建立新TCP+TLS连接，耗时约100–500ms。高频发送时这是最大瓶颈。
- 使用
gomail.NewDialer创建拨号器后，显式调用d.Dial()获取一个长连接gomail.SendCloser，之后所有邮件都通过该连接的s.Send()方法发送 - go-simple-mail 支持
server.KeepAlive = true，底层自动维持连接并复用，适合持续发送场景 - 手动实现连接池时，可用
sync.Pool缓存已认证的*smtp.Client实例，但要注意连接空闲超时与健康检查（例如发一个NOOP命令探测）
控制并发粒度，不贪多也不串行
并发不是越多越好。SMTP服务器通常对同一IP的并发连接数、每分钟请求数有硬限制（如Gmail为2/秒，SendGrid为100/秒）。应按目标服务商策略调整。
- 推荐采用“连接池 × 每连接串行发送”模式：例如启动5个长连接，每个连接上用for循环依次发200封邮件，总并发度=5，实际吞吐稳定且可控
- 若需更高吞吐，可用
errgroup.WithContext控制并发goroutine数量（如sem := make(chan struct{}, 10)），每goroutine独占一个连接，避免共享连接导致的竞态 - 对失败邮件做分级处理：临时错误（4xx）可延迟重试；永久错误（5xx）、无效邮箱等立即归档，不阻塞后续发送
支持本地MTA作为降级通道
当外部SMTP服务不稳定、被墙或配额耗尽时，切换到本机MTA（如Postfix或sendmail）能保障基础送达能力，尤其适合Linux生产环境。
立即学习“go语言免费学习笔记（深入）”；
- 用
exec.Command("/usr/sbin/sendmail", "-t")启动进程，将符合RFC 5322格式的原始邮件内容（含From/To/Subject/空行/正文）写入stdin - 无需配置账号密码，不依赖网络，MTA自动完成DNS查询、MX路由、队列持久化、退信归档等全套逻辑
- 建议封装统一发送接口：优先走SMTP，失败后自动fallback至sendmail，并记录日志供审计
结构清晰的批量发送骨架示例
以下为gomail风格的核心逻辑示意（非完整可运行代码，重在结构）：
// 初始化拨号器与连接池dialer := gomail.NewDialer(host, port, user, pass)
// 预建3个连接
var pool []*gomail.SendCloser
for i := 0; i < 3; i++ {
s, _ := dialer.Dial()
pool = append(pool, s)
}
// 分片分发任务
chunkSize := len(emails) / len(pool)
for i, chunk := range chunkEmails(emails, chunkSize) {
go func(s *gomail.SendCloser, mails []*gomail.Message) {
for _, m := range mails {
if err := s.Send(m); err != nil { /* 记录+跳过 */ }
}
}(pool[i], chunk)
}
