Huangzj
56 lines
1.0 KiB
Go
56 lines
1.0 KiB
Go
/*
|
||
* @Author : huangzj
|
||
* @Time : 2020/12/29 11:32
|
||
* @Description：
|
||
*/
|
||
|
||
package email
|
||
|
||
import (
|
||
"fmt"
|
||
"github.com/jordan-wright/email"
|
||
"log"
|
||
"net/smtp"
|
||
"os"
|
||
"sync"
|
||
"testing"
|
||
"time"
|
||
)
|
||
|
||
func TestEmailPool(t *testing.T) {
|
||
ch := make(chan *email.Email, 4)
|
||
//创建2个连接的邮件池
|
||
p, err := email.NewPool("smtp.qq.com:587", 2, smtp.PlainAuth("", "你的邮箱@qq.com", "你的stmp的密码", "smtp.qq.com"))
|
||
if err != nil {
|
||
log.Fatal("failed to create pool:", err)
|
||
}
|
||
|
||
//进行邮件发送
|
||
var wg sync.WaitGroup
|
||
wg.Add(2)
|
||
for i := 0; i < 2; i++ {
|
||
go func() {
|
||
defer wg.Done()
|
||
for e := range ch {
|
||
err := p.Send(e, 1*time.Second)
|
||
if err != nil {
|
||
_, _ = fmt.Fprintf(os.Stderr, "email:%v sent error:%v\n", e, err)
|
||
}
|
||
}
|
||
}()
|
||
}
|
||
|
||
//发送四个邮件
|
||
for i := 0; i < 4; i++ {
|
||
e := email.NewEmail()
|
||
e.From = "hzj <你的邮箱@qq.com>"
|
||
e.To = []string{"hzj <接受者的邮箱@qq.com>"}
|
||
e.Subject = "Awesome web"
|
||
e.Text = []byte(fmt.Sprintf("Awesome Web %d", i+1))
|
||
ch <- e
|
||
}
|
||
|
||
close(ch)
|
||
wg.Wait()
|
||
}
|