go get github.com/jordan-wright/email
go get -u github.com/gin-gonic/gin
go get github.com/redis/go-redis/v9

package main
import (
	"fmt"
	"net/smtp"
	"github.com/jordan-wright/email"
)
func main() {
	targetMailBox := ""          // 目標(biāo)郵箱
	smtpServer := "smtp.163.com" // smtp服務(wù)器
	emailAddr := ""              // 要發(fā)件的郵箱地址
	smtpKey := ""                // 獲取的smtp密鑰
	em := email.NewEmail()
	em.From = fmt.Sprintf("Go-Cloud-Disk <%s>", emailAddr) // 發(fā)件人
	em.To = []string{targetMailBox}                        // 目標(biāo)郵箱
	// email title
	em.Subject = "Email Confirm Test" // 標(biāo)題
	// build email content
	em.Text = []byte("test") // 內(nèi)容
	// 調(diào)用接口發(fā)送郵件
    // 此處端口號(hào)不一定為25使用對應(yīng)郵箱時(shí)需要具體更換
	em.Send(smtpServer+":25", smtp.PlainAuth("", emailAddr, smtpKey, smtpServer))
}

package main
import (
	"context"
	"os"
	"strconv"
	"github.com/redis/go-redis/v9"
)
var RedisClient *redis.Client
// init redis
func Redis() {
	db, _ := strconv.ParseUint(os.Getenv("REDIS_DB"), 10, 64) //可不填
	client := redis.NewClient(&redis.Options{
		Addr:       "127.0.0.1:6379", // Redis默認(rèn)地址
		Password:   "", // Redis密碼，一般建立時(shí)不設(shè)置
		DB:         int(db),
		MaxRetries: 1,
	})
	_, err := client.Ping(context.Background()).Result()
	if err != nil {
		panic("can't connect redis")
	}
	RedisClient = client
}

func VerifyEmailFormat(email string) bool {
	pattern := `^[^\s@]+@[^\s@]+\.[^\s@]+$` //match email
	reg := regexp.MustCompile(pattern)
	return reg.MatchString(email)
}

// SendConfirmMessage傳入目標(biāo)郵箱以及對應(yīng)的Code碼即可發(fā)送驗(yàn)證碼郵件
func SendConfirmMessage(targetMailBox string, code string) error {
	em := email.NewEmail()
	em.From = fmt.Sprintf("Go-Cloud-Disk <%s>", os.Getenv("EMAIL_ADDR"))
	em.To = []string{targetMailBox}
	// 郵箱標(biāo)題
	em.Subject = "Email Confirm Code " + code
	// 郵件內(nèi)容
	emailContentCode := "you confirm code is " + code + ", Your code will expire in 30 minutes"
	emailContentEmail := "you confirm email is " + targetMailBox
	emailContent := emailContentCode + "\n" + emailContentEmail
	em.Text = []byte(emailContent)
	// 調(diào)用發(fā)送郵件函數(shù)
	em.Send(os.Getenv("EMAIL_SMTP_SERVER")+":25", smtp.PlainAuth("", os.Getenv("EMAIL_ADDR"), os.Getenv("EMAIL_SECRET_KEY"), os.Getenv("EMAIL_SMTP_SERVER")))
	return nil
}

type UserSendConfirmEmailService struct {
	UserEmail string `json:"email" form:"email" binding:"required"`
}

func getConfirmCode() string {
	var confirmCode int
	for i := 0; i < 6; i++ {
		confirmCode = confirmCode*10 + (rand.Intn(9) + 1) //隨機(jī)函數(shù)獲取值
	}
    // 轉(zhuǎn)換成字符串
	confirmCodeStr := strconv.Itoa(confirmCode)
	return confirmCodeStr
}

func (service *UserSendConfirmEmailService) SendConfirmEmail() string {
	// 檢查是否為正確郵箱
	if !VerifyEmailFormat(service.UserEmail) {
		return "NotEmail"
	}
	// 檢查是否在3分鐘內(nèi)發(fā)送過郵件
	if RedisClient.Get(context.Background(), "send-email:"+service.UserEmail).Val() != "" {
		return "HasSendCode"
	}
    // 獲取六位數(shù)郵箱驗(yàn)證碼
	code := getConfirmCode()
    // 將其存儲(chǔ)至Redis中，由于Redis為KV鍵值對存儲(chǔ)所以需要定義前綴方便使用
	RedisClient.Set(context.Background(), "email:"+service.UserEmail, code, time.Minute*30)
    // 發(fā)送郵件，此處為方便起見沒有處理返回值
	SendConfirmMessage(service.UserEmail, code)
	// 設(shè)置每個(gè)郵箱發(fā)送郵件的時(shí)間 此處設(shè)置為3分鐘，由于Redis為KV鍵值對存儲(chǔ)所以需要定義前綴方便使用
	RedisClient.Set(context.Background(), "send-email:"+service.UserEmail, code, time.Minute*3)
	return "true"
}

func ConfirmUserEmail(c *gin.Context) {
	var service UserSendConfirmEmailService
	if err := c.ShouldBind(&service); err != nil { //使用ShouldBind綁定傳入?yún)?shù)
		c.JSON(200, "ParmaErr")
		return
	}
	res := service.SendConfirmEmail()
	c.JSON(200, res)
}

func main() {
	Redis() // 初始化Redis
	server := gin.Default()
	server.POST("email", ConfirmUserEmail) // 注冊函數(shù)至localhost:3030/email
	server.Run(":3030") // 服務(wù)具體運(yùn)行端口
}

code := cache.RedisClient.Get(context.Background(), "email:"+service.UserEmail).Val()