go?smtp實(shí)現(xiàn)郵件發(fā)送示例詳解
更新時(shí)間：2022年05月19日 15:44:09 作者：dz45693
這篇文章主要為大家介紹了go?smtp實(shí)現(xiàn)郵件發(fā)送示例詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪
smtp指令
書接上文郵件實(shí)現(xiàn)詳解，這里我們及我們簡(jiǎn)單復(fù)習(xí)一下smtp的指令如下：
telnet smtp.163.com 25 [outpout] ehlo dz45693 [outpout] auth login [outpout] 輸入用戶名base64 [outpout] 輸入密碼base64 mail from:<dz45693@163.com> [outpout] rcpt to:<dz45693@sina.com> [outpout] data [outpout] from:<dz45693@163.com> to:<dz45693@sina.com> subject:hello world This is the first email sent by hand using the SMTP protocol quit
go demo
好，那我們下現(xiàn)在用go實(shí)現(xiàn)代碼讓如下：這里只是一個(gè)demo，主要熟悉smtp命令
package main
import (
"bufio"
"encoding/base64"
"fmt"
"net"
"strconv"
"strings"
)
func main() {
testSmtp()
}
var gConn net.Conn
var gRead *bufio.Reader
var gWrite *bufio.Writer
//可以放到這樣的類里
type TcpClient struct {
Conn net.Conn
Read *bufio.Reader
Write *bufio.Writer
} //
func Connect(host string, port int) (net.Conn, *bufio.Reader, *bufio.Writer) {
addr := host + ":" + strconv.Itoa(port)
conn, err := net.Dial("tcp", addr)
if err != nil {
return nil, nil, nil
}
reader := bufio.NewReader(conn)
writer := bufio.NewWriter(conn)
return conn, reader, writer
} //
//收取一行,可再優(yōu)化
func RecvLine() string {
line, err := gRead.ReadString('\n') //如何設(shè)定超時(shí)?
if err != nil {
fmt.Print(err)
return ""
}
line = strings.Split(line, "\r")[0] //還要再去掉 "\r"，其實(shí)不去掉也可以
return line
}
func SendLine(line string) {
gWrite.WriteString(line + "\r\n")
gWrite.Flush()
}
//解碼一行命令,這里比較簡(jiǎn)單就是按空格進(jìn)行分隔就行了
func DecodeCmd(line string, sp string) []string {
tmp := strings.Split(line, sp)
var cmds = []string{"", "", "", "", ""} //先定義多幾個(gè)，以面后面使用時(shí)產(chǎn)生異常
for i := 0; i < len(tmp); i++ {
if i >= len(cmds) {
break
}
cmds[i] = tmp[i]
}
return cmds
}
//讀取多行結(jié)果
func RecvMCmd() string {
i := 0
rs := ""
mLine := ""
for i = 0; i < 50; i++ {
rs = RecvLine() //只收取一行
mLine = mLine + rs + "\r\n"
if len(rs) < 4 {
break
} //長(zhǎng)度要足夠
c4 := rs[4-1] //第4個(gè)字符
if ' ' == c4 {
break
} //第4個(gè)字符是空格就表示讀取完了//也可以判斷 "250[空格]"
}
return mLine
}
//簡(jiǎn)單的測(cè)試一下 smtp
func testSmtp() {
//連接
gConn, gRead, gWrite = Connect("smtp.163.com", 25)
defer gConn.Close()
//收取一行
line := RecvLine()
fmt.Println("recv:" + line)
//解碼一下,這樣后面的 EHLO 才能有正確的第二個(gè)參數(shù)
cmds := DecodeCmd(line, " ")
domain := cmds[1] //要從對(duì)方的應(yīng)答中取出域名//空格分開的各個(gè)命令參數(shù)中的第二個(gè)
//發(fā)送一個(gè)命令
SendLine("EHLO" + " " + domain) //domain 要求其實(shí)來自 HELO 命令//HELO <SP> <domain> <CRLF>
//收取多行
line = RecvMCmd()
fmt.Println("recv:" + line)
//--------------------------------------------------
//用 base64 登錄
SendLine("AUTH LOGIN")
//收取一行
line = RecvLine()
fmt.Println("recv:" + line)
s := "dz45693" //要換成你的用戶名,注意 163 郵箱的話不要帶后面的 @域名 部分
s = base64.StdEncoding.EncodeToString([]byte(s))
SendLine(s)
//收取一行
line = RecvLine()
fmt.Println("recv:" + line)
s = "xxxxx" //要換成您的密碼
s = base64.StdEncoding.EncodeToString([]byte(s))
SendLine(s)
//收取一行
line = RecvLine()
fmt.Println("recv:" + line)
//--------------------------------------------------
//郵件內(nèi)容
from := "dz45693@163.com"
to := "dz45693@sina.com"
SendLine("MAIL FROM: <" + from + ">") //注意"<" 符號(hào)和前面的空格。空格在協(xié)議中有和沒有都可能，最好還是有
//收取一行
line = RecvLine()
fmt.Println("recv:" + line)
SendLine("RCPT TO: <" + to + ">")
//收取一行
line = RecvLine()
fmt.Println("recv:" + line)
SendLine("DATA")
//收取一行
line = RecvLine()
fmt.Println("recv:" + line)
//發(fā)送郵件頭
SendLine("from:<dz45693@163.com>")
SendLine("to:<dz45693@sina.com>")
SendLine("subject:hello world")
SendLine("") //發(fā)送空行 后面就是郵件體
SendLine("This is the first email sent by hand using the SMTP protocol")
SendLine(".") //郵件結(jié)束符
//收取一行
line = RecvLine()
fmt.Println("recv:" + line)
SendLine("quit") //鏈接推出
line = RecvLine()
fmt.Println("recv:" + line)
} //運(yùn)行結(jié)果如下：
sdk中SendMail方法
在go的sdk中提供了SendMail方法【發(fā)送郵件后這個(gè)方法會(huì)關(guān)閉鏈接】，實(shí)現(xiàn)如下：
實(shí)現(xiàn)如下：
func SendMailBySmtp(){
auth := smtp.PlainAuth("", "dz45693@163.com", "xxx", "smtp.163.com")
to := []string{"dz45693@sina.com"}
image,_:=ioutil.ReadFile("d:\\Downloads\\1.png")
imageBase64:=base64.StdEncoding.EncodeToString(image)
msg := []byte("from:dz45693@163.com\r\n"+
"to: dz45693@sina.com\r\n" +
"Subject: hello,subject!\r\n"+
"Content-Type:multipart/mixed;boundary=a\r\n"+
"Mime-Version:1.0\r\n"+
"\r\n" +
"--a\r\n"+
"Content-type:text/plain;charset=utf-8\r\n"+
"Content-Transfer-Encoding:quoted-printable\r\n"+
"\r\n"+
"此處為正文內(nèi)容!\r\n"+
"--a\r\n"+
"Content-type:image/jpg;name=1.jpg\r\n"+
"Content-Transfer-Encoding:base64\r\n"+
"\r\n"+
imageBase64+"\r\n"+
"--a--\r\n")
err := smtp.SendMail("smtp.163.com:25", auth, "dz45693@163.com", to, msg)
if err != nil {
fmt.Println(err)
}
}運(yùn)行效果：
使用第三方庫gomail實(shí)現(xiàn)郵件的發(fā)送更多了解，
請(qǐng)前往：https://pkg.go.dev/gopkg.in/gomail.v2?utm_source=godoc
示例如下：
func SendMailByGomailOne(){
m := gomail.NewMessage()
m.SetAddressHeader("From", "dz45693@163.com", "dz45693")
m.SetHeader("To", "dz45693@sina.com")
m.SetHeader("Subject", "hello SendMailByGomailOne!")
m.Embed("d:\\Downloads\\1.png")
m.SetBody("text/html", "此處為正文121333!")
d := gomail.NewDialer("smtp.163.com", 25, "dz45693@163.com", "xxxx")
if err := d.DialAndSend(m); err != nil {
panic(err)
}
}運(yùn)行結(jié)果：
DialAndSend實(shí)現(xiàn)
來我們看看DialAndSend的實(shí)現(xiàn)如下：
package gomail
import (
"crypto/tls"
"fmt"
"io"
"net"
"net/smtp"
"strings"
"time"
)
// A Dialer is a dialer to an SMTP server.
type Dialer struct {
// Host represents the host of the SMTP server.
Host string
// Port represents the port of the SMTP server.
Port int
// Username is the username to use to authenticate to the SMTP server.
Username string
// Password is the password to use to authenticate to the SMTP server.
Password string
// Auth represents the authentication mechanism used to authenticate to the
// SMTP server.
Auth smtp.Auth
// SSL defines whether an SSL connection is used. It should be false in
// most cases since the authentication mechanism should use the STARTTLS
// extension instead.
SSL bool
// TSLConfig represents the TLS configuration used for the TLS (when the
// STARTTLS extension is used) or SSL connection.
TLSConfig *tls.Config
// LocalName is the hostname sent to the SMTP server with the HELO command.
// By default, "localhost" is sent.
LocalName string
}
// NewDialer returns a new SMTP Dialer. The given parameters are used to connect
// to the SMTP server.
func NewDialer(host string, port int, username, password string) *Dialer {
return &Dialer{
Host: host,
Port: port,
Username: username,
Password: password,
SSL: port == 465,
}
}
// NewPlainDialer returns a new SMTP Dialer. The given parameters are used to
// connect to the SMTP server.
//
// Deprecated: Use NewDialer instead.
func NewPlainDialer(host string, port int, username, password string) *Dialer {
return NewDialer(host, port, username, password)
}
// Dial dials and authenticates to an SMTP server. The returned SendCloser
// should be closed when done using it.
func (d *Dialer) Dial() (SendCloser, error) {
conn, err := netDialTimeout("tcp", addr(d.Host, d.Port), 10*time.Second)
if err != nil {
return nil, err
}
if d.SSL {
conn = tlsClient(conn, d.tlsConfig())
}
c, err := smtpNewClient(conn, d.Host)
if err != nil {
return nil, err
}
if d.LocalName != "" {
if err := c.Hello(d.LocalName); err != nil {
return nil, err
}
}
if !d.SSL {
if ok, _ := c.Extension("STARTTLS"); ok {
if err := c.StartTLS(d.tlsConfig()); err != nil {
c.Close()
return nil, err
}
}
}
if d.Auth == nil && d.Username != "" {
if ok, auths := c.Extension("AUTH"); ok {
if strings.Contains(auths, "CRAM-MD5") {
d.Auth = smtp.CRAMMD5Auth(d.Username, d.Password)
} else if strings.Contains(auths, "LOGIN") &&
!strings.Contains(auths, "PLAIN") {
d.Auth = &loginAuth{
username: d.Username,
password: d.Password,
host: d.Host,
}
} else {
d.Auth = smtp.PlainAuth("", d.Username, d.Password, d.Host)
}
}
}
if d.Auth != nil {
if err = c.Auth(d.Auth); err != nil {
c.Close()
return nil, err
}
}
return &smtpSender{c, d}, nil
}
func (d *Dialer) tlsConfig() *tls.Config {
if d.TLSConfig == nil {
return &tls.Config{ServerName: d.Host}
}
return d.TLSConfig
}
func addr(host string, port int) string {
return fmt.Sprintf("%s:%d", host, port)
}
// DialAndSend opens a connection to the SMTP server, sends the given emails and
// closes the connection.
func (d *Dialer) DialAndSend(m ...*Message) error {
s, err := d.Dial()
if err != nil {
return err
}
defer s.Close()
return Send(s, m...)
}
type smtpSender struct {
smtpClient
d *Dialer
}
func (c *smtpSender) Send(from string, to []string, msg io.WriterTo) error {
if err := c.Mail(from); err != nil {
if err == io.EOF {
// This is probably due to a timeout, so reconnect and try again.
sc, derr := c.d.Dial()
if derr == nil {
if s, ok := sc.(*smtpSender); ok {
*c = *s
return c.Send(from, to, msg)
}
}
}
return err
}
for _, addr := range to {
if err := c.Rcpt(addr); err != nil {
return err
}
}
w, err := c.Data()
if err != nil {
return err
}
if _, err = msg.WriteTo(w); err != nil {
w.Close()
return err
}
return w.Close()
}
func (c *smtpSender) Close() error {
return c.Quit()
}
// Stubbed out for tests.
var (
netDialTimeout = net.DialTimeout
tlsClient = tls.Client
smtpNewClient = func(conn net.Conn, host string) (smtpClient, error) {
return smtp.NewClient(conn, host)
}
)
type smtpClient interface {
Hello(string) error
Extension(string) (bool, string)
StartTLS(*tls.Config) error
Auth(smtp.Auth) error
Mail(string) error
Rcpt(string) error
Data() (io.WriteCloser, error)
Quit() error
Close() error
}DialAndSend ,首先調(diào)用Dial方法創(chuàng)建連接，然后發(fā)送郵件，最后關(guān)閉鏈接，如果要頻繁發(fā)郵件，那么是否保持長(zhǎng)連接更好了？這里的Dial 調(diào)用了smtp.NewClient 創(chuàng)建smtp.Client對(duì)象c,然后調(diào)用c.Hello ,c.Auth，send 實(shí)際是調(diào)用c.Mail,c.Rcpt,c.Data，那么我們可以自己調(diào)用Dial方法 然后循環(huán)調(diào)用send方法，最后在close。
代碼如下：
func SendMailByGomailTwo() {
d := gomail.NewDialer("smtp.163.com", 25, "dz45693@163.com", "xxxx")
m := gomail.NewMessage()
m.SetAddressHeader("From", "dz45693@163.com", "dz45693")
m.SetHeader("To", "dz45693@sina.com")
m.SetHeader("Subject", "hello SendMailByGomailtwo!")
m.Embed("d:\\Downloads\\1.png")
m.SetBody("text/html", "此處為正文121333!SendMailByGomailtwo")
s, err := d.Dial()
if err != nil {
panic(err)
}
defer s.Close()
err = gomail.Send(s, m)
if err != nil {
panic(err)
}
m.Reset()
m.SetAddressHeader("From", "dz45693@163.com", "dz45693")
m.SetHeader("To", "dz45693@sina.com")
m.SetHeader("Subject", "hello SendMailByGomailthree!")
m.Embed("d:\\Downloads\\2.png")
m.SetBody("text/html", "此處為正文1SendMailByGomailthreeSendMailByGomailthree!")
err = gomail.Send(s, m)
if err != nil {
panic(err)
}
}運(yùn)行結(jié)果：
以上就是go smtp實(shí)現(xiàn)郵件發(fā)送示例詳解的詳細(xì)內(nèi)容，更多關(guān)于go smtp郵件發(fā)送的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！
相關(guān)文章
go語言區(qū)塊鏈實(shí)戰(zhàn)實(shí)現(xiàn)簡(jiǎn)單的區(qū)塊與區(qū)塊鏈
這篇文章主要為大家介紹了go語言區(qū)塊鏈的實(shí)戰(zhàn)學(xué)習(xí)，來實(shí)現(xiàn)簡(jiǎn)單的區(qū)塊與區(qū)塊鏈?zhǔn)纠^程，有需要的朋友可以借鑒參考下，希望能夠有所幫助2021-10-10
在 Golang 中，errors 包是用于處理錯(cuò)誤的標(biāo)準(zhǔn)庫， errors 包提供的功能比較簡(jiǎn)單，使用起來非常方便，接下來就具體講解一下 errors 包提供的幾個(gè)函數(shù)，感興趣的小伙伴跟著小編一起來看看吧2023-07-07
GO?CountMinSketch計(jì)數(shù)器(布隆過濾器思想的近似計(jì)數(shù)器)
這篇文章主要介紹了GO?CountMinSketch計(jì)數(shù)器(布隆過濾器思想的近似計(jì)數(shù)器),文章圍繞主題展開詳細(xì)的內(nèi)容介紹，具有一定的參考價(jià)值，需要的朋友可以參考一下2022-09-09
Golang?動(dòng)態(tài)腳本調(diào)研詳解
這篇文章主要為大家介紹了Golang?動(dòng)態(tài)腳本調(diào)研詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2022-09-09
這篇文章主要介紹了golang逐行讀取文件的操作，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過來看看吧2020-12-12
本文主要介紹了深入理解Go語言中的結(jié)構(gòu)體,包括定義結(jié)構(gòu)體、聲明結(jié)構(gòu)體變量、使用結(jié)構(gòu)體、結(jié)構(gòu)體關(guān)聯(lián)函數(shù)、new、組合等,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2023-11-11
這篇文章主要介紹了golang http請(qǐng)求封裝代碼，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過來看看吧2020-12-12
這篇文章介紹了Go語言通道之緩沖通道，文中通過示例代碼介紹的非常詳細(xì)。對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2022-07-07
零拷貝是相對(duì)于用戶態(tài)來講的，即數(shù)據(jù)在用戶態(tài)不發(fā)生任何拷貝，那么零拷貝的原理是什么，又是如何實(shí)現(xiàn)的呢，下面小編就來和大家詳細(xì)聊聊吧2023-08-08
這篇文章主要給大家介紹了關(guān)于在docker中部署golang項(xiàng)目的步驟，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧。2017-11-11