使用 Golang 對接亞馬遜 Simple Email Service 傳送郵件

寫在前邊：國內有很多的郵件服務商，尤其幾個大的雲廠商都有非常成熟的郵件推送服務，如果可以的話，建議大家直接使用國內雲廠商的服務。我們公司因為做的國際業務，很多東西都在亞馬遜，所以拗不過我們老大，只能使用 AWS 的 SES；

進入正題，首先我們需要下載亞馬遜的 SDK ，執行 go get ，我這裡用的是 1。43。15 版本（不同版本之間亞馬遜可能會進行細微調整）。

go get github。com/aws/aws-sdk-go@v1。43。15

當然，基本上所有云廠商都支援使用 SMTP 的方式傳送郵件，各大語言均對 SMTP 有較好的支援，本文不介紹SMTP，介紹的是 SES 的模板傳送。

模板傳送的好處有很多，類似於強型別語言，雖然寫起來複雜，但是我們在編寫過程中的錯誤可以更好地暴露出來；其他優點不再贅述。

完整原始碼

先上程式碼，如果程式碼閱讀能力比較強的同學，可以直接拿走開始用了，使用方法比較簡單，將這個程式碼新建一個檔案，初始化一下，在需要發郵件的地方，呼叫即可，後邊會展開對下方程式碼的分析解讀；

tip: 程式碼裡邊的 xlog 是我們自己封裝的一個log包，換成fmt列印或者自己的日誌包

package aws_sesimport （ “context” “encoding/json” “github。com/aws/aws-sdk-go/aws” “github。com/aws/aws-sdk-go/aws/credentials” “github。com/aws/aws-sdk-go/aws/session” “github。com/aws/aws-sdk-go/service/sesv2” “github。com/aws/aws-sdk-go/service/sesv2/sesv2iface” “github。com/microcosm-cc/bluemonday”）const （ AwsRegion = “us-west-2” // 此處填寫你自己的亞馬遜所屬地區 Endpoint = “https：//email-smtp。us-west-2。amazonaws。com” // 此處是對應的所處地址 host FeedbackForwardingEmailAddress = “” // 發生錯誤時亞馬遜通知地址，前提是開通了aws配套的SNS 花不了多少錢，強烈建議開啟，否則你發不出來郵件，不知道怎麼回事兒。。。）type AwsSesRepo struct { SesV2BioAPI sesv2iface。SESV2API}func NewAwsSesRepo（） *AwsSesRepo { ctx ：= context。Background（） sess， err ：= session。NewSession（&aws。Config{ CredentialsChainVerboseErrors： nil， Credentials： credentials。NewStaticCredentials（accessKey， accessSecret， “”）， Endpoint： nil， EndpointResolver： nil， EnforceShouldRetryCheck： nil， Region： aws。String（AwsRegion）， DisableSSL： nil， HTTPClient： nil， LogLevel： nil， Logger： nil， MaxRetries： nil， Retryer： nil， DisableParamValidation： nil， DisableComputeChecksums： nil， S3ForcePathStyle： nil， S3Disable100Continue： nil， S3UseAccelerate： nil， S3DisableContentMD5Validation： nil， S3UseARNRegion： nil， LowerCaseHeaderMaps： nil， EC2MetadataDisableTimeoutOverride： nil， UseDualStackEndpoint： 0， UseFIPSEndpoint： 0， SleepDelay： nil， DisableRestProtocolURICleaning： nil， EnableEndpointDiscovery： nil， DisableEndpointHostPrefix： nil， STSRegionalEndpoint： 0， S3UsEast1RegionalEndpoint： 0， }） if err ！= nil { xlog。Error（ctx， “初始化亞馬遜 session 出錯”， “err”， err） return nil } svc ：= sesv2。New（sess） return &AwsSesRepo{ Conf： conf， SesV2BioAPI： svc， }}type SendEmailWithCtxParams struct { FromEmail string TemplateName string ToAddress ［］string BccAddress ［］string CcAddress ［］string TemplateData map［string］string}// 傳送郵件。func （r *AwsSesRepo） SendEmailWithContext（ctx context。Context， p *SendEmailWithCtxParams）（*sesv2。SendEmailOutput， error） { // 需要將結構體的內容json一下傳遞給發信介面 templateDataStr， err ：= json。Marshal（p。TemplateData） if err ！= nil { return nil， err } // 如果沒有設定from，建議在這個地方給個預設值 if len（p。FromEmail） == 0 { p。FromEmail = “demo@toutiao。com” //預設值 } // 呼叫 SDK 傳送郵件 resp， err ：= r。SesV2BioAPI。SendEmailWithContext（ctx， &sesv2。SendEmailInput{ ConfigurationSetName： aws。String（“default”）， // 設定集後邊有詳解 Content： &sesv2。EmailContent{ Raw： nil， // 原始傳送方式，需要自行拼裝各種引數。 Simple： nil， Template： &sesv2。Template{ // 使用模版方式傳送 TemplateArn： nil， TemplateData： aws。String（string（templateDataStr））， // 模版需要的 value TemplateName： aws。String（p。TemplateName）， // 模版的名稱必須唯一 }， }， Destination： &sesv2。Destination{ BccAddresses： aws。StringSlice（p。BccAddress）， // 密送 CcAddresses： aws。StringSlice（p。CcAddress）， // 抄送 ToAddresses： aws。StringSlice（p。ToAddress）， // 要發給誰 }， EmailTags： nil， // 郵件的標籤 FeedbackForwardingEmailAddress： nil， FeedbackForwardingEmailAddressIdentityArn： nil， FromEmailAddress： aws。String（p。FromEmail）， // 誰發出的 FromEmailAddressIdentityArn： nil， ListManagementOptions： nil， // 取消訂閱時的通知時間tag。 ReplyToAddresses： aws。StringSlice（［］string{“”}）， // 使用者收到郵件，進行回覆時的郵件地址。 }） return resp， err}// 建立模版。func （r *AwsSesRepo） CreateEmailTemplateWithContext（ctx context。Context， templateName， title， content string）（*sesv2。CreateEmailTemplateOutput， error） { p ：= bluemonday。UGCPolicy（） outPut， err ：= r。SesV2BioAPI。CreateEmailTemplateWithContext（ctx， &sesv2。CreateEmailTemplateInput{ TemplateContent： &sesv2。EmailTemplateContent{ Html： aws。String（content）， Subject： aws。String（title）， Text： aws。String（p。Sanitize（content））， }， TemplateName： aws。String（templateName）， }） return outPut， err}// 獲取單個郵件模版。func （r *AwsSesRepo） GetEmailTemplateWithContext（ctx context。Context， templateName string）（*sesv2。GetEmailTemplateOutput， error） { info， err ：= r。SesV2BioAPI。GetEmailTemplateWithContext（ctx， &sesv2。GetEmailTemplateInput{ TemplateName： aws。String（templateName）， }） if err ！= nil { xlog。Error（ctx， “GetEmailTemplateWithContext ”， “err”， err） return nil， err } return info， nil}// 修改模版func （r *AwsSesRepo） UpdateEmailTemplateWithContext（ctx context。Context， templateName， html， text， title string）（*sesv2。UpdateEmailTemplateOutput， error） { data， err ：= r。SesV2BioAPI。UpdateEmailTemplateWithContext（ctx， &sesv2。UpdateEmailTemplateInput{ TemplateContent： &sesv2。EmailTemplateContent{ Html： aws。String（html）， Subject： aws。String（title）， Text： aws。String（text）， }， TemplateName： aws。String（templateName）， }） if err ！= nil { xlog。Error（ctx， “UpdateEmailTemplateWithContext ”， “err”， err） return nil， err } return data， nil}// 批次獲取模版列表func （r *AwsSesRepo） ListEmailTemplatesWithContext（ctx context。Context， pageSize int64， cursor string）（*sesv2。ListEmailTemplatesOutput， error） { data， err ：= r。SesV2BioAPI。ListEmailTemplatesWithContext（ctx， &sesv2。ListEmailTemplatesInput{ NextToken： aws。String（cursor）， PageSize： aws。Int64（pageSize）， }） if err ！= nil { xlog。Error（ctx， “ListEmailTemplatesWithContext ”， “err”， err） return nil， err } return data， nil}

