Go 群发邮件Redis 实现邮件群发

一、安装

go get github.com/go-redis/redis/v8
go get gopkg.in/gomail.v2

 二、使用"gopkg.in/gomail.v2"群发 

package mainimport (gomail "gopkg.in/gomail.v2"
)func main() {// 邮件内容m := gomail.NewMessage()m.SetHeader("From", "[e-mail]")m.SetHeader("To", "[e-mail]")m.SetHeader("Subject", "邮件标题")m.SetBody("text/html", "<h2>邮件内容</h2>")// 邮件服务器账号密码// func NewDialer(host string, port int, username, password string) *Dialerd := gomail.NewDialer("smtp.163.com",25,"[e-mail]","password",)// 发送邮件d.DialAndSend(m)
}

 三、邮箱服务配置，以QQ邮箱为例 

四、示例代码 

package mainimport ("context""fmt"redis "github.com/go-redis/redis/v8""gopkg.in/gomail.v2""gopkg.in/ini.v1""log""time"
)func main() {// 1、连接redis，确保redis服务已开启// 创建一个Redis客户端实例rdb := redis.NewClient(&redis.Options{Addr:     "localhost:6379", // Redis 服务器地址Password: "",               // 没有密码就留空DB:       0,                // 使用默认DB})// 关闭 Redis 连接defer rdb.Close()ctx := context.Background()// 检查连接pong, err := rdb.Ping(context.Background()).Result()if err != nil {fmt.Println("连接Redis失败", err)return}fmt.Println(pong) // 输出 PING 命令的响应// 模拟添加邮件到待发送队列email1 := "[e-mail]"email2 := "[e-mail]"email3 := "[e-mail]"// 使用LPush命令向名为'my_list'的列表中添加元素//values := []interface{}{"[e-mail]", "[e-mail]", "[e-mail]"}//err := rdb.LPush(ctx, "email_queue", email1, email2, email3).Err()err = rdb.LPush(ctx, "email_queue", email1, email2, email3).Err()if err != nil {log.Fatalf("无法推送到列表: %v", err)}// 初始化邮件发送配置cfg, err := ini.Load("conf/email_config.ini")if err != nil {log.Fatalf("加载邮件配置失败: %v", err)}sender := cfg.Section("AUTHENTICATION").Key("username").String()password := cfg.Section("AUTHENTICATION").Key("password").String()smtpServer := cfg.Section("SMTP_SERVER").Key("smtp_server").String()smtpPort := cfg.Section("SMTP_SERVER").Key("smtp_port").MustInt(587)// 连接到 SMTP 服务器d := gomail.NewDialer(smtpServer, smtpPort, sender, password)// 循环处理邮件队列for {// 从 Redis 队列中获取邮件email, err := rdb.RPop(ctx, "email_queue").Result()if err == redis.Nil {// 队列为空，退出循环fmt.Println("电子邮件队列为空。")break} else if err != nil {log.Fatalf("无法从队列中获取电子邮件: %v", err)}// 创建邮件消息m := gomail.NewMessage()m.SetHeader("From", cfg.Section("EMAIL").Key("from").String())m.SetHeader("To", email)m.SetHeader("Subject", cfg.Section("EMAIL").Key("subject").String())// 设置邮件内容m.SetBody("text/plain", cfg.Section("EMAIL").Key("body").String())// 发送邮件if err := d.DialAndSend(m); err != nil {log.Fatalf("无法将电子邮件发送到:%s: %v", email, err)}// 模拟邮件发送后的一些操作fmt.Printf("发送电子邮件至:%s\n", email)time.Sleep(5 * time.Second) // 可以添加一些延迟以限制发送速率}
}

 五、邮件配置

# 以QQ邮箱为例
[SMTP_SERVER]
smtp_server = smtp.qq.com
#587或465，具体取决于SMTP服务器配置
smtp_port = 587[AUTHENTICATION]
# 发送者邮箱
username = [e-mail]
# 授权码，不是登录密码
password = aafrsdgsgsssfqw[EMAIL]
# 发送者邮箱
from = [e-mail]
subject = Test Email(邮件主题)
body = 这是我的应用程序发送的测试电子邮件。[SECURITY]
use_tls = yes
tls_insecure_skip_verify = no;这个配置文件包含以下部分：
;SMTP_SERVER: 存储 SMTP 服务器的主机名和端口号。
;AUTHENTICATION: 存储用于邮件认证的用户名和密码。
;EMAIL: 存储发送邮件时使用的发件人地址、邮件主题和邮件正文。
;SECURITY: 存储安全设置，比如是否使用 TLS 加密以及是否跳过 TLS 证书验证。
;请注意，你需要将示例中的占位符（如 smtp.example.com、[e-mail] 和 your_password）替换为实际的值。此外，use_tls 和 tls_insecure_skip_verify 用于配置安全选项，具体值取决于你的邮件服务器配置。
;在实际使用中，出于安全考虑，不建议在配置文件中明文存储密码。可以使用环境变量或加密存储密码的方式来提高安全性。