如何在Golang中实现并发邮件发送_Golang goroutine与SMTP发送方法_技术教程

直接用 goroutine 发 net/smtp.SendMail 易丢邮件，因其每次调用都新建 TCP+TLS 连接，无连接复用与并发控制，易触发 SMTP 限流或耗尽系统资源。

为什么直接用 goroutine 发 `net/smtp.SendMail` 容易丢邮件

因为 n

et/smtp.SendMail 是同步阻塞调用，但并发不等于“无节制起 goroutine”。没做任何限制地为每封邮件起一个 goroutine，可能瞬间创建数百个连接，触发 SMTP 服务器限流（如 Gmail 返回 421 4.7.0 Try again later），或耗尽本地文件描述符，导致 dial tcp: lookup smtp.gmail.com: no such host 这类看似 DNS 失败、实为系统资源枯竭的错误。

SMTP 连接建立开销大（TLS 握手 + 认证），频繁新建连接比复用慢得多
多数邮件服务商明确要求单 IP 单位时间发信上限（如 Outlook 限制 30 封/分钟）
net/smtp.SendMail 内部不复用连接，每次调用都新建 TCP+TLS 连接

用 `gomail` 库 + 限速池替代裸 goroutine

gomail 封装了连接池和重试逻辑，比手写更可靠。关键不是“用不用 goroutine”，而是“如何控制并发节奏”。推荐用带缓冲的 channel 控制并发数，再配合 gomail.Dialer 复用连接。

不要用 go d.DialAndSend(m) 直接并发——这仍会为每封邮件建新连接
用 gomail.NewDialer 创建一个复用连接的 *gomail.Dialer 实例，全局复用
用 make(chan *gomail.Message, 10) 做任务队列，另起固定数量 goroutine 消费（如 3–5 个）
每条消息发送后检查 err：非空时记录日志，但别 panic —— 邮件失败应降级处理，不影响其他消息

func sendWithRateLimit(d *gomail.Dialer, msgs <-chan *gomail.Message, workers int) {
    var wg sync.WaitGroup
    for i := 0; i < workers; i++ {
        wg.Add(1)
        go func() {
            defer wg.Done()
            for m := range msgs {
                if err := d.DialAndSend(m); err != nil {
                    log.Printf("send failed: %v", err)
                    // 可选：加入失败重试队列，或写入 DB 待人工处理
                }
                time.Sleep(2 * time.Second) // 强制限速，适配服务商策略
            }
        }()
    }
    wg.Wait()
}

`net/smtp` 手动复用连接的最小可行方案

如果因合规或调试需要绕过第三方库，必须自己管理连接。核心是：**连接复用 ≠ 全局单例**，而是在生命周期内复用同一 smtp.Client 实例，且确保并发安全。

smtp.Client 本身不是 goroutine-safe 的，不能多个 goroutine 同时调用 c.SendMail
正确做法：每个 worker goroutine 自己 Connect → Auth → 循环 SendMail → Close，连接生命周期与 goroutine 对齐
避免在 defer c.Close() 后继续用 c，否则会 panic：smtp: invalid state: cannot send mail after close
TLS 配置必须显式传入 &tls.Config{ServerName: "smtp.gmail.com"}，否则某些证书校验失败

func worker(smtpAddr, user, pass string, jobs <-chan emailJob) { c, err := smtp.Dial(smtpAddr) if err != nil { log.Printf("dial failed: %v", err) return } defer c.Close()

if err = c.Auth(smtp.PlainAuth("", user, pass, "smtp.gmail.com")); err != nil {
    log.Printf("auth failed: %v", err)
    return
}

for job := range jobs {
    if err = c.SendMail(job.from, job.to, job.msg); err != nil {
        log.Printf("send job %s failed: %v", job.id, err)
    }
}

}