如何使用：

func main（）{ sesRepo ：= NewAwsSesRepo（） sesRepo。SendEmailWithContext（。。。。。）}

可以看到我只是對接了幾個簡單的介面

傳送郵件SendEmailWithContext建立模版CreateEmailTemplateWithContext獲取單個模版資訊GetEmailTemplateWithContext更新模版UpdateEmailTemplateWithContext批次獲取模版列表ListEmailTemplatesWithContext

其他的介面大家可以舉一反三，在自己實際業務情況下進行擴充，亞馬遜的 Golang SDK 提供了非常全面的操作介面，全都封裝在這個檔案中：

。。。mod/github。com/aws/aws-sdk-go@v1。43。15/service/sesv2/sesv2iface/interface。go

如圖所示：

亞馬遜Ses API 介面

詳解步驟

現在我們來逐步拆解，講解每一步引數都是從哪裡拿到的。核心的

關鍵引數

都會用

黃色背景加粗

展示。

登入亞馬遜賬號：

https：//signin。aws。amazon。com/signin

在亞馬遜中開通 SES 服務（強烈建議同時開通 SNS 服務，當我們傳送一個郵件不成功，尤其在除錯階段，希望知道失敗原因，比如模版引數不對，對方拒收等等，SES傳送完之後，會透過 SNS 進行回撥通知）簡單地說 SES 是發郵件的， SNS是郵件傳送之後的訊息佇列，用來推送郵件傳送過程中的任何階段結果。