This content originally appeared on DEV Community and was authored by Tayfur
Selamlar Ben Tayfur Kaya yeni Golang öğreniyorum ve size öğrenirken yaşadığım zorlukları ve avantajları bu projede göstermek istiyorum.
Bugün go dili ile yazmış olduğum basit bir email service inceleyeceğiz.
kullandığım teknolojiler RabbitMQ, Smtp, fiber ve Gorm
Github Reposuna gitmek istiyorsanız Github
Stmp
Golang ile basit bir sekilde gönderici olan mail adresine giriş yaparak istediğimiz email adresine mesajı html template olarak göndereceğiz
Html nasıl parse edilir ?
template.ParseFiles("./Templates/FeatureNotification.html")
yukarıda html dosyasını parse ediyoruz.
ve aşağıdaki gibi execute ediyoruz buradaki subject kısmı ise gönderilecek mailin title yazıyoruz..
templateBuffer.Write([]byte(fmt.Sprintf("Subject: Lates Features \n%s\n\n", mimeHeaders)))
t.Execute(&templateBuffer, nil)
Smtp ile mail göndermek
sendMail fonksiyonu hangi consumerden triggerlandıysa ilgili htmli parse ediyoruz
switch tamplate {
case "WelcomeQueue":
body = parseHtml.WelcomeTemplate()
break
case "WeeklyReportQueue":
body = parseHtml.WeeklyReportTemplate()
break
case "FeatureNotificationQueue":
body = parseHtml.FeatureNotificationTemplate()
break
}
err := smtp.SendMail(smtpHost+":"+smtpPort, auth, senderMail, to, []byte(body))
yukaradaki kod bloğunda mail adresimize authentication oluyoruz ve oldugumuz email adresinden to göndereceğimiz mail adresini içeriyor. msg kısmı ise gönderilecek olan mesajı içeriyor ama biz orada bir mesaj yerine html template göndereceğiz.
RabbitMQ
diyebilirsinizki yukarıda basit yazıyordu ne gerek var rabbitMQ kullanmaya!
Evet var çünkü gönderecek oldugumuz mailleri Message queue
ya göndermemiz gerekiyor, yaptıgımız app belki databaseden aldığımız mail adreslerine email atarken yarısında app crashe olabilir ve biz hangi mail adreslerine mail gönderildi hangisine gönderilmedi bunu bilemeyiz.
Birden fazla email templatemiz olabilir mesela welcome, verify, Feature Notification gibi farkettiginiz gibi bazıları Bulk(toplu gönderilen) mail bazıları Transaction(tekli ) mail.
Biz her template icin bir Consume ve Publish oluşturacağız böylelikle mail adresleri ilk önce queue gidicek sonra Consume"a iletilecek ve oradan templatine göre smtp ile maili göndereceğiz =)
Publish
RabbitMQ bağlantısı oluşturuyoruz
connectRabbitMQ, err := amqp.Dial(amqpServerURL)
consume ile haberleşmek için bir channel oluşturuyoruz
channelRabbitMQ, err := connectRabbitMQ.Channel()
yeni bir mesaj oluşturup bunu queue gönderiyoruz ama burdaki en önemli nokta verilen queue name"i çok önemli bu fonksiyonun çağrıldığı yerden alıyor ve mesajı o queue ismine göre gönderiyor bu sayede consume ederken her template icin farklı queue den onları alabileceğiz
message := amqp.Publishing{
ContentType: "text/plain",
Body: msg,
}
// mesaji publish eder.
if err := channelRabbitMQ.Publish(
"",// exchange
queueName,// queue name
false,
false,
message,
); err != nil {
return err
}
Consume
buradaki işlemlerde aynı sayılır ama bir farkla =)
queue deki mesajları okuyup her mesaj için bir sendMail fonksiyonunu trigger ediyor
forever := make(chan bool)
go func() {
for message := range messages {
to := []string{string(message.Body)}
//queue'dan gelen mesaji mail.Send fonksiyonuna gönder
mail.SendMail(to, queueName)
log.Printf(" > Received message: %s\n", message.Body)
}
}()
<-forever
Bulk Mail & Transaction Mail
Yukarıda bu ikisinden bahsetmiştik genel anlamda toplu gönderilen maillere Bulk ,ve sadece tekli işlemler için gönderilen maillere Transaction mail denir
db, err := db.ConnectDB()
if err != nil {
log.Fatal(err)
panic(err)
}
var User []models.User
db.Find(&User)
yukarıda diye bağlanıp dbdeki User ların hepsini arrayin içine alıyoruz
Aşağıda is User arrayini for döngüsüne alıp her user"ın maili için []byte a dönüştürüp bunu queue gönderiyoruz burada []byte a dönüştürmemizin sebebi RabbitMQ channeli byte ile haberleşmesi
for _, t := range User {
var to []byte
to = []byte(t.Email)
rabbitmq.Publisher(to, template)
}
Transaction maillerinde ise farklı farklı işlemler yapılabilir ama biz basit bir halde fiber endpointinden gelen mail adresine email göndereceğiz
Main
Main fonksiyonu içinde goroutine ile bütün consumeleri dinliyoruz bunlar hep açık kalıyor queue herhangi bir mail girdiğinde direkt bunları işleme gönderecek
WelcomeQueue := "WelcomeQueue"
WeeklyReportQueue := "WeeklyReportQueue"
FeatureNotificationQueue := "FeatureNotificationQueue"
// consumelari dinliyoruz
go rabbitmq.Consume(WeeklyReportQueue)
go rabbitmq.Consume(FeatureNotificationQueue)
go rabbitmq.Consume(WelcomeQueue)
Dediğim gibi Mailleri gönderirken fiber endpointleri trigger edicek aslında daha complex hale getirilebilir örneğin eğer diye yeni bir kullanıcı eklendiyse o indexteki maile welcomeTemplati göndermek gibi ama şimdi daha basit bir şekilde handle ediyoruz
app := fiber.New()
app.Use(
logger.New(), // add simple logger
)
app.Get("/FeatureNotification", func(c *fiber.Ctx) error {
go logic.BulkMail(FeatureNotificationQueue)
return c.SendString("Feature notification Sended")
})
app.Get("/WelcomeNotification", func(c *fiber.Ctx) error {
msg := []byte(c.Query("msg"))
logic.Transactional(msg,WelcomeQueue)
return c.SendString("Welcome Sended to "+string(msg))
})
conclusion
Bence go yazması çok keyifli bir dil ve kolayca service oluşturabiliyorsunuz eğer sizde benim gibi başka yazılım dillerinden geldiyseniz variables'a önem verin çünkü verileri çok defa convert etmem gerekti
umarım yazımı beğenmişsinizdir, yazım yanlışları için özür dilerim elimden geldiğince anlaşılır yazmaya çalıştım
This content originally appeared on DEV Community and was authored by Tayfur
Tayfur | Sciencx (2021-12-03T13:23:51+00:00) Go Smtp ve RabbitMQ ile Email servisi. Retrieved from https://www.scien.cx/2021/12/03/go-smtp-ve-rabbitmq-ile-email-servisi/
Please log in to upload a file.
There are no updates yet.
Click the Upload button above to add an update.