参考文档(php的) https://alidocs.dingtalk.com/i/nodes/XPwkYGxZV32YGrg7cYobvzvEWAgozOKL
本功能在以下环境下开发和测试：
● Go 1.18 以上
● MySQL
● Redis
● 支持mailgun和sendgrid两种邮件发送客户端
● 支持 1-redis限流 2-平滑加权轮询 两种域名选择算法模型. 邮件发送频率很低建议使用算法模型2.
发送域配置表
CREATE TABLE `email_domains` (
`id` int unsigned NOT NULL AUTO_INCREMENT,
`service_provider` tinyint unsigned NOT NULL COMMENT '服务商; 1: Mailgun, 2: Sendgrid',
`domain` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL COMMENT '发件域',
`api_key_id` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL COMMENT 'API KEY-ID',
`api_key` varchar(128) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL COMMENT 'API 密钥',
`priority` tinyint unsigned NOT NULL DEFAULT '0' COMMENT '优先级, 越小越优先',
`weight` tinyint unsigned DEFAULT '1' COMMENT '轮训算法权重',
`status` tinyint unsigned NOT NULL DEFAULT '0' COMMENT '状态; 0: 禁用, 1: 启用',
`created_at` int unsigned NOT NULL DEFAULT '0',
`updated_at` int unsigned NOT NULL DEFAULT '0',
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=14 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci;示例数据 ● 新域名的优先级高，优先级为 0
INSERT INTO `email_domains` (`id`, `service_provider`, `domain`, `api_key_id`, `api_key`, `priority`, `weight`, `status`, `created_at`, `updated_at`) VALUES (1, 1, 'mail.parcelpanel.net', 'xxxx', 'xxxx', 0, 1, 1, 1716430043, 0);● 旧域名的优先级为最低的，往大了设置，这里设置为 99
INSERT INTO `email_domains` (`id`, `service_provider`, `domain`, `api_key_id`, `api_key`, `priority`, `status`, `created_at`, `updated_at`) VALUES (13, 1, 'edms.parcelpanel.net', 'xxxx', 'xxxx', 99, 1, 1, 1716437113, 0);发送规则表
CREATE TABLE `email_send_rules` (
`id` int unsigned NOT NULL AUTO_INCREMENT,
`domain_id` int unsigned NOT NULL DEFAULT '0',
`started_at` int unsigned NOT NULL DEFAULT '0',
`ended_at` int unsigned NOT NULL DEFAULT '0',
`total_send_count` int unsigned NOT NULL DEFAULT '0' COMMENT '预计总发送量',
`sent_count` int unsigned NOT NULL DEFAULT '0' COMMENT '已发数量',
`status` tinyint unsigned NOT NULL DEFAULT '0' COMMENT '启用状态; 0: 禁用, 1: 启用',
`created_at` int unsigned NOT NULL DEFAULT '0',
`updated_at` int unsigned NOT NULL DEFAULT '0',
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=4 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci;
```sql
示例数据
● 将旧发送域作为 fallback 发送域，开始结束时间分别设置为字段的最大最小值，started_at 设置为 0 表示一直可以发送，不会进入发送量控制的逻辑
```sql
INSERT INTO `email_send_rules` (`domain_id`, `started_at`, `ended_at`, `total_send_count`, `sent_count`, `status`, `created_at`, `updated_at`) VALUES (13, 0, 4294967295, 0, 4022820, 1, 1716858270, 0);● 给 ID 为 1 的发送域新增一条 2024-05-28 10:00 - 2024-05-29 9:59 时间段的发送规则，预计发送 50 封，则每封发送间隔至少会间隔 1728s
INSERT INTO `email_send_rules` (`domain_id`, `started_at`, `ended_at`, `total_send_count`, `sent_count`, `status`, `created_at`, `updated_at`) VALUES (1, 1716861600, 1716947999, 50, 0, 1, 1716858595, 0);- 选择发送域
- 获取邮件配置信息
- 创建 Sender 实例
- 发送邮件
- 记录日志
- 标记发送规则为已完成
main.go中是使用示例
//依次传入redis客户端, mysql连接客户端, 域名选择算法模型(1-redis限流 2-平滑加权轮询)
emailSenderSrv := sender.NewSenderManager(redisCli, db, 2)
send, err := emailSenderSrv.Send(content)