Tìm hiểu về spring boot - Bài 17: Spring boot mail

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>vn.techmaster</groupId>
        <artifactId>mastering-spring-boot</artifactId>
        <version>1.0.0</version>
    </parent>

    <artifactId>spring-boot-mail</artifactId>

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-dependencies</artifactId>
                <version>${spring.boot.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-mail</artifactId>
        </dependency>
        <dependency>
            <groupId>com.mysql</groupId>
            <artifactId>mysql-connector-j</artifactId>
            <version>${mysql.version}</version>
        </dependency>
    </dependencies>
</project>

spring:
  mail:
    host: smtp.ethereal.email
    port: 587
    username: maddison53@ethereal.email
    password: jn7jnAPss4f63QBp6D
    properties:
      mail:
        smtp:
          auth: true
          starttls:
            enable: true
            required: truespring:
  mail:
    host: smtp.ethereal.email
    port: 587
    username: maddison53@ethereal.email
    password: jn7jnAPss4f63QBp6D
    properties:
      mail:
        smtp:
          auth: true
          starttls:
            enable: true
            required: true

package vn.techmaster.mail.service;

import lombok.AllArgsConstructor;
import org.springframework.mail.SimpleMailMessage;
import org.springframework.mail.javamail.JavaMailSender;
import org.springframework.stereotype.Service;

@Service
@AllArgsConstructor
public class EmailService {

    private final JavaMailSender mailSender;

    public void sendMail(
        String from,
        String to,
        String subject,
        String text
    ) {
        SimpleMailMessage message = new SimpleMailMessage();
        message.setFrom(from);
        message.setTo(to);
        message.setSubject(subject);
        message.setText(text);
        mailSender.send(message);
    }
}

package vn.techmaster.mail;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.ApplicationContext;
import vn.techmaster.mail.service.EmailService;

@SpringBootApplication
public class SpringBootMailStartUp {

    public static void main(String[] args) {
        ApplicationContext applicationContext = SpringApplication
            .run(SpringBootMailStartUp.class);
        EmailService emailService = applicationContext
            .getBean(EmailService.class);
        emailService.sendMail(
            "\"Techmaster 👻\" <ta.van.dung@techmaster.vn>",
            "itprono3@gmail.com",
            "Hello ✔",
            "<b>Hello world?</b>"
        );
    }
}

package vn.techmaster.mail.service;

import org.springframework.mail.SimpleMailMessage;
import org.springframework.mail.javamail.JavaMailSender;
import org.springframework.stereotype.Service;

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;

@Service
public class EmailService {

    private final JavaMailSender mailSender;
    private final BlockingQueue<SimpleMailMessage> queue;

    public EmailService(JavaMailSender mailSender) {
        this.mailSender = mailSender;
        this.queue = new LinkedBlockingQueue<>();
        this.start();
    }

    private void start() {
        Thread newThread = new Thread(() -> {
           while (true) {
               try {
                   SimpleMailMessage mail = queue.take();
                   mailSender.send(mail);
                   System.out.println("sent mail: " + mail);
               } catch (InterruptedException e) {
                   break;
               } catch (Throwable e) {
                   System.out.println("send mail error: " + e);
               }
           }
        });
        newThread.setName("mail-sender");
        newThread.start();
    }

    public void sendMail(
        String from,
        String to,
        String subject,
        String text
    ) {
        SimpleMailMessage mail = new SimpleMailMessage();
        mail.setFrom(from);
        mail.setTo(to);
        mail.setSubject(subject);
        mail.setText(text);
        queue.add(mail);
    }
}