在项目中经常会遇到SpringBoot推送消息的业务,除了站内推送通知,邮件推送也是一种常见的方式,本次小鹿就带大家实现邮件推送。
引入依赖
<!-- spring mail -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-mail</artifactId>
</dependency>
<!-- thymeleaf -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-thymeleaf</artifactId>
</dependency>
spring-boot-starter-mail
:- 作用:提供了使用Spring Framework的邮件发送功能的起步依赖。
- 功能:使得在Spring Boot应用中可以轻松地配置和使用邮件发送功能,包括发送简单文本邮件、HTML邮件、附件邮件等。
- 使用:结合Spring的邮件模块,你可以方便地在你的应用程序中集成邮件发送功能,无论是用于发送通知、验证邮件还是其他目的。
spring-boot-starter-thymeleaf
:- 作用:提供了使用Thymeleaf模板引擎的起步依赖。
- 功能:Thymeleaf是一种流行的Java模板引擎,用于在Web应用中创建动态HTML模板。
- 使用:结合Spring Boot和Thymeleaf,你可以使用Thymeleaf的模板语言来生成动态内容,比如渲染服务器端数据到HTML页面上,以便在Web应用中更灵活地展示数据。
在项目中,使用第二个依赖再结合静态的html文件就可以实现,将邮件以预定义模板的形式发送出去。
在实际中只需要将对应的值以Map的方式填入到对应字段中即可,别急~接下来小鹿会带大家实现的。
配置
在项目配置中加入如下配置
yml格式如下:
spring:
# 邮箱配置
mail:
host: smtp.qq.com
# 用户名 替换成你实际的用户名
username: test@foxmail.com
# 授权码 可以去官方申请 不是个人邮箱密码
password: xxxxxxxxxx
application.properties文件格式如下:
# 需要开启 smtp qq邮箱为例
spring.mail.host=smtp.qq.com
spring.mail.port=465
# 发件人的邮箱
spring.mail.username=xxxxx
# qq 邮箱的第三方授权码 并非个人密码
spring.mail.password=xxxx
#开启ssl 否则 503 错误 但是实际测试发现其实不加也不会报错 但是最好还是加上
spring.mail.properties.mail.smtp.ssl.enable=true
代码具体实现
创建邮件实体封装类
package com.ican.model.dto;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.Map;
/**
* 邮箱DTO
* @author xiayexiaolu
*/
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
@ApiModel(description = "邮箱DTO")
public class MailDTO {
/**
* 接收者邮箱号
*/
@ApiModelProperty(value = "接收者邮箱号")
private String toEmail;
/**
* 主题
*/
@ApiModelProperty(value = "主题")
private String subject;
/**
* 内容
*/
@ApiModelProperty(value = "内容")
private String content;
/**
* 内容信息
*/
@ApiModelProperty(value = "内容信息")
private Map<String, Object> contentMap;
/**
* 邮件模板
*/
@ApiModelProperty(value = "邮件模板")
private String template;
}
创建邮件服务接口并实现
package com.ican.service;
import com.ican.model.dto.MailDTO;
/**
* 邮件服务接口
*
* @author xiaoyexiaolu
**/
public interface EmailService {
/**
* 发送简单邮件
*
* @param mailDTO 邮件信息
*/
void sendSimpleMail(MailDTO mailDTO);
/**
* 发送HTML邮件
*
* @param mailDTO 邮件信息
*/
void sendHtmlMail(MailDTO mailDTO);
}
对接口进行实现,下面为模板代码,可直接使用:
package com.ican.service.impl;
import com.ican.model.dto.MailDTO;
import com.ican.service.EmailService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.mail.SimpleMailMessage;
import org.springframework.mail.javamail.JavaMailSender;
import org.springframework.mail.javamail.MimeMessageHelper;
import org.springframework.stereotype.Service;
import org.thymeleaf.TemplateEngine;
import org.thymeleaf.context.Context;
import javax.mail.MessagingException;
import javax.mail.internet.MimeMessage;
/**
* 邮件服务接口实现类
*
* @author xiayexiaolu
**/
@Service
public class EmailServiceImpl implements EmailService {
/**
* 邮箱号
*/
@Value("${spring.mail.username}")
private String email;
@Autowired
private JavaMailSender javaMailSender;
@Autowired
private TemplateEngine templateEngine;
@Override
public void sendSimpleMail(MailDTO mailDTO) {
SimpleMailMessage simpleMail = new SimpleMailMessage();
simpleMail.setFrom(email);
simpleMail.setTo(mailDTO.getToEmail());
simpleMail.setSubject(mailDTO.getSubject());
simpleMail.setText(mailDTO.getContent());
javaMailSender.send(simpleMail);
}
@Override
public void sendHtmlMail(MailDTO mailDTO) {
try {
MimeMessage mimeMessage = javaMailSender.createMimeMessage();
MimeMessageHelper mimeMessageHelper = new MimeMessageHelper(mimeMessage);
Context context = new Context();
context.setVariables(mailDTO.getContentMap());
String process = templateEngine.process(mailDTO.getTemplate(), context);
mimeMessageHelper.setFrom(email);
mimeMessageHelper.setTo(mailDTO.getToEmail());
mimeMessageHelper.setSubject(mailDTO.getSubject());
mimeMessageHelper.setText(process, true);
javaMailSender.send(mimeMessage);
} catch (MessagingException e) {
e.printStackTrace();
}
}
}
其实到这里发送邮件就已经能用了,但是如果使用原生发送邮件的方式可能会有少许缺点。使用消息队列有以下好处
- 异步处理:通过消息队列,你可以将邮件发送操作异步化,即使发送邮件的过程比较耗时,也不会阻塞主线程,提高了应用程序的响应速度和吞吐量。
- 解耦:使用消息队列可以将邮件发送操作解耦合,发送邮件的业务逻辑与其他业务逻辑相互独立。这意味着你可以轻松地更改或扩展邮件发送的实现方式,而不影响其他业务逻辑。
- 负载均衡:通过消息队列,你可以将邮件发送请求分发到多个邮件发送服务节点上,从而实现负载均衡,提高了系统的稳定性和可用性。
- 削峰填谷:在高并发情况下,邮件发送请求可能会突然增加,而消息队列可以帮助平滑处理这种突发情况,避免邮件服务器过载。
- 失败处理:使用消息队列可以更好地处理邮件发送失败的情况。如果邮件发送失败,你可以通过消息队列实现重试机制或者将失败的消息重新放回队列,以便稍后再次尝试发送。
使用消息队列实现邮件发送
额外引入依赖
<!-- spring amqp -->
<dependency>
<groupId>cn.dev33</groupId>
<artifactId>sa-token-spring-boot-starter</artifactId>
<version>${saToken.version}</version>
</dependency>
这个依赖会自动地添加所需的 RabbitMQ 客户端库,并配置好Spring Boot的AMQP支持。
在配置中配置连接
spring:
# rabbitmq配置
rabbitmq:
host: localhost
port: 5672
username: guest
password: guest
listener:
simple:
retry:
enabled: true
# 重试间隔时间
initial-interval: 3000
# 最大重试次数
max-attempts: 3
创建邮件消费者
package com.ican.consumer;
import com.ican.model.dto.MailDTO;
import com.ican.service.EmailService;
import org.springframework.amqp.core.ExchangeTypes;
import org.springframework.amqp.rabbit.annotation.Exchange;
import org.springframework.amqp.rabbit.annotation.Queue;
import org.springframework.amqp.rabbit.annotation.QueueBinding;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.messaging.handler.annotation.Payload;
import org.springframework.stereotype.Component;
import static com.ican.constant.MqConstant.*;
/**
* 邮件消费者
* @author xiayexiaolu
*/
@Component
public class EmailConsumer {
@Autowired
private EmailService emailService;
@RabbitListener(bindings = {
@QueueBinding(
value = @Queue(value = EMAIL_SIMPLE_QUEUE, durable = "true", autoDelete = "false"),
exchange = @Exchange(value = EMAIL_EXCHANGE, type = ExchangeTypes.TOPIC),
key = EMAIL_SIMPLE_KEY
)})
public void listenSendSimpleEmail(@Payload MailDTO mail) {
emailService.sendSimpleMail(mail);
}
@RabbitListener(bindings = {
@QueueBinding(
value = @Queue(value = EMAIL_HTML_QUEUE, durable = "true", autoDelete = "false"),
exchange = @Exchange(value = EMAIL_EXCHANGE, type = ExchangeTypes.TOPIC),
key = EMAIL_HTML_KEY
)})
public void listenSendHtmlEmail(@Payload MailDTO mail) {
emailService.sendHtmlMail(mail);
}
}
@Component
注解表示这是一个 Spring 组件,会被 Spring 扫描并纳入到应用程序的上下文中。@Autowired
注解注入了一个EmailService
对象,用于实际发送邮件的逻辑处理。- 使用了
@RabbitListener
注解标注了两个方法,分别用于监听两个队列中的消息。这两个方法分别处理发送简单邮件和发送 HTML 邮件的逻辑。 - 在
@RabbitListener
注解中,通过@QueueBinding
注解配置了队列与交换机的绑定关系,指定了队列的属性和交换机的名称、类型、路由键等信息。 - 在方法参数中使用
@Payload
注解,指定了消息体的类型为MailDTO
,这样方法参数就会自动解析为消息体的内容。
具体使用
首先需要创建一个邮件对象
MailDTO mailDTO = new MailDTO();
mailDTO.setToEmail("目标邮箱");
mailDTO.setSubject("邮件主题");
mailDTO.setTemplate("邮件使用的模板"); //这里需要在之前加入了thymeleaf依赖支持
mailDTO.setContentMap(contentMap);
// 这里的contentMap是一个HashMap 也是最重要的参数,用于将值映射到模板中 具体示例如下图所示
然后直接使用代码:
// 发送HTML邮件
rabbitTemplate.convertAndSend(EMAIL_EXCHANGE, EMAIL_HTML_KEY, mailDTO);
背后的原理
- 邮件发送(生产者):
- 当你执行
rabbitTemplate.convertAndSend(EMAIL_EXCHANGE, EMAIL_HTML_KEY, mailDTO);
时,实际上是将mailDTO
对象发送到了 RabbitMQ 中的EMAIL_EXCHANGE
交换机,并使用EMAIL_HTML_KEY
路由键。 - 这个过程是异步的,即发送操作执行后就会立即返回,而不会等待邮件真正发送完成。
- 当你执行
- 邮件消费者:
- 通过
@RabbitListener
注解,你的邮件消费者监听了名为EMAIL_HTML_QUEUE
的队列。 - 当有消息到达队列时,
listenSendHtmlEmail
方法会被调用,并传入消息体mailDTO
。 - 在
listenSendHtmlEmail
方法中,调用了emailService.sendHtmlMail(mail)
方法来实际发送邮件。
- 通过
- 消息传递:
- RabbitMQ 确保了消息传递的可靠性和顺序性。当你发送一条消息到交换机时,RabbitMQ 会根据路由规则将消息路由到对应的队列中去。
- 邮件消费者监听队列,一旦有消息到达队列,就会立即触发消费者方法的执行,从而实现邮件发送的过程。
总的来说,执行 rabbitTemplate.convertAndSend(EMAIL_EXCHANGE, EMAIL_HTML_KEY, mailDTO);
之后,程序并不会自动调用消费者中的代码,而是将消息发送到 RabbitMQ 中,并触发消费者的监听。一旦有消息到达队列,消费者会立即执行对应的消费方法,完成邮件发送的过程。
小结
本文介绍了如何在Spring Boot项目中实现邮件推送功能。首先,通过引入相关依赖,包括spring-boot-starter-mail
和spring-boot-starter-thymeleaf
,使得项目具备了发送邮件和使用Thymeleaf模板的能力。然后,配置了邮件服务的连接信息,包括邮箱的主机、端口、用户名和授权码等。接着,创建了邮件实体封装类MailDTO
,定义了邮件的相关信息。通过邮件服务接口EmailService
和其实现类EmailServiceImpl
,实现了发送简单邮件和HTML邮件的功能。此外,还介绍了使用消息队列来异步处理邮件发送的好处,以及如何通过RabbitMQ实现邮件发送的异步处理。最后,通过具体的代码示例,展示了如何在项目中使用消息队列发送邮件,并给出了发送邮件的具体步骤。
小鹿的朋友们~大家共同加油呀